clichouse create user query update

db/dialect_clickhouse.go

@@ -133,20 +133,25 @@ func (d clickhouseDialect) OnlyInserts() bool {
 
 func (d clickhouseDialect) CreateUser(tx Tx, ctx context.Context, l *Loader, username string, password string, _database string, readOnly bool) error {
 	user, pass := EscapeIdentifier(username), EscapeIdentifier(password)
-	var q string
+
+	createUserQ := "CREATE USER %s IDENTIFIED BY '%s';"
+	_, err := tx.ExecContext(ctx, createUserQ)
+	if err != nil {
+		return fmt.Errorf("executing query %q: %w", q, err)
+	}
+
+	var grantQ string
 	if readOnly {
-		q = fmt.Sprintf(`
-            CREATE USER %s IDENTIFIED BY '%s';
+		grantQ = fmt.Sprintf(`
             GRANT SELECT ON *.* TO %s;
-        `, user, pass, user)
+        `, user)
 	} else {
-		q = fmt.Sprintf(`
-            CREATE USER %s IDENTIFIED BY '%s';
+		grantQ = fmt.Sprintf(`
             GRANT ALL ON *.* TO %s;
-        `, user, pass, user)
+        `, user)
 	}
 
-	_, err := tx.ExecContext(ctx, q)
+	_, err = tx.ExecContext(ctx, grantQ)
 	if err != nil {
 		return fmt.Errorf("executing query %q: %w", q, err)
 	}