Prepared statements (#6)

* wip

* fix

* rm commented-out code

* extract to file

* add comments

* docs

* fix

* upd

* test

* upd

* flutter_version

* test

* ?

* blessrng

* blessRNG

* experiment

* up

* ultra bless

* .

* maybe closer

* not bruh

* please

* <>

* 777

* pls

* ultra please

* pls

* hope

* fix

* fix

* versions

* fix

* init?

* done?

* fix

* upd

Author: danylo-safonov-solid

example/lib/main.dart

@@ -22,8 +22,9 @@ Future<Response> fetch(Request _) async {
 Future<QueryObjectResult<dynamic>> transaction(Transaction transaction) async {
   await transaction.queryObject(
     'UPDATE public."User" '
-    "SET username='user${transaction.hashCode}' "
+    r'SET username=$1 '
     "WHERE last_name='user'",
+    ["'user${transaction.hashCode}'"],
   );
   await Future.delayed(const Duration(seconds: 10));
 

lib/deno_postgres_interop.dart

@@ -4,6 +4,7 @@ library;
 export 'src/client.dart';
 export 'src/isolation_level.dart';
 export 'src/query_client.dart';
+export 'src/query_object.dart' show QueryArguments;
 export 'src/query_object_result.dart';
 export 'src/transaction.dart';
 export 'src/transaction_options.dart';

lib/src/query_client.dart

@@ -1,6 +1,7 @@
 import 'dart:js_interop';
 import 'dart:js_util';
 
+import 'package:deno_postgres_interop/src/query_object.dart';
 import 'package:deno_postgres_interop/src/query_object_result.dart';
 import 'package:deno_postgres_interop/src/transaction.dart';
 import 'package:deno_postgres_interop/src/transaction_options.dart';
@@ -46,9 +47,9 @@ extension QueryClientProps on QueryClient {
   }
 
   /// [[email protected]/QueryClient/queryObject](https://deno.land/x/[email protected]/mod.ts?s=QueryClient#method_queryObject_0).
-  Future<QueryObjectResult<T>> queryObject<T>(String query) => callFutureMethod(
-        this,
-        'queryObject',
-        [query],
-      );
+  Future<QueryObjectResult<T>> queryObject<T>(
+    String query, [
+    QueryArguments? arguments,
+  ]) =>
+      queryObjectCommon(this, query, arguments);
 }

lib/src/query_object.dart

@@ -0,0 +1,36 @@
+import 'package:deno_postgres_interop/deno_postgres_interop.dart';
+import 'package:deno_postgres_interop/src/util.dart';
+
+/// [[email protected]/QueryArguments](https://deno.land/x/[email protected]/query/query.ts?s=QueryArguments)
+typedef QueryArguments = Object;
+
+/// Common method between all Clients.
+///
+/// [[email protected]/Transaction/queryObject](https://deno.land/x/[email protected]/mod.ts?s=Transaction#method_queryObject_0).
+/// [[email protected]/QueryClient/queryObject](https://deno.land/x/[email protected]/mod.ts?s=QueryClient#method_queryObject_0).
+Future<QueryObjectResult<T>> queryObjectCommon<T>(
+  Object queryable,
+  String query, [
+  QueryArguments? arguments,
+]) {
+  final isCorrectType = arguments is List ||
+      arguments is Map<String, dynamic> ||
+      arguments == null;
+
+  if (!isCorrectType) {
+    throw ArgumentError.value(
+      arguments,
+      'arguments',
+      'Accepted types are List<any> and Map<String, any>.',
+    );
+  }
+
+  return callFutureMethod(
+    queryable,
+    'queryObject',
+    [
+      query,
+      if (arguments != null) arguments,
+    ],
+  );
+}

lib/src/transaction.dart

@@ -1,5 +1,6 @@
 import 'dart:js_interop';
 
+import 'package:deno_postgres_interop/src/query_object.dart';
 import 'package:deno_postgres_interop/src/query_object_result.dart';
 import 'package:deno_postgres_interop/src/util.dart';
 
@@ -16,9 +17,9 @@ extension TransactionProps on Transaction {
   Future<void> commit() => callFutureMethod(this, 'commit');
 
   /// [[email protected]/Transaction/queryObject](https://deno.land/x/[email protected]/mod.ts?s=Transaction#method_queryObject_0).
-  Future<QueryObjectResult<T>> queryObject<T>(String query) => callFutureMethod(
-        this,
-        'queryObject',
-        [query],
-      );
+  Future<QueryObjectResult<T>> queryObject<T>(
+    String query, [
+    QueryArguments? arguments,
+  ]) =>
+      queryObjectCommon(this, query, arguments);
 }