use execute instead of prepareMultiple

Author: stevenctl

packages/sqlite_async/lib/src/common/connection/sync_sqlite_connection.dart

@@ -166,18 +166,10 @@ final class _UnsafeSyncContext extends UnscopedContext {
   }
 
   @override
-  Future<void> executeMultiple(String sql) async {
-    task.timeSync('executeBatch', () {
-      final statements = db.prepareMultiple(sql);
-      try {
-        for (var statement in statements) {
-          task.timeSync('iteration', () => statement.execute());
-        }
-      } finally {
-        for (var statement in statements) {
-          statement.dispose();
-        }
-      }
+  Future<void> executeMultiple(String sql,
+      [List<Object?> parameters = const []]) async {
+    task.timeSync('executeMultiple', () {
+      db.execute(sql, parameters);
     }, sql: sql);
   }
 }

packages/sqlite_async/lib/src/impl/context.dart

@@ -12,7 +12,7 @@ import '../sqlite_connection.dart';
 abstract base class UnscopedContext implements SqliteReadContext {
   Future<ResultSet> execute(String sql, List<Object?> parameters);
   Future<void> executeBatch(String sql, List<List<Object?>> parameterSets);
-  Future<void> executeMultiple(String sql);
+  Future<void> executeMultiple(String sql, List<Object?> parameters);
 
   /// Returns an [UnscopedContext] useful as the outermost transaction.
   ///
@@ -145,9 +145,10 @@ final class ScopedWriteContext extends ScopedReadContext
   }
 
   @override
-  Future<void> executeMultiple(String sql) {
+  Future<void> executeMultiple(String sql,
+      [List<Object?> parameters = const []]) async {
     _checkNotLocked();
-    return _context.executeMultiple(sql);
+    return await _context.executeMultiple(sql, parameters);
   }
 
   @override

packages/sqlite_async/lib/src/native/database/native_sqlite_connection_impl.dart

@@ -277,18 +277,11 @@ final class _UnsafeContext extends UnscopedContext {
   }
 
   @override
-  Future<void> executeMultiple(String sql) async {
+  Future<void> executeMultiple(String sql,
+      [List<Object?> parameters = const []]) async {
     return computeWithDatabase((db) async {
-      final statements = db.prepareMultiple(sql);
-      try {
-        for (var statement in statements) {
-          statement.execute();
-        }
-      } finally {
-        for (var statement in statements) {
-          statement.dispose();
-        }
-      }
+      // execute allows multiple statements, but does not return results.
+      db.execute(sql, parameters);
     });
   }
 }

packages/sqlite_async/lib/src/sqlite_connection.dart

@@ -76,8 +76,9 @@ abstract interface class SqliteWriteContext extends SqliteReadContext {
   /// parameter set.
   Future<void> executeBatch(String sql, List<List<Object?>> parameterSets);
 
-  // Execute multiple SQL statements from a single string, sequentially.
-  Future<void> executeMultiple(String sql);
+  // Execute a query that potentially contains multiple statements.
+  Future<void> executeMultiple(String sql,
+      [List<Object?> parameters = const []]);
 
   /// Open a read-write transaction on this write context.
   ///

packages/sqlite_async/lib/src/sqlite_queries.dart

@@ -137,9 +137,10 @@ mixin SqliteQueries implements SqliteWriteContext, SqliteConnection {
   }
 
   @override
-  Future<void> executeMultiple(String sql) {
+  Future<void> executeMultiple(String sql,
+      [List<Object?> parameters = const []]) {
     return writeTransaction((tx) async {
-      return tx.executeMultiple(sql);
+      return tx.executeMultiple(sql, parameters);
     });
   }
 

packages/sqlite_async/lib/src/web/database.dart

@@ -294,11 +294,13 @@ final class _UnscopedContext extends UnscopedContext {
   }
 
   @override
-  Future<void> executeMultiple(String sql) {
+  Future<void> executeMultiple(String sql,
+      [List<Object?> parameters = const []]) {
     return _task.timeAsync('executeMultiple', sql: sql, () {
       return wrapSqliteException(() async {
-        await _database._database.executeMultiple(
+        await _database._database.execute(
           sql,
+          parameters: parameters,
           token: _lock,
           checkInTransaction: _checkInTransaction,
         );

packages/sqlite_async/pubspec.yaml

@@ -5,15 +5,6 @@ repository: https://github.com/powersync-ja/sqlite_async.dart
 environment:
   sdk: ">=3.5.0 <4.0.0"
 
-# TODO : Remove this override when the changes are merged and published.
-dependency_overrides:
-  sqlite3_web:
-    git:
-      url: https://github.com/stevenctl/sqlite3.dart
-      ref: stevenctl/execute-multi-support
-      path: sqlite3_web
-
-
 topics:
   - sqlite
   - async

packages/sqlite_async/test/basic_test.dart

@@ -331,11 +331,11 @@ void main() {
       expect(result.rows[0][1], equals('test returning without params'));
     });
 
-    test('execute handles multiple statements', () async {
+    test('executeMultiple handles multiple statements', () async {
       final db = await testUtils.setupDatabase(path: path);
       await createTables(db);
 
-      await db.execute('''
+      await db.executeMultiple('''
         INSERT INTO test_data(description) VALUES('row1');
         INSERT INTO test_data(description) VALUES('row2');
       ''');