disable 'snapshot' mode for create query (#369)

Author: yl-lisen

src/Interpreters/executeQuery.cpp

@@ -488,6 +488,10 @@ static std::tuple<ASTPtr, BlockIO> executeQueryImpl(
             begin = recovered_query.data();
             end = recovered_query.data() + recovered_query.size();
         }
+
+        /// In snapshot mode, all stream query (except create query) will be executed in 'table' mode
+        if (settings.query_mode.value == "snapshot")
+            context->setSetting("query_mode", ast->as<ASTCreateQuery>() ? Field{"stream"} : Field{"table"});
         /// proton: ends
 
         if (auto txn = context->getCurrentTransaction())

src/Server/HTTPHandler.cpp

@@ -990,9 +990,9 @@ bool DynamicQueryHandler::customizeQueryParam(ContextMutablePtr context, const s
 std::string DynamicQueryHandler::getQuery(HTTPServerRequest & request, HTMLForm & params, ContextMutablePtr context)
 {
     /// proton: starts
-    /// set query_mode to 'table' if snapshot_mode is on
+    /// set query_mode to 'snapshot' if snapshot_mode is on
     if (snapshot_mode)
-        context->setSetting("query_mode", Field("table"));
+        context->setSetting("query_mode", Field("snapshot"));
     /// proton: ends
 
     if (likely(!startsWith(request.getContentType(), "multipart/form-data")))

src/Server/TCPHandler.cpp

@@ -1390,11 +1390,9 @@ void TCPHandler::receiveQuery()
     }
     query_context->applySettingsChanges(settings_changes);
 
-    /// If TCP server runs in snapshot mode, all stream query will be executed in 'hist' mode mode
+    /// set query_mode to 'snapshot' if snapshot_mode is on
     if (snapshot_mode)
-    {
-        query_context->setSetting("query_mode", Field{"table"});
-    }
+        query_context->setSetting("query_mode", Field{"snapshot"});
 
     /// Use the received query id, or generate a random default. It is convenient
     /// to also generate the default OpenTelemetry trace id at the same time, and