Function query

nodejs/test/e2e/session_fs_sqlite.e2e.test.ts:204–246

(
                queryType: SessionFsSqliteQueryType,
                query: string,
                params?: Record<string, string | number | null>
            )

        },
        sqlite: {
            async query(
                queryType: SessionFsSqliteQueryType,
                query: string,
                params?: Record<string, string | number | null>
            ): Promise<SessionFsSqliteQueryResult | undefined> {
                sqliteCalls.push({ sessionId: session.sessionId, queryType, query });

                const database = getOrCreateDb();
                const trimmed = query.trim();
                if (trimmed.length === 0) {
                    return undefined;
                }

                switch (queryType) {
                    case "exec":
                        database.exec(trimmed);
                        return undefined;

                    case "query": {
                        const stmt = database.prepare(trimmed);
                        const rows = (params ? stmt.all(params) : stmt.all()) as Record<
                            string,
                            unknown
                        >[];
                        const columns = rows.length > 0 ? Object.keys(rows[0]) : [];
                        return { rows, columns, rowsAffected: 0 };
                    }

                    case "run": {
                        const stmt = database.prepare(trimmed);
                        const result = params ? stmt.run(params) : stmt.run();
                        return {
                            rows: [],
                            columns: [],
                            rowsAffected: Number(result.changes),
                            lastInsertRowid:
                                result.lastInsertRowid !== undefined
                                    ? Number(result.lastInsertRowid)
                                    : undefined,
                        };
                    }
                }
            },
            async exists(): Promise<boolean> {
                return sessionDbs.has(session.sessionId);
            },