Fix ut

client_test.go

@@ -100,19 +100,12 @@ func TestConnection(t *testing.T) {
 	}
 	checkConResp("return 1", resp)
 
-	resp, err = conn.execute(sessionID, "return 1")
+	resp, err = conn.execute(sessionID, "DROP SPACE client_test;")
 	if err != nil {
 		t.Error(err.Error())
 		return
 	}
-	checkConResp("return 1", resp)
-
-	// resp, err = conn.execute(sessionID, "DROP SPACE client_test;")
-	// if err != nil {
-	// 	t.Error(err.Error())
-	// 	return
-	// }
-	// checkConResp( "drop space", resp)
+	checkConResp("drop space", resp)
 
 	res := conn.ping()
 	if res != true {

session_pool.go

@@ -308,6 +308,14 @@ func (pool *SessionPool) newSession() (*Session, error) {
 	if err != nil {
 		return nil, fmt.Errorf("failed to create a new session: %s", err.Error())
 	}
+
+	// If the authentication failed, close the session pool because the pool must have a valid user to work
+	if authResp.GetErrorCode() != 0 {
+		pool.Close()
+		return nil, fmt.Errorf("failed to authenticate the user, error code: %d, error message: %s, the pool has been closed",
+			authResp.ErrorCode, authResp.ErrorMsg)
+	}
+
 	sessID := authResp.GetSessionID()
 	timezoneOffset := authResp.GetTimeZoneOffsetSeconds()
 	timezoneName := authResp.GetTimeZoneName()