summaryrefslogtreecommitdiffstats
path: root/yql/essentials/sql/v1/sql.cpp
diff options
context:
space:
mode:
authorgrigoriypisar <[email protected]>2025-08-28 16:56:17 +0300
committergrigoriypisar <[email protected]>2025-08-28 17:21:58 +0300
commit45c5e8ac55972ded21c846f9e05a3d61d197e3a4 (patch)
tree058b5d184adcc94e57a8262c9dcde768d5589eb7 /yql/essentials/sql/v1/sql.cpp
parent9be8744bb96ab00cbf25afb60ab54db5cbad95dc (diff)
added sql syntax for CREATE / ALTER DROP STREAMING QUERY
Добавлен синтаксис (переиспользован код для inline action): ``` CREATE [OR REPLACE] STREAMING QUERY [IF NOT EXISTS] query_name [WITH ( key = value ... )] AS DO BEGIN ... END DO; ALTER STREAMING QUERY [IF EXISTS] query_name [SET( key = value ... )] [AS DO BEGIN ... END DO]; DROP STREAMING QUERY [IF EXISTS] query_name; ``` commit_hash:29fa6aa7e61ecf45112480fe3c1df8fab542354e
Diffstat (limited to 'yql/essentials/sql/v1/sql.cpp')
-rw-r--r--yql/essentials/sql/v1/sql.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/yql/essentials/sql/v1/sql.cpp b/yql/essentials/sql/v1/sql.cpp
index 3d8951cb83e..7f60d87d6a1 100644
--- a/yql/essentials/sql/v1/sql.cpp
+++ b/yql/essentials/sql/v1/sql.cpp
@@ -184,6 +184,9 @@ bool NeedUseForAllStatements(const TRule_sql_stmt_core::AltCase& subquery) {
case TRule_sql_stmt_core::kAltSqlStmtCore60: // drop transfer
case TRule_sql_stmt_core::kAltSqlStmtCore61: // alter database
case TRule_sql_stmt_core::kAltSqlStmtCore62: // show create table
+ case TRule_sql_stmt_core::kAltSqlStmtCore63: // create streaming query
+ case TRule_sql_stmt_core::kAltSqlStmtCore64: // alter streaming query
+ case TRule_sql_stmt_core::kAltSqlStmtCore65: // drop streaming query
return false;
}
}