OP-SQLite support

build/index.d.ts

@@ -1,3 +1,3 @@
-import useDrizzleStudio from "./useDrizzleStudio";
+declare const useDrizzleStudio: any;
 export { useDrizzleStudio };
 //# sourceMappingURL=index.d.ts.map

build/useDrizzleStudio.d.ts

@@ -1,3 +1,12 @@
+import * as opSQLite from "@op-engineering/op-sqlite";
 import * as SQLite from "expo-sqlite";
-export default function useDrizzleStudio(db: SQLite.SQLiteDatabase | null): void;
+type Props = {
+    driver: "expo";
+    db: SQLite.SQLiteDatabase | null;
+} | {
+    driver: "opsqlite";
+    db: opSQLite.DB | null;
+};
+export default function useDrizzleStudio(props: Props): void;
+export {};
 //# sourceMappingURL=useDrizzleStudio.d.ts.map

package.json

@@ -25,15 +25,15 @@
         "expo-module.config.json"
     ],
     "license": "MIT",
-    "dependencies": {
-        "expo-sqlite": "^15.0.3"
-    },
+    "dependencies": {},
     "devDependencies": {
         "expo": "~52.0.0",
         "expo-module-scripts": "^3.1.0",
         "typescript": "^5.1.3"
     },
     "peerDependencies": {
-        "expo": "*"
+        "@op-engineering/op-sqlite": "^10.1.0",
+        "expo": "*",
+        "expo-sqlite": "^15.0.3"
     }
 }

src/useDrizzleStudio.tsx

@@ -1,8 +1,13 @@
+import * as opSQLite from "@op-engineering/op-sqlite";
 import * as SQLite from "expo-sqlite";
 import { useDevToolsPluginClient } from "expo/devtools";
 import { useEffect } from "react";
 
-export default function useDrizzleStudio(db: SQLite.SQLiteDatabase | null) {
+type Props =
+    | { driver: "expo"; db: SQLite.SQLiteDatabase | null }
+    | { driver: "opsqlite"; db: opSQLite.DB | null };
+
+export default function useDrizzleStudio(props: Props) {
     const client = useDevToolsPluginClient("expo-drizzle-studio-plugin");
 
     const transferData = async (e: {
@@ -11,17 +16,31 @@ export default function useDrizzleStudio(db: SQLite.SQLiteDatabase | null) {
         arrayMode: boolean;
         id: string;
     }) => {
-        if (!db) return;
+        if (!props.db) return;
+        let data: any[] = [];
+
         try {
-            const statement = await db.prepareAsync(e.sql);
-            let executed;
-            if (e.arrayMode) {
-                executed = await statement.executeForRawResultAsync(e.params);
+            if (props.driver === "expo") {
+                const statement = await props.db.prepareAsync(e.sql);
+                let executed;
+                if (e.arrayMode) {
+                    executed = await statement.executeForRawResultAsync(
+                        e.params,
+                    );
+                } else {
+                    executed = await statement.executeAsync(e.params);
+                }
+
+                data = await executed.getAllAsync();
             } else {
-                executed = await statement.executeAsync(e.params);
+                if (e.arrayMode) {
+                    data = await props.db.executeRaw(e.sql, e.params);
+                } else {
+                    const executed = await props.db.execute(e.sql, e.params);
+                    data = executed.rows;
+                }
             }
 
-            const data = await executed.getAllAsync();
             client?.sendMessage(`transferData-${e.id}`, { from: "app", data });
         } catch (error) {
             console.error(error);