(self, params: Any)
| 263 | return _to_session_fs_error(exc) |
| 264 | |
| 265 | async def sqlite_query(self, params: Any) -> _GeneratedSqliteQueryResult: |
| 266 | # SQLite methods intentionally skip toSessionFsError wrapping — FS errno |
| 267 | # mapping (ENOENT) isn't meaningful for SQL errors and the JSON-RPC layer |
| 268 | # already handles uncaught exceptions. |
| 269 | if not isinstance(self._p, SessionFsSqliteProvider): |
| 270 | return _GeneratedSqliteQueryResult( |
| 271 | columns=[], |
| 272 | rows=[], |
| 273 | rows_affected=0, |
| 274 | error=SessionFSError( |
| 275 | code=SessionFSErrorCode.UNKNOWN, |
| 276 | message="SQLite is not supported by this SessionFs provider", |
| 277 | ), |
| 278 | ) |
| 279 | result = await self._p.sqlite_query( |
| 280 | params.query_type, |
| 281 | params.query, |
| 282 | getattr(params, "params", None), |
| 283 | ) |
| 284 | if result is None: |
| 285 | return _GeneratedSqliteQueryResult( |
| 286 | columns=[], |
| 287 | rows=[], |
| 288 | rows_affected=0, |
| 289 | ) |
| 290 | return _GeneratedSqliteQueryResult( |
| 291 | columns=result.columns, |
| 292 | rows=result.rows, |
| 293 | rows_affected=result.rows_affected, |
| 294 | last_insert_rowid=result.last_insert_rowid, |
| 295 | ) |
| 296 | |
| 297 | async def sqlite_exists(self, params: Any) -> SessionFSSqliteExistsResult: |
| 298 | if not isinstance(self._p, SessionFsSqliteProvider): |
nothing calls this directly
no test coverage detected