Function createDuckDBBridge

frontend/src/lib/python/init.ts:348–454

(duckDBStore: any)

 * Create DuckDB bridge for Python
 */
export function createDuckDBBridge(duckDBStore: any): DuckDBBridge {
  const bridge = {
    async queryToPandas(sql: string): Promise<any> {
      if (!pyodideInstance) {
        throw new Error("Pyodide not initialized");
      }

      // Execute query in DuckDB
      const result = await duckDBStore.executePaginatedQuery(sql, 1, 10000, false, false);
      
      if (!result || !result.data) {
        throw new Error("Query returned no data");
      }

      // Convert to pandas DataFrame
      const dataJson = JSON.stringify({
        columns: result.columns,
        data: result.data
      });

      // Create DataFrame directly in Python
      const pyCode = `
import pandas as pd
import json

_query_result_data = json.loads('''${dataJson}''')
_query_result_df = pd.DataFrame(_query_result_data['data'], columns=_query_result_data['columns'])
_query_result_df
      `;
      
      const df = await pyodideInstance.runPythonAsync(pyCode);
      return df;
    },

    async pandasToTable(df: any, tableName: string): Promise<void> {
      if (!pyodideInstance) {
        throw new Error("Pyodide not initialized");
      }

      // Convert DataFrame to records
      const records = await pyodideInstance.runPython(`
        import json
        json.dumps(${df.name}.to_dict('records'))
      `);

      const data = JSON.parse(records);
      const columns = Object.keys(data[0] || {});
      
      // Convert to format expected by DuckDB
      const rows = data.map((record: any) => columns.map(col => record[col]));
      
      // Create table in DuckDB
      await duckDBStore.loadData(rows, columns, tableName, []);
    },

    getTableNames(): string[] {
      return duckDBStore.getAvailableTables();
    },