Fix CancellableQuery for adapters without cursor support

- Use adapter.execute_query/execute_non_query instead of direct cursor access
- Add has_cursor check in commands.py for streaming CSV/JSON output
- Fixes "'ClientSync' object has no attribute 'cursor'" error with Turso

Author: Maxteabag

sqlit/commands.py

@@ -360,7 +360,12 @@ def cmd_query(
             # For unlimited streaming output (CSV/JSON only), use direct cursor access
             from .services.query import is_select_query
 
-            if max_rows is None and args.format in ("csv", "json") and is_select_query(query):
+            # Check if connection supports cursors (some adapters like Turso don't)
+            has_cursor = hasattr(session.connection, "cursor") and callable(
+                getattr(session.connection, "cursor", None)
+            )
+
+            if max_rows is None and args.format in ("csv", "json") and is_select_query(query) and has_cursor:
                 # Stream directly from cursor for unlimited CSV/JSON
                 cursor = session.connection.cursor()
                 cursor.execute(query)

sqlit/services/cancellable.py

@@ -100,37 +100,22 @@ def execute(
                     raise RuntimeError("Query was cancelled")
                 self._connection = self.adapter.connect(connect_config)
 
-            # Execute query
-            cursor = self._connection.cursor()
-            cursor.execute(self.sql)
-
-            # Check if it's a SELECT query
-            if is_select_query(self.sql) and cursor.description:
-                columns = [col[0] for col in cursor.description]
-
-                if max_rows:
-                    rows = cursor.fetchmany(max_rows + 1)
-                    truncated = len(rows) > max_rows
-                    if truncated:
-                        rows = rows[:max_rows]
-                else:
-                    rows = cursor.fetchall()
-                    truncated = False
-
-                row_list = [tuple(row) for row in rows]
+            # Execute query using adapter methods
+            if is_select_query(self.sql):
+                columns, rows, truncated = self.adapter.execute_query(
+                    self._connection, self.sql, max_rows
+                )
                 return QueryResult(
                     columns=columns,
-                    rows=row_list,
-                    row_count=len(row_list),
+                    rows=rows,
+                    row_count=len(rows),
                     truncated=truncated,
                 )
             else:
                 # Non-SELECT query
-                rows_affected = cursor.rowcount if cursor.rowcount >= 0 else 0
-                try:
-                    self._connection.commit()
-                except Exception:
-                    pass
+                rows_affected = self.adapter.execute_non_query(
+                    self._connection, self.sql
+                )
                 return NonQueryResult(rows_affected=rows_affected)
 
         finally: