diff --git a/common/lib/client_wrapper.ts b/common/lib/client_wrapper.ts
index 68ac21df..1c521158 100644
--- a/common/lib/client_wrapper.ts
+++ b/common/lib/client_wrapper.ts
@@ -22,7 +22,7 @@ export interface ClientWrapper {
   readonly properties: Map<string, any>;
   readonly id: string;
 
-  query(sql: any): Promise<any>;
+  query(sql: string): Promise<any>;
 
   end(): Promise<void>;
 
diff --git a/common/lib/mysql_client_wrapper.ts b/common/lib/mysql_client_wrapper.ts
index 0d94ee62..eb438d53 100644
--- a/common/lib/mysql_client_wrapper.ts
+++ b/common/lib/mysql_client_wrapper.ts
@@ -46,9 +46,10 @@ export class MySQLClientWrapper implements ClientWrapper {
     this.id = uniqueId("MySQLClient_");
   }
 
-  query(sql: any): Promise<any> {
-    this.driverDialect.setQueryTimeout(this.properties, sql);
-    return this.client?.query(sql);
+  query(sql: string): Promise<any> {
+    const query = { sql: sql };
+    this.driverDialect.setQueryTimeout(this.properties, query);
+    return this.client?.query(query);
   }
 
   async queryWithTimeout(sql: string): Promise<any> {
diff --git a/common/lib/pg_client_wrapper.ts b/common/lib/pg_client_wrapper.ts
index 8989315e..f72d6e1f 100644
--- a/common/lib/pg_client_wrapper.ts
+++ b/common/lib/pg_client_wrapper.ts
@@ -41,7 +41,7 @@ export class PgClientWrapper implements ClientWrapper {
     this.id = uniqueId("PgClient_");
   }
 
-  query(sql: any): Promise<any> {
+  query(sql: string): Promise<any> {
     return this.client?.query(sql);
   }
 
diff --git a/common/lib/pool_client_wrapper.ts b/common/lib/pool_client_wrapper.ts
index 12dad3c1..0c59c815 100644
--- a/common/lib/pool_client_wrapper.ts
+++ b/common/lib/pool_client_wrapper.ts
@@ -38,7 +38,7 @@ export class PoolClientWrapper implements ClientWrapper {
     return this.end();
   }
 
-  query(sql: any): Promise<any> {
+  query(sql: string): Promise<any> {
     return this.client?.query(sql);
   }
 
diff --git a/mysql/lib/dialect/mysql2_driver_dialect.ts b/mysql/lib/dialect/mysql2_driver_dialect.ts
index 61b9003d..49887a28 100644
--- a/mysql/lib/dialect/mysql2_driver_dialect.ts
+++ b/mysql/lib/dialect/mysql2_driver_dialect.ts
@@ -68,10 +68,10 @@ export class MySQL2DriverDialect implements DriverDialect {
     }
   }
 
-  setQueryTimeout(props: Map<string, any>, sql?: any, wrapperConnectTimeout?: any) {
-    const timeout = wrapperConnectTimeout ?? props.get(WrapperProperties.WRAPPER_QUERY_TIMEOUT.name);
+  setQueryTimeout(props: Map<string, any>, sql?: any, wrapperQueryTimeout?: any) {
+    const timeout = wrapperQueryTimeout ?? props.get(WrapperProperties.WRAPPER_QUERY_TIMEOUT.name);
     if (timeout && !sql[MySQL2DriverDialect.QUERY_TIMEOUT_PROPERTY_NAME]) {
-      sql[MySQL2DriverDialect.QUERY_TIMEOUT_PROPERTY_NAME] = timeout;
+      sql[MySQL2DriverDialect.QUERY_TIMEOUT_PROPERTY_NAME] = Number(timeout);
     }
   }
 
diff --git a/mysql/lib/dialect/mysql_database_dialect.ts b/mysql/lib/dialect/mysql_database_dialect.ts
index 04fbb34a..01a1a1c6 100644
--- a/mysql/lib/dialect/mysql_database_dialect.ts
+++ b/mysql/lib/dialect/mysql_database_dialect.ts
@@ -120,7 +120,7 @@ export class MySQLDatabaseDialect implements DatabaseDialect {
     try {
       return await ClientUtils.queryWithTimeout(
         targetClient
-          .query({ sql: "SELECT 1" })
+          .query("SELECT 1")
           .then(() => {
             return true;
           })