Skip to content

Commit d1bb0bf

Browse files
authored
Merge branch 'main' into read-parquet
2 parents a3b855a + ee1e005 commit d1bb0bf

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/query/service/src/servers/mysql/mysql_interactive_worker.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -306,6 +306,10 @@ impl<W: AsyncWrite + Send + Unpin> InteractiveWorkerBase<W> {
306306
// Check the query is a federated or driver setup command.
307307
// Here we fake some values for the command which Databend not supported.
308308
fn federated_server_command_check(&self, query: &str) -> Option<DataBlock> {
309+
// INSERT don't need MySQL federated check
310+
if query.len() > 6 && query[..6].eq_ignore_ascii_case("INSERT") {
311+
return None;
312+
}
309313
let federated = MySQLFederated::create();
310314
federated.check(query)
311315
}

0 commit comments

Comments
 (0)