fix(bindings/python): add blocking client related to pyi

.github/workflows/bindings.python.yml

@@ -40,7 +40,7 @@ jobs:
         run: pipenv install --dev
       - name: Check format
         working-directory: bindings/python
-        run: pipenv run black --check .
+        run: pipenv run ruff format --check .
       - name: Setup develop
         working-directory: bindings/python
         run: pipenv run maturin develop

bindings/python/Pipfile

@@ -4,12 +4,12 @@ verify_ssl = true
 name = "pypi"
 
 [packages]
+databend-driver = {path = ".", editable = true}
 
 [dev-packages]
 maturin = "*"
 behave = "*"
-black = "*"
-flake8 = "*"
+ruff = "*"
 
 [requires]
 python_version = "3.11"

bindings/python/package/databend_driver/__init__.py

@@ -13,4 +13,5 @@
 # limitations under the License.
 
 # flake8: noqa
+
 from ._databend_driver import *

bindings/python/package/databend_driver/__init__.pyi

@@ -12,6 +12,8 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+# flake8: noqa
+
 class ServerStats:
     @property
     def total_rows(self) -> int: ...
@@ -59,7 +61,6 @@ class RowIterator:
     async def __anext__(self) -> Row: ...
     def schema(self) -> Schema: ...
 
-# flake8: noqa
 class AsyncDatabendConnection:
     async def info(self) -> ConnectionInfo: ...
     async def version(self) -> str: ...
@@ -68,7 +69,18 @@ class AsyncDatabendConnection:
     async def query_iter(self, sql: str) -> RowIterator: ...
     async def stream_load(self, sql: str, data: list[list[str]]) -> ServerStats: ...
 
-# flake8: noqa
 class AsyncDatabendClient:
     def __init__(self, dsn: str): ...
     async def get_conn(self) -> AsyncDatabendConnection: ...
+
+class BlockingDatabendConnection:
+    def info(self) -> ConnectionInfo: ...
+    def version(self) -> str: ...
+    def exec(self, sql: str) -> int: ...
+    def query_row(self, sql: str) -> Row: ...
+    def query_iter(self, sql: str) -> RowIterator: ...
+    def stream_load(self, sql: str, data: list[list[str]]) -> ServerStats: ...
+
+class BlockingDatabendClient:
+    def __init__(self, dsn: str): ...
+    def get_conn(self) -> BlockingDatabendConnection: ...