feat: add heartbeat to avoid unexpected timeout.

Author: youngsofun

bindings/nodejs/tests/binding.js

@@ -476,7 +476,10 @@ Then("Query should not timeout", { timeout: 30000 }, async function () {
 });
 
 Then("Drop result set should close it", async function () {
-  return;
+  if (DRIVER_VERSION < [0, 30, 3]) {
+    console.log("SKIP");
+    return;
+  }
   const dbName = "drop_result_set_js";
   const n = (1n << 50n) + 1n;
 

bindings/python/tests/asyncio/steps/binding.py

@@ -367,6 +367,9 @@ async def _(context):
 
 @then("Drop result set should close it")
 async def _(context):
+    if DRIVER_VERSION <= (0, 30, 3):
+        print("SKIP")
+        return
     db_name = "drop_result_set_conn"
     n = (1 << 50) + 1
     conn = await context.client.get_conn()

bindings/python/tests/blocking/steps/binding.py

@@ -226,12 +226,13 @@ def _(context):
 @then("Temp table is cleaned up when conn is dropped")
 def _(context):
     test_temp_table(context, 1)
-    test_temp_table(context, 0)
+    if DRIVER_VERSION > (0, 30, 3):
+        test_temp_table(context, 0)
 
 
 def test_temp_table(context, by_close):
     conn = context.client.get_conn()
-    db_name = "temp_table_blocking"
+    db_name = f"temp_table_blocking_{by_close}"
     conn.exec(f"create or replace database {db_name}")
     conn.exec(f"use {db_name}")
     for i in range(10):
@@ -358,6 +359,9 @@ def _(context):
 
 @then("Drop result set should close it")
 def _(context):
+    if DRIVER_VERSION <= (0, 30, 3):
+        print("SKIP")
+        return
     db_name = "drop_result_set_conn"
     dsn = "databend://root:@localhost:8000/?sslmode=disable"
 

bindings/python/tests/cursor/steps/binding.py

@@ -312,6 +312,9 @@ def _(context):
 
 @then("Drop result set should close it")
 def _(context):
+    if DRIVER_VERSION <= (0, 30, 3):
+        print("SKIP")
+        return
     db_name = "drop_result_set_cursor"
     n = (1 << 50) + 1
     sql = f"select * from numbers({n})"