Use proper SqlStorage object for executions

Author: Brayden

src/import/json.ts

@@ -11,6 +11,7 @@ interface JsonData {
 }
 
 export async function importTableFromJsonRoute(
+    sql: SqlStorage,
     operationQueue: any,
     ctx: any,
     processingOperation: { value: boolean },
@@ -58,11 +59,11 @@ export async function importTableFromJsonRoute(
             const values = Object.values(mappedRecord);
             const placeholders = values.map(() => '?').join(', ');
 
-            const sql = `INSERT INTO ${tableName} (${columns.join(', ')}) VALUES (${placeholders})`;
+            const statement = `INSERT INTO ${tableName} (${columns.join(', ')}) VALUES (${placeholders})`;
 
             try {
                 await enqueueOperation(
-                    [{ sql, params: values }],
+                    [{ sql: statement, params: values }],
                     false,
                     false,
                     operationQueue,
@@ -71,8 +72,8 @@ export async function importTableFromJsonRoute(
                 successCount++;
             } catch (error: any) {
                 failedStatements.push({
-                    statement: sql,
-                    error: error.message || 'Unknown error'
+                    statement: statement,
+                    error: error || 'Unknown error'
                 });
             }
         }

src/index.ts

@@ -150,7 +150,7 @@ export class DatabaseDurableObject extends DurableObject {
             if (!tableName) {
                 return createResponse(undefined, 'Table name is required', 400);
             }
-            return importTableFromJsonRoute(this.operationQueue, this.ctx, this.processingOperation, tableName, request);
+            return importTableFromJsonRoute(this.sql, this.operationQueue, this.ctx, this.processingOperation, tableName, request);
         } else {
             return createResponse(undefined, 'Unknown operation', 400);
         }