Accept max_total_rows on Connection / AsyncConnection

Cycle 9 — DBAPI Connection / AsyncConnection now take max_total_rows
and thread it down to the underlying DqliteConnection, so SQLAlchemy
(or any direct DBAPI user) can tune the cumulative row cap without
reaching into private internals.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: antoineleclair

src/dqlitedbapi/aio/connection.py

@@ -17,13 +17,17 @@ def __init__(
         *,
         database: str = "default",
         timeout: float = 10.0,
+        max_total_rows: int | None = 10_000_000,
     ) -> None:
         """Initialize connection (does not connect yet).
 
         Args:
             address: Node address in "host:port" format
             database: Database name to open
             timeout: Connection timeout in seconds (positive, finite)
+            max_total_rows: Cumulative row cap across continuation
+                frames. Forwarded to the underlying DqliteConnection;
+                ``None`` disables the cap.
         """
         import math
 
@@ -32,6 +36,7 @@ def __init__(
         self._address = address
         self._database = database
         self._timeout = timeout
+        self._max_total_rows = max_total_rows
         self._async_conn: DqliteConnection | None = None
         self._closed = False
         # asyncio primitives MUST be created inside the loop they will
@@ -68,6 +73,7 @@ async def _ensure_connection(self) -> DqliteConnection:
                 self._address,
                 database=self._database,
                 timeout=self._timeout,
+                max_total_rows=self._max_total_rows,
             )
             try:
                 await conn.connect()

src/dqlitedbapi/connection.py

@@ -64,6 +64,7 @@ def __init__(
         *,
         database: str = "default",
         timeout: float = 10.0,
+        max_total_rows: int | None = 10_000_000,
     ) -> None:
         """Initialize connection (does not connect yet).
 
@@ -74,6 +75,9 @@ def __init__(
                 and finite; validated here so direct ``Connection(...)``
                 calls don't silently accept bad values that later
                 produce hangs or stranger downstream errors)
+            max_total_rows: Cumulative row cap across continuation
+                frames for a single query. Forwarded to the underlying
+                :class:`DqliteConnection`. ``None`` disables the cap.
         """
         import math
 
@@ -82,6 +86,7 @@ def __init__(
         self._address = address
         self._database = database
         self._timeout = timeout
+        self._max_total_rows = max_total_rows
         self._async_conn: DqliteConnection | None = None
         self._closed = False
         self._loop: asyncio.AbstractEventLoop | None = None
@@ -193,6 +198,7 @@ async def _get_async_connection(self) -> DqliteConnection:
                 self._address,
                 database=self._database,
                 timeout=self._timeout,
+                max_total_rows=self._max_total_rows,
             )
             try:
                 await conn.connect()