sdfsdf

matrixorigin · Sep 4, 2023 · 4c45fd6 · 4c45fd6
1 parent 1203823
commit 4c45fd6
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/pkg/sql/parsers/dialect/mysql/mysql_sql_test.go b/pkg/sql/parsers/dialect/mysql/mysql_sql_test.go
@@ -27,8 +27,8 @@ var (
 		input  string
 		output string
 	}{
-		input:  "create view cte_view as( with t as (select * from MyEmployees) select * from t);",
-		output: "create stream s (a varchar, b varchar) with (type = kafka, topic = user, partion = 1, value = json, bootstrap.servers = 127.0.0.1:62610)",
+		input:  "create connector s with (\"type\"='kafkamo', \"topic\"= 'user', \"partion\" = '1', \"value\"= 'json', \"bootstrap.servers\" = '127.0.0.1:62610');",
+		output: "create connector s with (type = kafkamo, topic = user, partion = 1, value = json, bootstrap.servers = 127.0.0.1:62610)",
 	}
 )
 

diff --git a/pkg/sql/plan/build_ddl.go b/pkg/sql/plan/build_ddl.go
@@ -39,13 +39,13 @@ func genViewTableDef(ctx CompilerContext, stmt *tree.Select) (*plan.TableDef, er
 	var stmtPlan *Plan
 	var err error
 	switch s := stmt.Select.(type) {
-	case *tree.SelectClause:
-		stmtPlan, err = runBuildSelectByBinder(plan.Query_SELECT, ctx, stmt, false)
+	case *tree.ParenSelect:
+		stmtPlan, err = runBuildSelectByBinder(plan.Query_SELECT, ctx, s.Select, false)
 		if err != nil {
 			return nil, err
 		}
-	case *tree.ParenSelect:
-		stmtPlan, err = runBuildSelectByBinder(plan.Query_SELECT, ctx, s.Select, false)
+	default:
+		stmtPlan, err = runBuildSelectByBinder(plan.Query_SELECT, ctx, stmt, false)
 		if err != nil {
 			return nil, err
 		}