From 4e77f1600f55295454e1fcdfc9a153a0c8119e69 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Javier=20Jaramago=20Fern=C3=A1ndez?= Date: Tue, 28 Jan 2025 10:04:23 +0100 Subject: [PATCH] Enable 'CLIENT_DEPRECATE_EOF' capability for SQLite3 backend --- src/SQLite3_Server.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/SQLite3_Server.cpp b/src/SQLite3_Server.cpp index da0949520..2bb7bc70a 100644 --- a/src/SQLite3_Server.cpp +++ b/src/SQLite3_Server.cpp @@ -962,7 +962,8 @@ __run_query: if ((*proxy_sqlite3_get_autocommit)(db)==0) { in_trans = true; } - sess->SQLite3_to_MySQL(resultset, error, affected_rows, &sess->client_myds->myprot, in_trans); + bool deprecate_eof = sess->client_myds->myconn->options.client_flag & CLIENT_DEPRECATE_EOF; + sess->SQLite3_to_MySQL(resultset, error, affected_rows, &sess->client_myds->myprot, in_trans, deprecate_eof); delete resultset; #ifdef TEST_READONLY if (strncasecmp("SELECT",query_no_space,6)) { @@ -1054,7 +1055,7 @@ static void *child_mysql(void *arg) { fds[0].revents=0; fds[0].events=POLLIN|POLLOUT; free(arg); - sess->client_myds->myprot.generate_pkt_initial_handshake(true,NULL,NULL, &sess->thread_session_id, false); + sess->client_myds->myprot.generate_pkt_initial_handshake(true,NULL,NULL, &sess->thread_session_id, true); while (__sync_fetch_and_add(&glovars.shutdown,0)==0) { if (myds->available_data_out()) {