Update pg and enable queryMode extended (#617)

* wip

* wip

* wip

* wip

.changeset/pretty-planes-check.md

@@ -0,0 +1,6 @@
+---
+"@slonik/pg-driver": minor
+"slonik": minor
+---
+
+utilize extended query mode

packages/pg-driver/package.json

@@ -21,9 +21,9 @@
     "@slonik/sql-tag": "^45.5.0",
     "@slonik/types": "^45.5.0",
     "@slonik/utilities": "^45.5.0",
-    "pg-query-stream": "^4.5.5",
+    "pg-query-stream": "^4.6.0",
     "pg-types": "^4.0.2",
-    "pg": "^8.11.5",
+    "pg": "^8.12.0",
     "postgres-array": "^3.0.2"
   },
   "description": "A Node.js PostgreSQL client with strict types, detailed logging and assertions.",

packages/pg-driver/src/factories/createPgDriverFactory.ts

@@ -111,6 +111,8 @@ const createClientConfiguration = (
     options: connectionOptions.options,
     password: connectionOptions.password,
     port: connectionOptions.port,
+    // @ts-expect-error - https://github.com/brianc/node-postgres/pull/3214
+    queryMode: 'extended',
     ssl: false,
     user: connectionOptions.username,
   };

packages/slonik/src/helpers.test/createIntegrationTests.ts

@@ -139,7 +139,7 @@ export const createIntegrationTests = (
     await pool.end();
   });
 
-  test('produces error if multiple statements are passed as the query input', async (t) => {
+  test('produces error if multiple statements are passed as the query input (without parameters)', async (t) => {
     const pool = await createPool(t.context.dsn, {
       driverFactory,
     });
@@ -153,6 +153,24 @@ export const createIntegrationTests = (
     t.true(error instanceof InvalidInputError);
   });
 
+  // The difference between this test and the previous one is that this one is expected to fail before the query is executed.
+  // In case of pg driver, that is because of the { queryMode: 'extended' } setting.
+  test('produces error if multiple statements are passed as the query input (with parameters)', async (t) => {
+    const pool = await createPool(t.context.dsn, {
+      driverFactory,
+    });
+
+    const error = await t.throwsAsync(
+      pool.query(sql.unsafe`
+        SELECT ${1}; SELECT ${2};
+      `),
+    );
+
+    // The actual error is going to be driver specific, e.g.: 'cannot insert multiple commands into a prepared statement'.
+    // However, Slonik will require compatible drivers to throw InputSyntaxError.
+    t.true(error instanceof InputSyntaxError);
+  });
+
   test('NotNullIntegrityConstraintViolationError identifies the table and column', async (t) => {
     const pool = await createPool(t.context.dsn, {
       driverFactory,