Feat(parallel): Support parallel sql executed

.github/workflows/build_linux_arm64_wheels-gh.yml

@@ -29,7 +29,7 @@ jobs:
         run: |
           sudo apt-get update
           sudo apt-get install -y make build-essential libssl-dev zlib1g-dev \
-            libbz2-dev libreadline-dev libsqlite3-dev wget curl llvm \
+            libbz2-dev libreadline-dev wget curl llvm \
             libncursesw5-dev xz-utils tk-dev libxml2-dev libxmlsec1-dev \
             libffi-dev liblzma-dev
       - name: Scan SQLite vulnerabilities with grype

.github/workflows/build_linux_x86_wheels.yml

@@ -29,7 +29,7 @@ jobs:
         run: |
           sudo apt-get update
           sudo apt-get install -y make build-essential libssl-dev zlib1g-dev \
-            libbz2-dev libreadline-dev libsqlite3-dev wget curl llvm \
+            libbz2-dev libreadline-dev wget curl llvm \
             libncursesw5-dev xz-utils tk-dev libxml2-dev libxmlsec1-dev \
             libffi-dev liblzma-dev
       - name: Scan SQLite vulnerabilities with grype
@@ -62,7 +62,7 @@ jobs:
           else
             echo "✅ No SQLite vulnerabilities found"
           fi
-        continue-on-error: true 
+        continue-on-error: true
       - name: Setup pyenv
         run: |
           curl https://pyenv.run | bash

chdb/session/state.py

@@ -4,9 +4,6 @@
 from ..state import sqlitelike as chdb_stateful
 from ..state.sqlitelike import StreamingResult
 
-g_session = None
-g_session_path = None
-
 
 class Session:
     """
@@ -35,21 +32,15 @@ class Session:
         - "mode=ro" would be "--readonly=1" for clickhouse (read-only mode)
 
     Important:
-        - There can be only one session at a time. If you want to create a new session, you need to close the existing one.
-        - Creating a new session will close the existing one.
+        - Multiple sessions can coexist. Each session has its own connection and database context.
+        - Sessions are thread-safe: Multiple threads can safely use the same session concurrently.
+        - Internal mutexes protect concurrent access to the underlying connection and client.
+        - For optimal performance in multi-threaded scenarios, consider creating a separate session for each thread
+          to avoid lock contention, though sharing a session across threads is safe.
     """
 
     def __init__(self, path=None):
         self._conn = None
-        global g_session, g_session_path
-        if g_session is not None:
-            warnings.warn(
-                "There is already an active session. Creating a new session will close the existing one. "
-                "It is recommended to close the existing session before creating a new one. "
-                f"Closing the existing session {g_session_path}"
-            )
-            g_session.close()
-            g_session_path = None
         if path is None:
             self._path = ":memory:"
         else:
@@ -68,8 +59,6 @@ def __init__(self, path=None):
             self._udf_path = ""
             self._conn_str = f"{self._path}"
         self._conn = chdb_stateful.Connection(self._conn_str)
-        g_session = self
-        g_session_path = self._path
 
     def __del__(self):
         self.close()
@@ -102,9 +91,6 @@ def close(self):
         if self._conn is not None:
             self._conn.close()
             self._conn = None
-        global g_session, g_session_path
-        g_session = None
-        g_session_path = None
 
     def cleanup(self):
         """Cleanup session resources with exception handling.

contrib/corrosion-cmake/CMakeLists.txt

@@ -192,7 +192,7 @@ endfunction()
 function(clickhouse_config_crate_flags target_name)
     corrosion_set_env_vars(${target_name} "CFLAGS=${RUST_CFLAGS}")
     corrosion_set_env_vars(${target_name} "CXXFLAGS=${RUST_CXXFLAGS}")
-    corrosion_set_env_vars(${target_name} "RUSTFLAGS=${RUSTFLAGS}")
+    corrosion_set_env_vars(${target_name} "RUSTFLAGS=${RUSTFLAGS} --cfg osslconf=\"OPENSSL_NO_DEPRECATED_3_0\"")
     corrosion_set_env_vars(${target_name} "RUSTDOCFLAGS=${RUSTFLAGS}")
     if (CMAKE_OSX_SYSROOT)
         corrosion_set_env_vars(${target_name} "SDKROOT=${CMAKE_OSX_SYSROOT}")

programs/local/CMakeLists.txt

@@ -4,6 +4,8 @@ set (CLICKHOUSE_LOCAL_SOURCES
     ArrowStreamWrapper.cpp
     ArrowTableReader.cpp
     LocalServer.cpp
+    EmbeddedServer.cpp
+    ChdbClient.cpp
 )
 
 if (NOT USE_PYTHON)
@@ -25,10 +27,11 @@ endif()
 if (USE_PYTHON)
     set (CHDB_SOURCES
         chdb.cpp
-        FormatHelper.cpp
         ListScan.cpp
         LocalChdb.cpp
         LocalServer.cpp
+        EmbeddedServer.cpp
+        ChdbClient.cpp
         NumpyType.cpp
         PandasAnalyzer.cpp
         PandasDataFrame.cpp