Execute overloading

packages/libsql-client-wasm/src/wasm.ts

@@ -2,7 +2,6 @@ import sqlite3InitModule from "@libsql/libsql-wasm-experimental";
 
 import type {
     Database,
-    InitOptions,
     SqlValue,
     Sqlite3Static,
 } from "@libsql/libsql-wasm-experimental";
@@ -18,6 +17,7 @@ import type {
     Value,
     InValue,
     InStatement,
+    InArgs
 } from "@libsql/core/api";
 import { LibsqlError } from "@libsql/core/api";
 import type { ExpandedConfig } from "@libsql/core/config";
@@ -122,7 +122,21 @@ export class Sqlite3Client implements Client {
         this.protocol = "file";
     }
 
-    async execute(stmt: InStatement): Promise<ResultSet> {
+    async execute(stmt: InStatement): Promise<ResultSet>;
+    async execute(sql: string, args?: InArgs): Promise<ResultSet>;
+
+    async execute(stmtOrSql: InStatement | string, args?: InArgs): Promise<ResultSet> {
+      let stmt: InStatement;
+
+      if (typeof stmtOrSql === 'string') {
+        stmt = {
+            sql: stmtOrSql,
+            args: args || []
+        };
+      } else {
+          stmt = stmtOrSql;
+      }
+
         this.#checkNotClosed();
         return executeStmt(this.#getDb(), stmt, this.#intMode);
     }

packages/libsql-client/src/http.ts

@@ -6,6 +6,7 @@ import type {
     ResultSet,
     Transaction,
     IntMode,
+    InArgs
 } from "@libsql/core/api";
 import { TransactionMode, LibsqlError } from "@libsql/core/api";
 import type { ExpandedConfig } from "@libsql/core/config";
@@ -112,7 +113,21 @@ export class HttpClient implements Client {
         return this.#promiseLimitFunction(fn);
     }
 
-    async execute(stmt: InStatement): Promise<ResultSet> {
+    async execute(stmt: InStatement): Promise<ResultSet>;
+    async execute(sql: string, args?: InArgs): Promise<ResultSet>;
+
+    async execute(stmtOrSql: InStatement | string, args?: InArgs): Promise<ResultSet> {
+      let stmt: InStatement;
+
+      if (typeof stmtOrSql === 'string') {
+        stmt = {
+            sql: stmtOrSql,
+            args: args || []
+        };
+      } else {
+          stmt = stmtOrSql;
+      }
+
         return this.limit<ResultSet>(async () => {
             try {
                 const isSchemaDatabasePromise = this.getIsSchemaDatabase();

packages/libsql-client/src/sqlite3.ts

@@ -12,6 +12,7 @@ import type {
     Value,
     InValue,
     InStatement,
+    InArgs
 } from "@libsql/core/api";
 import { LibsqlError } from "@libsql/core/api";
 import type { ExpandedConfig } from "@libsql/core/config";
@@ -105,7 +106,21 @@ export class Sqlite3Client implements Client {
         this.protocol = "file";
     }
 
-    async execute(stmt: InStatement): Promise<ResultSet> {
+    async execute(stmt: InStatement): Promise<ResultSet>;
+    async execute(sql: string, args?: InArgs): Promise<ResultSet>;
+
+    async execute(stmtOrSql: InStatement | string, args?: InArgs): Promise<ResultSet> {
+      let stmt: InStatement;
+
+      if (typeof stmtOrSql === 'string') {
+        stmt = {
+            sql: stmtOrSql,
+            args: args || []
+        };
+      } else {
+          stmt = stmtOrSql;
+      }
+
         this.#checkNotClosed();
         return executeStmt(this.#getDb(), stmt, this.#intMode);
     }
@@ -192,7 +207,21 @@ export class Sqlite3Transaction implements Transaction {
         this.#intMode = intMode;
     }
 
-    async execute(stmt: InStatement): Promise<ResultSet> {
+    async execute(stmt: InStatement): Promise<ResultSet>;
+        async execute(sql: string, args?: InArgs): Promise<ResultSet>;
+
+        async execute(stmtOrSql: InStatement | string, args?: InArgs): Promise<ResultSet> {
+          let stmt: InStatement;
+
+          if (typeof stmtOrSql === 'string') {
+            stmt = {
+                sql: stmtOrSql,
+                args: args || []
+            };
+          } else {
+              stmt = stmtOrSql;
+          }
+
         this.#checkNotClosed();
         return executeStmt(this.#database, stmt, this.#intMode);
     }

packages/libsql-client/src/ws.ts

@@ -7,6 +7,7 @@ import type {
     Transaction,
     ResultSet,
     InStatement,
+    InArgs
 } from "@libsql/core/api";
 import { TransactionMode, LibsqlError } from "@libsql/core/api";
 import type { ExpandedConfig } from "@libsql/core/config";
@@ -167,7 +168,21 @@ export class WsClient implements Client {
         return this.#promiseLimitFunction(fn);
     }
 
-    async execute(stmt: InStatement): Promise<ResultSet> {
+    async execute(stmt: InStatement): Promise<ResultSet>;
+    async execute(sql: string, args?: InArgs): Promise<ResultSet>;
+
+    async execute(stmtOrSql: InStatement | string, args?: InArgs): Promise<ResultSet> {
+      let stmt: InStatement;
+
+      if (typeof stmtOrSql === 'string') {
+        stmt = {
+            sql: stmtOrSql,
+            args: args || []
+        };
+      } else {
+          stmt = stmtOrSql;
+      }
+
         return this.limit<ResultSet>(async () => {
             const streamState = await this.#openStream();
             try {