We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 873844b + 83c7a03 commit ee1e005Copy full SHA for ee1e005
src/query/service/src/servers/mysql/mysql_interactive_worker.rs
@@ -306,6 +306,10 @@ impl<W: AsyncWrite + Send + Unpin> InteractiveWorkerBase<W> {
306
// Check the query is a federated or driver setup command.
307
// Here we fake some values for the command which Databend not supported.
308
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
+ }
313
let federated = MySQLFederated::create();
314
federated.check(query)
315
}
0 commit comments