try fix synchronization check

src/Core/ya.make

@@ -17,7 +17,9 @@ SRCS(
     ExternalTable.cpp
     Field.cpp
     iostream_debug_helpers.cpp
+    MySQLClient.cpp
     MySQLProtocol.cpp
+    MySQLReplication.cpp
     NamesAndTypes.cpp
     PostgreSQLProtocol.cpp
     Settings.cpp

src/DataStreams/ya.make

@@ -11,6 +11,7 @@ NO_COMPILER_WARNINGS()
 SRCS(
     AddingDefaultBlockOutputStream.cpp
     AddingDefaultsBlockInputStream.cpp
+    AddingVersionsBlockOutputStream.cpp
     AsynchronousBlockInputStream.cpp
     BlockIO.cpp
     BlockStreamProfileInfo.cpp

src/Databases/MySQL/MaterializeMySQLSyncThread.h

@@ -1,6 +1,8 @@
 #pragma once
 
+#if !defined(ARCADIA_BUILD)
 #    include "config_core.h"
+#endif
 
 #if USE_MYSQL
 

src/Databases/ya.make

@@ -11,11 +11,15 @@ SRCS(
     DatabaseFactory.cpp
     DatabaseLazy.cpp
     DatabaseMemory.cpp
-    DatabaseMySQL.cpp
     DatabaseOnDisk.cpp
     DatabaseOrdinary.cpp
     DatabasesCommon.cpp
     DatabaseWithDictionaries.cpp
+    MySQL/DatabaseConnectionMySQL.cpp
+    MySQL/DatabaseMaterializeMySQL.cpp
+    MySQL/MaterializeMetadata.cpp
+    MySQL/MaterializeMySQLSettings.cpp
+    MySQL/MaterializeMySQLSyncThread.cpp
 
 )
 

src/Interpreters/MySQL/tests/gtest_create_rewritten.cpp

@@ -22,7 +22,6 @@ static inline ASTPtr tryRewrittenCreateQuery(const String & query, const Context
     ASTPtr ast = parseQuery(external_ddl_parser, query, 0, 0);
 
     Context context = context_;
-    context.unsafeSetCurrentDatabase("default");
     return MySQLInterpreter::InterpreterCreateImpl::getRewrittenQuery(
         *ast->as<ASTExternalDDLQuery>()->external_ddl->as<MySQLParser::ASTCreateQuery>(),
         context, "test_database", "test_database");

src/Interpreters/ya.make

@@ -78,6 +78,7 @@ SRCS(
     InterpreterDropQuery.cpp
     InterpreterExistsQuery.cpp
     InterpreterExplainQuery.cpp
+    InterpreterExternalDDLQuery.cpp
     InterpreterFactory.cpp
     InterpreterGrantQuery.cpp
     InterpreterInsertQuery.cpp
@@ -110,6 +111,7 @@ SRCS(
     MergeJoin.cpp
     MetricLog.cpp
     MutationsInterpreter.cpp
+    MySQL/InterpretersMySQLDDLQuery.cpp
     NullableUtils.cpp
     OptimizeIfChains.cpp
     OptimizeIfWithConstantConditionVisitor.cpp

src/Parsers/ya.make

@@ -66,6 +66,19 @@ SRCS(
     IParserBase.cpp
     Lexer.cpp
     makeASTForLogicalFunction.cpp
+    MySQL/ASTAlterCommand.cpp
+    MySQL/ASTAlterQuery.cpp
+    MySQL/ASTCreateDefines.cpp
+    MySQL/ASTCreateQuery.cpp
+    MySQL/ASTDeclareColumn.cpp
+    MySQL/ASTDeclareConstraint.cpp
+    MySQL/ASTDeclareIndex.cpp
+    MySQL/ASTDeclareOption.cpp
+    MySQL/ASTDeclarePartition.cpp
+    MySQL/ASTDeclarePartitionOptions.cpp
+    MySQL/ASTDeclareReference.cpp
+    MySQL/ASTDeclareSubPartition.cpp
+    MySQL/ASTDeclareTableOptions.cpp
     parseDatabaseAndTableName.cpp
     parseIdentifierOrStringLiteral.cpp
     parseIntervalKind.cpp
@@ -86,6 +99,7 @@ SRCS(
     ParserDropAccessEntityQuery.cpp
     ParserDropQuery.cpp
     ParserExplainQuery.cpp
+    ParserExternalDDLQuery.cpp
     ParserGrantQuery.cpp
     ParserInsertQuery.cpp
     ParserKillQueryQuery.cpp

src/Storages/ya.make

@@ -115,6 +115,7 @@ SRCS(
     StorageLog.cpp
     StorageLogSettings.cpp
     StorageMaterializedView.cpp
+    StorageMaterializeMySQL.cpp
     StorageMemory.cpp
     StorageMerge.cpp
     StorageMergeTree.cpp