fix ci

matrixorigin · Dec 11, 2024 · 450e8e5 · 450e8e5
1 parent 22c78a3
commit 450e8e5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/pkg/frontend/authenticate_test.go b/pkg/frontend/authenticate_test.go
@@ -7126,7 +7126,7 @@ func Test_doDropAccount(t *testing.T) {
 		bh.sql2result["commit;"] = nil
 		bh.sql2result["rollback;"] = nil
 
-		sql := getAccountIdNamesSql + ` and account_name = "acc" order by account_id  for update`
+		sql := getAccountIdNamesSql + ` order by account_id  for update`
 		mrs := newMrsForGetAllAccounts([][]interface{}{
 			{uint64(0), "sys", "open", uint64(1), nil},
 			{uint64(1), "acc", "open", uint64(1), nil},
@@ -7187,7 +7187,7 @@ func Test_doDropAccount(t *testing.T) {
 		bh.sql2result["commit;"] = nil
 		bh.sql2result["rollback;"] = nil
 
-		sql := getAccountIdNamesSql + ` and account_name = "acc" order by account_id  for update`
+		sql := getAccountIdNamesSql + ` order by account_id  for update`
 		bh.sql2result[sql] = newMrsForGetAllAccounts([][]interface{}{})
 
 		sql, _ = getSqlForDeleteAccountFromMoAccount(context.TODO(), mustUnboxExprStr(stmt.Name))
@@ -7234,7 +7234,7 @@ func Test_doDropAccount(t *testing.T) {
 		bh.sql2result["commit;"] = nil
 		bh.sql2result["rollback;"] = nil
 
-		sql := getAccountIdNamesSql + ` and account_name = "acc" order by account_id  for update`
+		sql := getAccountIdNamesSql + ` order by account_id  for update`
 		bh.sql2result[sql] = newMrsForGetAllAccounts([][]interface{}{})
 
 		sql, _ = getSqlForDeleteAccountFromMoAccount(context.TODO(), mustUnboxExprStr(stmt.Name))

diff --git a/pkg/frontend/publication_subscription.go b/pkg/frontend/publication_subscription.go
@@ -628,9 +628,6 @@ func dropPublication(ctx context.Context, bh BackgroundExec, ifExists bool, pubN
 func getAccounts(ctx context.Context, bh BackgroundExec, accName string, forUpdate bool) (idInfoMap map[int32]*pubsub.AccountInfo, nameInfoMap map[string]*pubsub.AccountInfo, err error) {
 	ctx = defines.AttachAccountId(ctx, catalog.System_Account)
 	sql := getAccountIdNamesSql
-	if len(accName) != 0 {
-		sql += fmt.Sprintf(` and account_name = "%s"`, accName)
-	}
 	sql += " order by account_id "
 	if forUpdate {
 		sql += " for update"