From 0fb39cb33faeb71410db3046b7f5c6fa7abf347b Mon Sep 17 00:00:00 2001
From: Guoyu Su <yss2813483011xxl@gmail.com>
Date: Sun, 28 Jun 2026 16:34:09 +0800
Subject: [PATCH] fix(mysql): use milliseconds for tcp keepalive

---
 crates/dbx-core/src/db/mysql.rs | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/crates/dbx-core/src/db/mysql.rs b/crates/dbx-core/src/db/mysql.rs
index d62066bbf..2711dd4ef 100644
--- a/crates/dbx-core/src/db/mysql.rs
+++ b/crates/dbx-core/src/db/mysql.rs
@@ -23,6 +23,7 @@ use crate::types::{
 use super::file_validator::validate_file_path;
 
 pub type MySqlPool = mysql_async::Pool;
+const MYSQL_TCP_KEEPALIVE_MS: u32 = 30_000;
 
 #[derive(Clone, Copy, Debug, Default)]
 pub struct MySqlQueryDialect {
@@ -456,7 +457,7 @@ fn create_pool(
         .stmt_cache_size(0)
         .prefer_socket(false)
         .pool_opts(Some(pool_opts))
-        .tcp_keepalive(Some(30u32))
+        .tcp_keepalive(Some(MYSQL_TCP_KEEPALIVE_MS))
         .setup(mysql_setup_queries(url));
     if let Some(ssl_opts) = mysql_ssl_opts(base_ssl_opts, url, ca_cert_path, &tls_url.files)? {
         builder = builder.ssl_opts(ssl_opts);
@@ -3419,6 +3420,12 @@ UNIQUE KEY(`tenant_id`, `name``part`)
         assert!(mysql_error_should_retry_without_ssl(error));
     }
 
+    #[test]
+    fn mysql_tcp_keepalive_uses_milliseconds_not_seconds() {
+        assert_eq!(MYSQL_TCP_KEEPALIVE_MS, 30_000);
+        assert!(MYSQL_TCP_KEEPALIVE_MS >= 1_000);
+    }
+
     #[test]
     fn mysql_tls_url_strips_client_identity_params_before_driver_parse() {
         let dir = std::env::temp_dir();