feat:parse sql.y

include/common/ttokendef.h

@@ -193,9 +193,9 @@
 #define TK_INTERVAL                       175
 #define TK_COUNT                          176
 #define TK_LAST_ROW                       177
-#define TK_TOPIC                          178
-#define TK_META                           179
-#define TK_ONLY                           180
+#define TK_META                           178
+#define TK_ONLY                           179
+#define TK_TOPIC                          180
 #define TK_CONSUMER                       181
 #define TK_GROUP                          182
 #define TK_DESC                           183

source/libs/parser/inc/sql.y

@@ -538,18 +538,18 @@ sma_stream_opt(A) ::= sma_stream_opt(B) MAX_DELAY duration_literal(C).
 sma_stream_opt(A) ::= sma_stream_opt(B) DELETE_MARK duration_literal(C).          { ((SStreamOptions*)B)->pDeleteMark = releaseRawExprNode(pCxt, C); A = B; }
 
 /************************************************ create/drop topic ***************************************************/
+%type with_meta                                                                   { int32_t }
+%destructor with_meta                                                             { }
+with_meta(A) ::= AS.                                                              { A = 0; }
+with_meta(A) ::= WITH META AS.                                                    { A = 1; }
+with_meta(A) ::= ONLY META AS.                                                    { A = 2; }
+
 cmd ::= CREATE TOPIC not_exists_opt(A) topic_name(B) AS query_or_subquery(C).     { pCxt->pRootNode = createCreateTopicStmtUseQuery(pCxt, A, &B, C); }
-cmd ::= CREATE TOPIC not_exists_opt(A) topic_name(B) AS DATABASE db_name(C).      { pCxt->pRootNode = createCreateTopicStmtUseDb(pCxt, A, &B, &C, 0); }
-cmd ::= CREATE TOPIC not_exists_opt(A) topic_name(B)
-  WITH META AS DATABASE db_name(C).                                               { pCxt->pRootNode = createCreateTopicStmtUseDb(pCxt, A, &B, &C, 1); }
-cmd ::= CREATE TOPIC not_exists_opt(A) topic_name(B)
-  ONLY META AS DATABASE db_name(C).                                               { pCxt->pRootNode = createCreateTopicStmtUseDb(pCxt, A, &B, &C, 2); }
-cmd ::= CREATE TOPIC not_exists_opt(A) topic_name(B)
-  AS STABLE full_table_name(C) where_clause_opt(D).                               { pCxt->pRootNode = createCreateTopicStmtUseTable(pCxt, A, &B, C, 0, D); }
-cmd ::= CREATE TOPIC not_exists_opt(A) topic_name(B)
-  WITH META AS STABLE full_table_name(C) where_clause_opt(D).                     { pCxt->pRootNode = createCreateTopicStmtUseTable(pCxt, A, &B, C, 1, D); }
-cmd ::= CREATE TOPIC not_exists_opt(A) topic_name(B)
-  ONLY META AS STABLE full_table_name(C) where_clause_opt(D).                     { pCxt->pRootNode = createCreateTopicStmtUseTable(pCxt, A, &B, C, 2, D); }
+cmd ::= CREATE TOPIC not_exists_opt(A) topic_name(B) with_meta(D)
+  DATABASE db_name(C).                                                            { pCxt->pRootNode = createCreateTopicStmtUseDb(pCxt, A, &B, &C, D); }
+cmd ::= CREATE TOPIC not_exists_opt(A) topic_name(B) with_meta(E)
+  STABLE full_table_name(C) where_clause_opt(D).                                  { pCxt->pRootNode = createCreateTopicStmtUseTable(pCxt, A, &B, C, E, D); }
+
 cmd ::= DROP TOPIC exists_opt(A) topic_name(B).                                   { pCxt->pRootNode = createDropTopicStmt(pCxt, A, &B); }
 cmd ::= DROP CONSUMER GROUP exists_opt(A) cgroup_name(B) ON topic_name(C).        { pCxt->pRootNode = createDropCGroupStmt(pCxt, A, &B, &C); }
 

source/libs/parser/src/parTokenizer.c

@@ -140,6 +140,7 @@ static SKeyword keywordTable[] = {
     {"MAX_SPEED",            TK_MAX_SPEED},
     {"MERGE",                TK_MERGE},
     {"META",                 TK_META},
+    {"ONLY",                 TK_ONLY},
     {"MINROWS",              TK_MINROWS},
     {"MINUS",                TK_MINUS},
     {"MNODE",                TK_MNODE},