slonik - npm Package Compare versions

Comparing version 43.0.5 to 43.0.6

dist/binders/bindPool.test/connect.test.js

 "use strict";
 /* eslint-disable ava/max-asserts */
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../../factories/createPgDriverFactory");
 const createPoolWithSpy_1 = require("../../helpers.test/createPoolWithSpy");
 const createTestRunner_1 = require("../../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -10,0 +10,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/binders/bindPool.test/interceptors/afterPoolConnection.test.js

@@ -26,9 +26,9 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../../../factories/createPgDriverFactory");
 const createPool_1 = require("../../../factories/createPool");
 const createPoolWithSpy_1 = require("../../../helpers.test/createPoolWithSpy");
 const createTestRunner_1 = require("../../../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
 const sinon = __importStar(require("sinon"));
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -35,0 +35,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/binders/bindPool.test/interceptors/beforePoolConnection.test.js

@@ -26,7 +26,7 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../../../factories/createPgDriverFactory");
 const createPoolWithSpy_1 = require("../../../helpers.test/createPoolWithSpy");
 const createTestRunner_1 = require("../../../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sinon = __importStar(require("sinon"));
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -33,0 +33,0 @@ test('`beforePoolConnection` is called before `connect`', async (t) => {

dist/binders/bindPool.test/transaction.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../../factories/createPgDriverFactory");
 const createPool_1 = require("../../factories/createPool");
 const createPoolWithSpy_1 = require("../../helpers.test/createPoolWithSpy");
 const createTestRunner_1 = require("../../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
 const promises_1 = require("node:timers/promises");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -11,0 +11,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/any.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.any = void 0;
-const createQueryId_1 = require("../utilities/createQueryId");
 const query_1 = require("./query");
+const utilities_1 = require("@slonik/utilities");
 /**
@@ -10,3 +10,3 @@ * Makes a query and expects any number of results.
 const any = async (log, connection, clientConfiguration, slonikSql, inheritedQueryId) => {
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const { rows } = await (0, query_1.query)(log, connection, clientConfiguration, slonikSql, queryId);
@@ -13,0 +13,0 @@ return rows;

dist/connectionMethods/anyFirst.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.anyFirst = void 0;
-const createQueryId_1 = require("../utilities/createQueryId");
 const any_1 = require("./any");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 const anyFirst = async (log, connection, clientConfigurationType, query, inheritedQueryId) => {
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const rows = await (0, any_1.any)(log, connection, clientConfigurationType, query, queryId);
@@ -10,0 +10,0 @@ if (rows.length === 0) {

dist/connectionMethods/anyFirst.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
 const errors_1 = require("@slonik/errors");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -10,0 +10,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/exists.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.exists = void 0;
-const createQueryId_1 = require("../utilities/createQueryId");
 const query_1 = require("./query");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 const exists = async (log, connection, clientConfiguration, slonikQuery, inheritedQueryId) => {
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const { rows } = await (0, query_1.query)(log, connection, clientConfiguration, {
@@ -10,0 +10,0 @@ sql: 'SELECT EXISTS(' + slonikQuery.sql + ')',

dist/connectionMethods/many.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.many = void 0;
-const createQueryId_1 = require("../utilities/createQueryId");
 const query_1 = require("./query");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 /**
@@ -12,3 +12,3 @@ * Makes a query and expects at least 1 result.
 const many = async (log, connection, clientConfiguration, slonikQuery, inheritedQueryId) => {
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const { rows } = await (0, query_1.query)(log, connection, clientConfiguration, slonikQuery, queryId);
@@ -15,0 +15,0 @@ if (rows.length === 0) {

dist/connectionMethods/many.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
 const errors_1 = require("@slonik/errors");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -10,0 +10,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/manyFirst.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.manyFirst = void 0;
-const createQueryId_1 = require("../utilities/createQueryId");
 const many_1 = require("./many");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 const manyFirst = async (log, connection, clientConfigurationType, query, inheritedQueryId) => {
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const rows = await (0, many_1.many)(log, connection, clientConfigurationType, query, queryId);
@@ -10,0 +10,0 @@ if (rows.length === 0) {

dist/connectionMethods/manyFirst.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
 const errors_1 = require("@slonik/errors");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -10,0 +10,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/maybeOne.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.maybeOne = void 0;
-const createQueryId_1 = require("../utilities/createQueryId");
 const query_1 = require("./query");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 /**
@@ -12,3 +12,3 @@ * Makes a query and expects exactly one result.
 const maybeOne = async (log, connection, clientConfiguration, slonikQuery, inheritedQueryId) => {
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const { rows } = await (0, query_1.query)(log, connection, clientConfiguration, slonikQuery, queryId);
@@ -15,0 +15,0 @@ if (rows.length === 0) {

dist/connectionMethods/maybeOne.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
 const errors_1 = require("@slonik/errors");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -10,0 +10,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/maybeOneFirst.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.maybeOneFirst = void 0;
-const createQueryId_1 = require("../utilities/createQueryId");
 const maybeOne_1 = require("./maybeOne");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 /**
@@ -13,3 +13,3 @@ * Makes a query and expects exactly one result.
 const maybeOneFirst = async (log, connection, clientConfiguration, query, inheritedQueryId) => {
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const row = await (0, maybeOne_1.maybeOne)(log, connection, clientConfiguration, query, queryId);
@@ -16,0 +16,0 @@ if (!row) {

dist/connectionMethods/maybeOneFirst.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
 const errors_1 = require("@slonik/errors");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -10,0 +10,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/nestedTransaction.js

@@ -7,3 +7,3 @@ "use strict";
 const state_1 = require("../state");
-const createUid_1 = require("../utilities/createUid");
+const utilities_1 = require("@slonik/utilities");
 const serialize_error_1 = require("serialize-error");
@@ -56,3 +56,3 @@ const execNestedTransaction = async (parentLog, connection, clientConfiguration, handler, newTransactionDepth) => {
     const log = parentLog.child({
-        transactionId: (0, createUid_1.createUid)(),
+        transactionId: (0, utilities_1.generateUid)(),
     });
@@ -59,0 +59,0 @@ try {

dist/connectionMethods/nestedTransaction.test.js

@@ -26,3 +26,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
@@ -32,4 +31,5 @@ const createErrorWithCode_1 = require("../helpers.test/createErrorWithCode");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sinon = __importStar(require("sinon"));
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -36,0 +36,0 @@ test('creates a savepoint', async (t) => {

dist/connectionMethods/one.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.one = void 0;
-const createQueryId_1 = require("../utilities/createQueryId");
 const query_1 = require("./query");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 /**
@@ -13,3 +13,3 @@ * Makes a query and expects exactly one result.
 const one = async (log, connection, clientConfiguration, slonikQuery, inheritedQueryId) => {
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const { rows } = await (0, query_1.query)(log, connection, clientConfiguration, slonikQuery, queryId);
@@ -16,0 +16,0 @@ if (rows.length === 0) {

dist/connectionMethods/one.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
 const errors_1 = require("@slonik/errors");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
 const expect_type_1 = require("expect-type");
 const zod_1 = require("zod");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -12,0 +12,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/oneFirst.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.oneFirst = void 0;
-const createQueryId_1 = require("../utilities/createQueryId");
 const one_1 = require("./one");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 /**
@@ -14,3 +14,3 @@ * Makes a query and expects exactly one result.
 const oneFirst = async (log, connection, clientConfiguration, slonikSql, inheritedQueryId) => {
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const row = await (0, one_1.one)(log, connection, clientConfiguration, slonikSql, queryId);
@@ -17,0 +17,0 @@ const keys = Object.keys(row);

dist/connectionMethods/oneFirst.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
 const errors_1 = require("@slonik/errors");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
 const expect_type_1 = require("expect-type");
 const zod_1 = require("zod");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -12,0 +12,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/query.test/interceptors/beforeQueryExecution.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../../../factories/createPgDriverFactory");
 const createPoolWithMockedQuery_1 = require("../../../helpers.test/createPoolWithMockedQuery");
 const createTestRunner_1 = require("../../../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -9,0 +9,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/query.test/interceptors/transformQuery.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../../../factories/createPgDriverFactory");
 const createPoolWithSpy_1 = require("../../../helpers.test/createPoolWithSpy");
 const createTestRunner_1 = require("../../../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -9,0 +9,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/query.test/interceptors/transformRow.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../../../factories/createPgDriverFactory");
 const createPoolWithMockedQuery_1 = require("../../../helpers.test/createPoolWithMockedQuery");
 const createTestRunner_1 = require("../../../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -9,0 +9,0 @@ const sql = (0, sql_tag_1.createSqlTag)();

dist/connectionMethods/query.test/query.test.js

@@ -27,9 +27,9 @@ "use strict";
 exports.createErrorWithCodeAndConstraint = void 0;
-const createPgDriverFactory_1 = require("../../factories/createPgDriverFactory");
 const createPool_1 = require("../../factories/createPool");
 const createErrorWithCode_1 = require("../../helpers.test/createErrorWithCode");
 const createTestRunner_1 = require("../../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sql_tag_1 = require("@slonik/sql-tag");
 const sinon = __importStar(require("sinon"));
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -36,0 +36,0 @@ const createErrorWithCodeAndConstraint = (code) => {

dist/connectionMethods/transaction.js

@@ -8,4 +8,4 @@ "use strict";
 const state_1 = require("../state");
-const createUid_1 = require("../utilities/createUid");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 const serialize_error_1 = require("serialize-error");
@@ -65,3 +65,3 @@ const execTransaction = async (parentLog, connection, clientConfiguration, handler) => {
 const transaction = async (parentLog, connection, clientConfiguration, handler, transactionRetryLimit) => {
-    const transactionId = (0, createUid_1.createUid)();
+    const transactionId = (0, utilities_1.generateUid)();
     return transactionContext_1.transactionContext.run({
@@ -68,0 +68,0 @@ transactionId,

dist/connectionMethods/transaction.test.js

@@ -26,3 +26,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
@@ -32,4 +31,5 @@ const createErrorWithCode_1 = require("../helpers.test/createErrorWithCode");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sinon = __importStar(require("sinon"));
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -36,0 +36,0 @@ test('commits successful transaction', async (t) => {

dist/factories/createConnection.js

@@ -7,4 +7,4 @@ "use strict";
 const state_1 = require("../state");
-const defer_1 = require("../utilities/defer");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 const destroyBoundConnection = (boundConnection) => {
@@ -32,3 +32,3 @@ const boundConnectionMethods = [
 const raceError = async (connection, routine) => {
-    const connectionErrorPromise = (0, defer_1.defer)();
+    const connectionErrorPromise = (0, utilities_1.defer)();
     const onError = (error) => {
@@ -35,0 +35,0 @@ connectionErrorPromise.reject(error);

dist/factories/createConnectionPool.d.ts

@@ -1,3 +0,2 @@
-import { type TypedReadable } from '../types';
-import { type Driver, type DriverClientEventEmitter, type DriverClientState, type DriverQueryResult, type DriverStreamResult } from './createDriverFactory';
+import { type Driver, type DriverClientEventEmitter, type DriverClientState, type DriverQueryResult, type DriverStream, type DriverStreamResult } from '@slonik/driver';
 export type ConnectionPoolClient = {
@@ -13,3 +12,3 @@ acquire: () => void;
     state: () => DriverClientState;
-    stream: (query: string, values?: unknown[]) => TypedReadable<DriverStreamResult>;
+    stream: (query: string, values?: unknown[]) => DriverStream<DriverStreamResult>;
 };
@@ -16,0 +15,0 @@ type ConnectionPoolStateName = 'ACTIVE' | 'ENDING' | 'ENDED';

dist/factories/createConnectionPool.js

@@ -5,4 +5,3 @@ "use strict";
 const Logger_1 = require("../Logger");
-const createUid_1 = require("../utilities/createUid");
-const defer_1 = require("../utilities/defer");
+const utilities_1 = require("@slonik/utilities");
 const promises_1 = require("node:timers/promises");
@@ -19,3 +18,3 @@ const serialize_error_1 = require("serialize-error");
     const waitingClients = [];
-    const id = (0, createUid_1.createUid)();
+    const id = (0, utilities_1.generateUid)();
     let isEnding = false;
@@ -92,3 +91,3 @@ let isEnded = false;
         else {
-            const deferred = (0, defer_1.defer)();
+            const deferred = (0, utilities_1.defer)();
             waitingClients.push({
@@ -95,0 +94,0 @@ deferred,

dist/factories/createPool.js

@@ -8,4 +8,4 @@ "use strict";
 const createConnectionPool_1 = require("./createConnectionPool");
-const createPgDriverFactory_1 = require("./createPgDriverFactory");
 const createPoolConfiguration_1 = require("./createPoolConfiguration");
+const pg_driver_1 = require("@slonik/pg-driver");
 /**
@@ -16,3 +16,3 @@ * @param connectionUri PostgreSQL [Connection URI](https://www.postgresql.org/docs/current/libpq-connect.html#LIBPQ-CONNSTRING).
     const clientConfiguration = (0, createClientConfiguration_1.createClientConfiguration)(connectionUri, clientConfigurationInput);
-    const createDriver = clientConfiguration.driverFactory ?? (0, createPgDriverFactory_1.createPgDriverFactory)();
+    const createDriver = clientConfiguration.driverFactory ?? (0, pg_driver_1.createPgDriverFactory)();
     const driver = await createDriver({
@@ -19,0 +19,0 @@ // TODO resolve name conflict between ClientConfiguration and DriverConfiguration

dist/factories/createTypeParserPreset.d.ts

@@ -1,3 +0,3 @@
-import { type TypeParser } from '../types';
-export declare const createTypeParserPreset: () => readonly TypeParser[];
+import { type DriverTypeParser } from '@slonik/driver';
+export declare const createTypeParserPreset: () => readonly DriverTypeParser[];
 //# sourceMappingURL=createTypeParserPreset.d.ts.map

dist/factories/typeParsers/createBigintTypeParser.d.ts

@@ -1,3 +0,3 @@
-import { type TypeParser } from '../../types';
-export declare const createBigintTypeParser: () => TypeParser;
+import { type DriverTypeParser } from '@slonik/driver';
+export declare const createBigintTypeParser: () => DriverTypeParser;
 //# sourceMappingURL=createBigintTypeParser.d.ts.map

dist/factories/typeParsers/createDateTypeParser.d.ts

@@ -1,3 +0,3 @@
-import { type TypeParser } from '../../types';
-export declare const createDateTypeParser: () => TypeParser;
+import { type DriverTypeParser } from '@slonik/driver';
+export declare const createDateTypeParser: () => DriverTypeParser;
 //# sourceMappingURL=createDateTypeParser.d.ts.map

dist/factories/typeParsers/createIntervalTypeParser.d.ts

@@ -1,3 +0,3 @@
-import { type TypeParser } from '../../types';
-export declare const createIntervalTypeParser: () => TypeParser;
+import { type DriverTypeParser } from '@slonik/driver';
+export declare const createIntervalTypeParser: () => DriverTypeParser;
 //# sourceMappingURL=createIntervalTypeParser.d.ts.map

dist/factories/typeParsers/createNumericTypeParser.d.ts

@@ -1,3 +0,3 @@
-import { type TypeParser } from '../../types';
-export declare const createNumericTypeParser: () => TypeParser;
+import { type DriverTypeParser } from '@slonik/driver';
+export declare const createNumericTypeParser: () => DriverTypeParser;
 //# sourceMappingURL=createNumericTypeParser.d.ts.map

dist/factories/typeParsers/createTimestampTypeParser.d.ts

@@ -1,3 +0,3 @@
-import { type TypeParser } from '../../types';
-export declare const createTimestampTypeParser: () => TypeParser;
+import { type DriverTypeParser } from '@slonik/driver';
+export declare const createTimestampTypeParser: () => DriverTypeParser;
 //# sourceMappingURL=createTimestampTypeParser.d.ts.map

dist/factories/typeParsers/createTimestampWithTimeZoneTypeParser.d.ts

@@ -1,3 +0,3 @@
-import { type TypeParser } from '../../types';
-export declare const createTimestampWithTimeZoneTypeParser: () => TypeParser;
+import { type DriverTypeParser } from '@slonik/driver';
+export declare const createTimestampWithTimeZoneTypeParser: () => DriverTypeParser;
 //# sourceMappingURL=createTimestampWithTimeZoneTypeParser.d.ts.map

dist/helpers.test/createIntegrationTests.d.ts

@@ -1,5 +0,5 @@
-import { type DriverFactory } from '../factories/createDriverFactory';
 import { type TestContextType } from './createTestRunner';
+import { type DriverFactory } from '@slonik/driver';
 import { type TestFn } from 'ava';
 export declare const createIntegrationTests: (test: TestFn<TestContextType>, driverFactory: DriverFactory) => void;
 //# sourceMappingURL=createIntegrationTests.d.ts.map

dist/helpers.test/createTestRunner.d.ts

@@ -1,2 +0,2 @@
-import { type DriverFactory } from '../factories/createDriverFactory';
+import { type DriverFactory } from '@slonik/driver';
 import { type TestFn } from 'ava';
@@ -3,0 +3,0 @@ export type TestContextType = {

dist/index.d.ts

@@ -1,2 +0,2 @@
-export { createDriverFactory, type Driver, type DriverClient, type DriverClientEventEmitter, type DriverClientState, type DriverCommand, type DriverConfiguration, type DriverEventEmitter, type DriverFactory, type DriverNotice, type DriverQueryResult, type DriverStreamResult, } from './factories/createDriverFactory';
+export { createDriverFactory, type Driver, type DriverClient, type DriverClientEventEmitter, type DriverClientState, type DriverCommand, type DriverConfiguration, type DriverEventEmitter, type DriverFactory, type DriverNotice, type DriverQueryResult, type DriverStreamResult, type DriverTypeParser, } from '@slonik/driver';
 export declare const sql: import("@slonik/sql-tag").SqlTag<Record<PropertyKey, import("zod").ZodTypeAny>>;
@@ -11,7 +11,7 @@ export { createPool } from './factories/createPool';
 export { createTimestampWithTimeZoneTypeParser } from './factories/typeParsers/createTimestampWithTimeZoneTypeParser';
-export type { ClientConfiguration, ClientConfigurationInput, CommonQueryMethods, Connection, ConnectionOptions, ConnectionRoutine, DatabaseConnection, DatabasePool, DatabasePoolConnection, DatabaseTransactionConnection, Field, IdentifierNormalizer, Interceptor, MaybePromise, PoolContext, Query, QueryContext, QueryFunction, QueryResult, QueryResultRow, QueryResultRowColumn, TypeNameIdentifier, TypeParser, ValueExpression, } from './types';
-export { parseDsn } from './utilities/parseDsn';
-export { stringifyDsn } from './utilities/stringifyDsn';
+export type { ClientConfiguration, ClientConfigurationInput, CommonQueryMethods, Connection, ConnectionOptions, ConnectionRoutine, DatabaseConnection, DatabasePool, DatabasePoolConnection, DatabaseTransactionConnection, Field, IdentifierNormalizer, Interceptor, MaybePromise, PoolContext, Query, QueryContext, QueryFunction, QueryResult, QueryResultRow, QueryResultRowColumn, TypeNameIdentifier, ValueExpression, } from './types';
 export { BackendTerminatedError, BackendTerminatedUnexpectedlyError, CheckIntegrityConstraintViolationError, ConnectionError, DataIntegrityError, ForeignKeyIntegrityConstraintViolationError, IdleTransactionTimeoutError, InputSyntaxError, IntegrityConstraintViolationError, InvalidConfigurationError, InvalidInputError, NotFoundError, NotNullIntegrityConstraintViolationError, SchemaValidationError, SlonikError, StatementCancelledError, StatementTimeoutError, TupleMovedToAnotherPartitionError, UnexpectedForeignConnectionError, UnexpectedStateError, UniqueIntegrityConstraintViolationError, } from '@slonik/errors';
 export { type ArraySqlToken, type BinarySqlToken, createSqlTag, createSqlTokenSqlFragment, type FragmentSqlToken, type IdentifierSqlToken, isSqlToken, type JsonBinarySqlToken, type JsonSqlToken, type ListSqlToken, type PrimitiveValueExpression, type QuerySqlToken, type SerializableValue, type SqlTag, type SqlToken, type UnnestSqlToken, } from '@slonik/sql-tag';
+export { stringifyDsn } from '@slonik/utilities';
+export { parseDsn } from '@slonik/utilities';
 //# sourceMappingURL=index.d.ts.map

dist/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.isSqlToken = exports.createSqlTokenSqlFragment = exports.createSqlTag = exports.UniqueIntegrityConstraintViolationError = exports.UnexpectedStateError = exports.UnexpectedForeignConnectionError = exports.TupleMovedToAnotherPartitionError = exports.StatementTimeoutError = exports.StatementCancelledError = exports.SlonikError = exports.SchemaValidationError = exports.NotNullIntegrityConstraintViolationError = exports.NotFoundError = exports.InvalidInputError = exports.InvalidConfigurationError = exports.IntegrityConstraintViolationError = exports.InputSyntaxError = exports.IdleTransactionTimeoutError = exports.ForeignKeyIntegrityConstraintViolationError = exports.DataIntegrityError = exports.ConnectionError = exports.CheckIntegrityConstraintViolationError = exports.BackendTerminatedUnexpectedlyError = exports.BackendTerminatedError = exports.stringifyDsn = exports.parseDsn = exports.createTimestampWithTimeZoneTypeParser = exports.createTimestampTypeParser = exports.createNumericTypeParser = exports.createIntervalTypeParser = exports.createDateTypeParser = exports.createBigintTypeParser = exports.createTypeParserPreset = exports.createPool = exports.sql = exports.createDriverFactory = void 0;
+exports.parseDsn = exports.stringifyDsn = exports.isSqlToken = exports.createSqlTokenSqlFragment = exports.createSqlTag = exports.UniqueIntegrityConstraintViolationError = exports.UnexpectedStateError = exports.UnexpectedForeignConnectionError = exports.TupleMovedToAnotherPartitionError = exports.StatementTimeoutError = exports.StatementCancelledError = exports.SlonikError = exports.SchemaValidationError = exports.NotNullIntegrityConstraintViolationError = exports.NotFoundError = exports.InvalidInputError = exports.InvalidConfigurationError = exports.IntegrityConstraintViolationError = exports.InputSyntaxError = exports.IdleTransactionTimeoutError = exports.ForeignKeyIntegrityConstraintViolationError = exports.DataIntegrityError = exports.ConnectionError = exports.CheckIntegrityConstraintViolationError = exports.BackendTerminatedUnexpectedlyError = exports.BackendTerminatedError = exports.createTimestampWithTimeZoneTypeParser = exports.createTimestampTypeParser = exports.createNumericTypeParser = exports.createIntervalTypeParser = exports.createDateTypeParser = exports.createBigintTypeParser = exports.createTypeParserPreset = exports.createPool = exports.sql = exports.createDriverFactory = void 0;
 const sql_tag_1 = require("@slonik/sql-tag");
-var createDriverFactory_1 = require("./factories/createDriverFactory");
-Object.defineProperty(exports, "createDriverFactory", { enumerable: true, get: function () { return createDriverFactory_1.createDriverFactory; } });
+var driver_1 = require("@slonik/driver");
+Object.defineProperty(exports, "createDriverFactory", { enumerable: true, get: function () { return driver_1.createDriverFactory; } });
 exports.sql = (0, sql_tag_1.createSqlTag)();
@@ -24,6 +24,2 @@ var createPool_1 = require("./factories/createPool");
 Object.defineProperty(exports, "createTimestampWithTimeZoneTypeParser", { enumerable: true, get: function () { return createTimestampWithTimeZoneTypeParser_1.createTimestampWithTimeZoneTypeParser; } });
-var parseDsn_1 = require("./utilities/parseDsn");
-Object.defineProperty(exports, "parseDsn", { enumerable: true, get: function () { return parseDsn_1.parseDsn; } });
-var stringifyDsn_1 = require("./utilities/stringifyDsn");
-Object.defineProperty(exports, "stringifyDsn", { enumerable: true, get: function () { return stringifyDsn_1.stringifyDsn; } });
 var errors_1 = require("@slonik/errors");
@@ -55,2 +51,6 @@ Object.defineProperty(exports, "BackendTerminatedError", { enumerable: true, get: function () { return errors_1.BackendTerminatedError; } });
 Object.defineProperty(exports, "isSqlToken", { enumerable: true, get: function () { return sql_tag_2.isSqlToken; } });
+var utilities_1 = require("@slonik/utilities");
+Object.defineProperty(exports, "stringifyDsn", { enumerable: true, get: function () { return utilities_1.stringifyDsn; } });
+var utilities_2 = require("@slonik/utilities");
+Object.defineProperty(exports, "parseDsn", { enumerable: true, get: function () { return utilities_2.parseDsn; } });
 //# sourceMappingURL=index.js.map

dist/integration.test/pg.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const __1 = require("..");
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
 const createIntegrationTests_1 = require("../helpers.test/createIntegrationTests");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const pg_driver_1 = require("@slonik/pg-driver");
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -10,0 +10,0 @@ (0, createIntegrationTests_1.createIntegrationTests)(test, driverFactory);

dist/integration.test/stream.test.js

@@ -27,7 +27,7 @@ "use strict";
 const __1 = require("..");
-const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const pg_driver_1 = require("@slonik/pg-driver");
 const sinon = __importStar(require("sinon"));
 const zod_1 = require("zod");
-const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
+const driverFactory = (0, pg_driver_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
@@ -34,0 +34,0 @@ test('reading stream after a delay', async (t) => {

dist/routines/establishConnection.js

@@ -5,4 +5,4 @@ "use strict";
 const state_1 = require("../state");
-const createUid_1 = require("../utilities/createUid");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 const serialize_error_1 = require("serialize-error");
@@ -18,3 +18,3 @@ const establishConnection = async (parentLog, pool, connectionRetryLimit) => {
             state_1.poolClientStateMap.set(connection, {
-                connectionId: (0, createUid_1.createUid)(),
+                connectionId: (0, utilities_1.generateUid)(),
                 poolId: pool.id(),
@@ -21,0 +21,0 @@ terminated: null,

dist/routines/executeQuery.js

@@ -7,5 +7,4 @@ "use strict";
 const state_1 = require("../state");
-const createQueryId_1 = require("../utilities/createQueryId");
-const defer_1 = require("../utilities/defer");
 const errors_1 = require("@slonik/errors");
+const utilities_1 = require("@slonik/utilities");
 const get_stack_trace_1 = require("get-stack-trace");
@@ -72,3 +71,3 @@ const serialize_error_1 = require("serialize-error");
     }
-    const queryId = inheritedQueryId ?? (0, createQueryId_1.createQueryId)();
+    const queryId = inheritedQueryId ?? (0, utilities_1.generateUid)();
     const log = connectionLogger.child({
@@ -123,3 +122,3 @@ queryId,
     };
-    const activeQuery = (0, defer_1.defer)();
+    const activeQuery = (0, utilities_1.defer)();
     const blockingPromise = poolClientState.activeQuery?.promise ?? null;
@@ -126,0 +125,0 @@ poolClientState.activeQuery = activeQuery;

dist/state.d.ts

 import { type ConnectionPoolClient } from './factories/createConnectionPool';
-import { type DeferredPromise } from './utilities/defer';
+import { type DeferredPromise } from '@slonik/utilities';
 type PoolClientState = {
@@ -4,0 +4,0 @@ activeQuery?: DeferredPromise<null>;

dist/types.d.ts

 /// <reference types="node" />
-/// <reference types="node" />
 import { type ConnectionPoolClient } from './factories/createConnectionPool';
-import { type DriverFactory, type DriverNotice } from './factories/createDriverFactory';
+import { type DriverFactory, type DriverNotice, type DriverStream, type DriverTypeParser } from '@slonik/driver';
 import { type SlonikError } from '@slonik/errors';
 import { type PrimitiveValueExpression, type QuerySqlToken, type SqlToken } from '@slonik/sql-tag';
-import { type Readable } from 'node:stream';
 import { type ConnectionOptions as TlsConnectionOptions } from 'node:tls';
 import { type Logger } from 'roarr';
 import { type z, type ZodTypeAny } from 'zod';
-type StreamDataEvent<T> = {
-    data: T;
-    fields: readonly Field[];
-};
-export interface TypedReadable<T> extends Readable {
-    on(event: 'data', listener: (chunk: StreamDataEvent<T>) => void): this;
-    on(event: string | symbol, listener: (...args: any[]) => void): this;
-    [Symbol.asyncIterator]: () => AsyncIterableIterator<StreamDataEvent<T>>;
-}
-export type StreamHandler<T> = (stream: TypedReadable<T>) => void;
+export type StreamHandler<T> = (stream: DriverStream<T>) => void;
 /**
@@ -126,3 +115,3 @@ * @see https://www.postgresql.org/docs/current/libpq-connect.html#LIBPQ-PARAMKEYWORDS
      */
-    readonly typeParsers: readonly TypeParser[];
+    readonly typeParsers: readonly DriverTypeParser[];
 };
@@ -176,9 +165,2 @@ export type ClientConfigurationInput = Partial<ClientConfiguration>;
 /**
- * @property name Value of "pg_type"."typname" (e.g. "int8", "timestamp", "timestamptz").
- */
-export type TypeParser<T = unknown> = {
-    readonly name: string;
-    readonly parse: (value: string) => T;
-};
-/**
  * @property log Instance of Roarr logger with bound connection context parameters.
@@ -185,0 +167,0 @@ * @property poolId Unique connection pool ID.

package.json

@@ -8,15 +8,12 @@ {
   "dependencies": {
-    "@slonik/errors": "^43.0.5",
-    "@slonik/sql-tag": "^43.0.5",
-    "@types/pg": "^8.11.6",
+    "@slonik/driver": "^43.0.6",
+    "@slonik/errors": "^43.0.6",
+    "@slonik/pg-driver": "^43.0.6",
+    "@slonik/sql-tag": "^43.0.6",
+    "@slonik/utilities": "^43.0.6",
     "get-stack-trace": "^3.1.1",
     "iso8601-duration": "^1.3.0",
-    "pg": "^8.11.5",
-    "pg-query-stream": "^4.5.5",
-    "pg-types": "^4.0.2",
-    "postgres-array": "^3.0.2",
     "postgres-interval": "^4.0.2",
     "roarr": "^7.21.1",
-    "serialize-error": "^8.0.0",
-    "strict-event-emitter-types": "^2.0.0"
+    "serialize-error": "^8.0.0"
   },
@@ -53,2 +50,8 @@ "description": "A Node.js PostgreSQL client with strict types, detailed logging and assertions.",
   "main": "./dist/index.js",
+  "exports": {
+    ".": {
+      "require": "./dist/index.js",
+      "types": "./dist/index.d.ts"
+    }
+  },
   "name": "slonik",
@@ -91,3 +94,3 @@ "nyc": {
   "types": "./dist/index.d.ts",
-  "version": "43.0.5"
+  "version": "43.0.6"
 }

src/binders/bindPool.test/connect.test.ts

 /* eslint-disable ava/max-asserts */
 
-import { createPgDriverFactory } from '../../factories/createPgDriverFactory';
 import { createPoolWithSpy } from '../../helpers.test/createPoolWithSpy';
 import { createTestRunner } from '../../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -7,0 +7,0 @@

src/binders/bindPool.test/interceptors/afterPoolConnection.test.ts

@@ -1,5 +0,5 @@
-import { createPgDriverFactory } from '../../../factories/createPgDriverFactory';
 import { createPool } from '../../../factories/createPool';
 import { createPoolWithSpy } from '../../../helpers.test/createPoolWithSpy';
 import { createTestRunner } from '../../../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -6,0 +6,0 @@ import * as sinon from 'sinon';

src/binders/bindPool.test/interceptors/beforePoolConnection.test.ts

@@ -1,4 +0,4 @@
-import { createPgDriverFactory } from '../../../factories/createPgDriverFactory';
 import { createPoolWithSpy } from '../../../helpers.test/createPoolWithSpy';
 import { createTestRunner } from '../../../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import * as sinon from 'sinon';
@@ -5,0 +5,0 @@

src/binders/bindPool.test/transaction.test.ts

@@ -1,5 +0,5 @@
-import { createPgDriverFactory } from '../../factories/createPgDriverFactory';
 import { createPool } from '../../factories/createPool';
 import { createPoolWithSpy } from '../../helpers.test/createPoolWithSpy';
 import { createTestRunner } from '../../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -6,0 +6,0 @@ import { setTimeout as delay } from 'node:timers/promises';

src/connectionMethods/any.ts

 import { type InternalQueryMethod } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
 import { query } from './query';
+import { generateUid } from '@slonik/utilities';
 
@@ -15,3 +15,3 @@ /**
 ) => {
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -18,0 +18,0 @@ const { rows } = await query(

src/connectionMethods/anyFirst.test.ts

@@ -1,5 +0,5 @@
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
 import { createTestRunner } from '../helpers.test/createTestRunner';
 import { DataIntegrityError } from '@slonik/errors';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -6,0 +6,0 @@

src/connectionMethods/anyFirst.ts

 import { type InternalQueryMethod } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
 import { any } from './any';
 import { DataIntegrityError } from '@slonik/errors';
+import { generateUid } from '@slonik/utilities';
 
@@ -13,3 +13,3 @@ export const anyFirst: InternalQueryMethod = async (
 ) => {
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -16,0 +16,0 @@ const rows = await any(

src/connectionMethods/exists.ts

 import { type InternalQueryMethod } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
 import { query } from './query';
 import { DataIntegrityError } from '@slonik/errors';
 import { type QuerySqlToken } from '@slonik/sql-tag';
+import { generateUid } from '@slonik/utilities';
 
@@ -14,3 +14,3 @@ export const exists: InternalQueryMethod<Promise<boolean>> = async (
 ) => {
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -17,0 +17,0 @@ const { rows } = await query(

src/connectionMethods/many.test.ts

@@ -1,5 +0,5 @@
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
 import { createTestRunner } from '../helpers.test/createTestRunner';
 import { NotFoundError } from '@slonik/errors';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -6,0 +6,0 @@

src/connectionMethods/many.ts

 import { type InternalQueryMethod } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
 import { query } from './query';
 import { NotFoundError } from '@slonik/errors';
+import { generateUid } from '@slonik/utilities';
 
@@ -17,3 +17,3 @@ /**
 ) => {
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -20,0 +20,0 @@ const { rows } = await query(

src/connectionMethods/manyFirst.test.ts

@@ -1,5 +0,5 @@
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
 import { createTestRunner } from '../helpers.test/createTestRunner';
 import { DataIntegrityError, NotFoundError } from '@slonik/errors';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -6,0 +6,0 @@

src/connectionMethods/manyFirst.ts

 import { type InternalQueryMethod } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
 import { many } from './many';
 import { DataIntegrityError } from '@slonik/errors';
+import { generateUid } from '@slonik/utilities';
 
@@ -13,3 +13,3 @@ export const manyFirst: InternalQueryMethod = async (
 ) => {
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -16,0 +16,0 @@ const rows = await many(

src/connectionMethods/maybeOne.test.ts

@@ -1,5 +0,5 @@
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
 import { createTestRunner } from '../helpers.test/createTestRunner';
 import { DataIntegrityError } from '@slonik/errors';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -6,0 +6,0 @@

src/connectionMethods/maybeOne.ts

 import { type InternalQueryMethod } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
 import { query } from './query';
 import { DataIntegrityError } from '@slonik/errors';
+import { generateUid } from '@slonik/utilities';
 
@@ -17,3 +17,3 @@ /**
 ) => {
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -20,0 +20,0 @@ const { rows } = await query(

src/connectionMethods/maybeOneFirst.test.ts

@@ -1,5 +0,5 @@
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
 import { createTestRunner } from '../helpers.test/createTestRunner';
 import { DataIntegrityError } from '@slonik/errors';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -6,0 +6,0 @@

src/connectionMethods/maybeOneFirst.ts

 import { type InternalQueryMethod } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
 import { maybeOne } from './maybeOne';
 import { DataIntegrityError } from '@slonik/errors';
+import { generateUid } from '@slonik/utilities';
 
@@ -18,3 +18,3 @@ /**
 ) => {
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -21,0 +21,0 @@ const row = await maybeOne(

src/connectionMethods/nestedTransaction.test.ts

@@ -1,2 +0,1 @@
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
@@ -6,2 +5,3 @@ import { createErrorWithCode } from '../helpers.test/createErrorWithCode';
 import { createTestRunner } from '../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import * as sinon from 'sinon';
@@ -8,0 +8,0 @@

src/connectionMethods/nestedTransaction.ts

@@ -5,3 +5,3 @@ import { bindTransactionConnection } from '../binders/bindTransactionConnection';
 import { type InternalNestedTransactionFunction } from '../types';
-import { createUid } from '../utilities/createUid';
+import { generateUid } from '@slonik/utilities';
 import { serializeError } from 'serialize-error';
@@ -116,3 +116,3 @@
   const log = parentLog.child({
-    transactionId: createUid(),
+    transactionId: generateUid(),
   });
@@ -119,0 +119,0 @@

src/connectionMethods/one.test.ts

@@ -1,5 +0,5 @@
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
 import { createTestRunner } from '../helpers.test/createTestRunner';
 import { DataIntegrityError, NotFoundError } from '@slonik/errors';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -6,0 +6,0 @@ import { expectTypeOf } from 'expect-type';

src/connectionMethods/one.ts

 import { type InternalQueryMethod } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
 import { query } from './query';
 import { DataIntegrityError, NotFoundError } from '@slonik/errors';
+import { generateUid } from '@slonik/utilities';
 
@@ -18,3 +18,3 @@ /**
 ) => {
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -21,0 +21,0 @@ const { rows } = await query(

src/connectionMethods/oneFirst.test.ts

@@ -1,2 +0,1 @@
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
@@ -9,2 +8,3 @@ import { createTestRunner } from '../helpers.test/createTestRunner';
 } from '@slonik/errors';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -11,0 +11,0 @@ import { expectTypeOf } from 'expect-type';

src/connectionMethods/oneFirst.ts

 import { type InternalQueryMethod } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
 import { one } from './one';
 import { UnexpectedStateError } from '@slonik/errors';
+import { generateUid } from '@slonik/utilities';
 
@@ -19,3 +19,3 @@ /**
 ) => {
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -22,0 +22,0 @@ const row = await one(

src/connectionMethods/query.test/interceptors/beforeQueryExecution.test.ts

@@ -1,4 +0,4 @@
-import { createPgDriverFactory } from '../../../factories/createPgDriverFactory';
 import { createPoolWithMockedQuery } from '../../../helpers.test/createPoolWithMockedQuery';
 import { createTestRunner } from '../../../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -5,0 +5,0 @@

src/connectionMethods/query.test/interceptors/transformQuery.test.ts

@@ -1,4 +0,4 @@
-import { createPgDriverFactory } from '../../../factories/createPgDriverFactory';
 import { createPoolWithSpy } from '../../../helpers.test/createPoolWithSpy';
 import { createTestRunner } from '../../../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -5,0 +5,0 @@

src/connectionMethods/query.test/interceptors/transformRow.test.ts

@@ -1,4 +0,4 @@
-import { createPgDriverFactory } from '../../../factories/createPgDriverFactory';
 import { createPoolWithMockedQuery } from '../../../helpers.test/createPoolWithMockedQuery';
 import { createTestRunner } from '../../../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -5,0 +5,0 @@

src/connectionMethods/query.test/query.test.ts

@@ -1,5 +0,5 @@
-import { createPgDriverFactory } from '../../factories/createPgDriverFactory';
 import { createPool } from '../../factories/createPool';
 import { createErrorWithCode } from '../../helpers.test/createErrorWithCode';
 import { createTestRunner } from '../../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import { createSqlTag } from '@slonik/sql-tag';
@@ -6,0 +6,0 @@ import * as sinon from 'sinon';

src/connectionMethods/query.ts

@@ -1,5 +0,1 @@
-import {
-  type DriverNotice,
-  type DriverQueryResult,
-} from '../factories/createDriverFactory';
 import { executeQuery, type ExecutionRoutine } from '../routines/executeQuery';
@@ -12,2 +8,3 @@ import {
 } from '../types';
+import { type DriverNotice, type DriverQueryResult } from '@slonik/driver';
 
@@ -14,0 +11,0 @@ const executionRoutine: ExecutionRoutine = async (

src/connectionMethods/stream.ts

@@ -1,2 +0,1 @@
-import { type DriverStreamResult } from '../factories/createDriverFactory';
 import { executeQuery, type ExecutionRoutine } from '../routines/executeQuery';
@@ -12,2 +11,3 @@ import {
 } from '../types';
+import { type DriverStreamResult } from '@slonik/driver';
 import { Transform } from 'node:stream';
@@ -14,0 +14,0 @@ import { pipeline } from 'node:stream/promises';

src/connectionMethods/transaction.test.ts

@@ -1,2 +0,1 @@
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
@@ -6,2 +5,3 @@ import { createErrorWithCode } from '../helpers.test/createErrorWithCode';
 import { createTestRunner } from '../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import * as sinon from 'sinon';
@@ -8,0 +8,0 @@

src/connectionMethods/transaction.ts

@@ -6,4 +6,4 @@ import { bindTransactionConnection } from '../binders/bindTransactionConnection';
 import { type InternalTransactionFunction } from '../types';
-import { createUid } from '../utilities/createUid';
 import { BackendTerminatedError, UnexpectedStateError } from '@slonik/errors';
+import { generateUid } from '@slonik/utilities';
 import { serializeError } from 'serialize-error';
@@ -121,3 +121,3 @@
 ) => {
-  const transactionId = createUid();
+  const transactionId = generateUid();
 
@@ -124,0 +124,0 @@ return transactionContext.run(

src/factories/createClientConfiguration.ts

 import {
   type ClientConfiguration,
   type ClientConfigurationInput,
-  type TypeParser,
 } from '../types';
 import { createTypeParserPreset } from './createTypeParserPreset';
+import { type DriverTypeParser } from '@slonik/driver';
 import { InvalidConfigurationError } from '@slonik/errors';
@@ -13,3 +13,3 @@
 ): ClientConfiguration => {
-  const typeParsers: readonly TypeParser[] = [];
+  const typeParsers: readonly DriverTypeParser[] = [];
 
@@ -16,0 +16,0 @@ const configuration = {

src/factories/createConnection.ts

@@ -12,3 +12,2 @@ import { bindPoolConnection } from '../binders/bindPoolConnection';
 } from '../types';
-import { defer } from '../utilities/defer';
 import {
@@ -20,2 +19,3 @@ type ConnectionPool,
 import { type QuerySqlToken } from '@slonik/sql-tag';
+import { defer } from '@slonik/utilities';
 
@@ -22,0 +22,0 @@ type ConnectionHandlerType = (

src/factories/createConnectionPool.ts

 import { Logger } from '../Logger';
-import { type TypedReadable } from '../types';
-import { createUid } from '../utilities/createUid';
-import { defer, type DeferredPromise } from '../utilities/defer';
 import {
@@ -10,4 +7,6 @@ type Driver,
   type DriverQueryResult,
+  type DriverStream,
   type DriverStreamResult,
-} from './createDriverFactory';
+} from '@slonik/driver';
+import { defer, type DeferredPromise, generateUid } from '@slonik/utilities';
 import { setTimeout as delay } from 'node:timers/promises';
@@ -33,3 +32,3 @@ import { serializeError } from 'serialize-error';
     values?: unknown[],
-  ) => TypedReadable<DriverStreamResult>;
+  ) => DriverStream<DriverStreamResult>;
 };
@@ -78,3 +77,3 @@
 
-  const id = createUid();
+  const id = generateUid();
 
@@ -81,0 +80,0 @@ let isEnding = false;

src/factories/createPool.ts

@@ -6,5 +6,5 @@ import { bindPool } from '../binders/bindPool';
 import { createConnectionPool } from './createConnectionPool';
-import { type DriverFactory } from './createDriverFactory';
-import { createPgDriverFactory } from './createPgDriverFactory';
 import { createPoolConfiguration } from './createPoolConfiguration';
+import { type DriverFactory } from '@slonik/driver';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 
@@ -11,0 +11,0 @@ /**

src/factories/createTypeParserPreset.ts

@@ -1,2 +0,1 @@
-import { type TypeParser } from '../types';
 import { createBigintTypeParser } from './typeParsers/createBigintTypeParser';
@@ -8,4 +7,5 @@ import { createDateTypeParser } from './typeParsers/createDateTypeParser';
 import { createTimestampWithTimeZoneTypeParser } from './typeParsers/createTimestampWithTimeZoneTypeParser';
+import { type DriverTypeParser } from '@slonik/driver';
 
-export const createTypeParserPreset = (): readonly TypeParser[] => {
+export const createTypeParserPreset = (): readonly DriverTypeParser[] => {
   return [
@@ -12,0 +12,0 @@ createBigintTypeParser(),

src/factories/typeParsers/createBigintTypeParser.ts

@@ -1,2 +0,2 @@
-import { type TypeParser } from '../../types';
+import { type DriverTypeParser } from '@slonik/driver';
 
@@ -8,3 +8,3 @@ // eslint-disable-next-line unicorn/prefer-native-coercion-functions
 
-export const createBigintTypeParser = (): TypeParser => {
+export const createBigintTypeParser = (): DriverTypeParser => {
   return {
@@ -11,0 +11,0 @@ name: 'int8',

src/factories/typeParsers/createDateTypeParser.ts

@@ -1,2 +0,2 @@
-import { type TypeParser } from '../../types';
+import { type DriverTypeParser } from '@slonik/driver';
 
@@ -7,3 +7,3 @@ const dateParser = (value: string) => {
 
-export const createDateTypeParser = (): TypeParser => {
+export const createDateTypeParser = (): DriverTypeParser => {
   return {
@@ -10,0 +10,0 @@ name: 'date',

src/factories/typeParsers/createIntervalTypeParser.ts

@@ -1,2 +0,2 @@
-import { type TypeParser } from '../../types';
+import { type DriverTypeParser } from '@slonik/driver';
 import {
@@ -14,3 +14,3 @@ parse as parseIsoDuration,
 
-export const createIntervalTypeParser = (): TypeParser => {
+export const createIntervalTypeParser = (): DriverTypeParser => {
   return {
@@ -17,0 +17,0 @@ name: 'interval',

src/factories/typeParsers/createNumericTypeParser.ts

@@ -1,2 +0,2 @@
-import { type TypeParser } from '../../types';
+import { type DriverTypeParser } from '@slonik/driver';
 
@@ -7,3 +7,3 @@ const numericParser = (value: string) => {
 
-export const createNumericTypeParser = (): TypeParser => {
+export const createNumericTypeParser = (): DriverTypeParser => {
   return {
@@ -10,0 +10,0 @@ name: 'numeric',

src/factories/typeParsers/createTimestampTypeParser.ts

@@ -1,2 +0,2 @@
-import { type TypeParser } from '../../types';
+import { type DriverTypeParser } from '@slonik/driver';
 
@@ -15,3 +15,3 @@ const timestampParser = (value: string | null) => {
 
-export const createTimestampTypeParser = (): TypeParser => {
+export const createTimestampTypeParser = (): DriverTypeParser => {
   return {
@@ -18,0 +18,0 @@ name: 'timestamp',

src/factories/typeParsers/createTimestampWithTimeZoneTypeParser.ts

@@ -1,2 +0,2 @@
-import { type TypeParser } from '../../types';
+import { type DriverTypeParser } from '@slonik/driver';
 
@@ -15,3 +15,3 @@ const timestampParser = (value: string | null) => {
 
-export const createTimestampWithTimeZoneTypeParser = (): TypeParser => {
+export const createTimestampWithTimeZoneTypeParser = (): DriverTypeParser => {
   return {
@@ -18,0 +18,0 @@ name: 'timestamptz',

src/helpers.test/createIntegrationTests.ts

@@ -23,4 +23,4 @@ /* eslint-disable id-length */
 } from '..';
-import { type DriverFactory } from '../factories/createDriverFactory';
 import { type TestContextType } from './createTestRunner';
+import { type DriverFactory } from '@slonik/driver';
 // eslint-disable-next-line ava/use-test
@@ -27,0 +27,0 @@ import { type TestFn } from 'ava';

src/helpers.test/createTestRunner.ts

 import { sql } from '..';
-import { type DriverFactory } from '../factories/createDriverFactory';
 import { createPool } from '../factories/createPool';
+import { type DriverFactory } from '@slonik/driver';
 import anyTest, { type TestFn } from 'ava';
@@ -5,0 +5,0 @@

src/index.ts

@@ -16,3 +16,4 @@ import { createSqlTag } from '@slonik/sql-tag';
   type DriverStreamResult,
-} from './factories/createDriverFactory';
+  type DriverTypeParser,
+} from '@slonik/driver';
 
@@ -52,7 +53,4 @@ export const sql = createSqlTag();
   TypeNameIdentifier,
-  TypeParser,
   ValueExpression,
 } from './types';
-export { parseDsn } from './utilities/parseDsn';
-export { stringifyDsn } from './utilities/stringifyDsn';
 export {
@@ -99,1 +97,3 @@ BackendTerminatedError,
 } from '@slonik/sql-tag';
+export { stringifyDsn } from '@slonik/utilities';
+export { parseDsn } from '@slonik/utilities';

src/integration.test/pg.test.ts

 import { sql } from '..';
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
 import { createIntegrationTests } from '../helpers.test/createIntegrationTests';
 import { createTestRunner } from '../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 
@@ -7,0 +7,0 @@ const driverFactory = createPgDriverFactory();

src/integration.test/stream.test.ts

@@ -7,4 +7,4 @@ import {
 } from '..';
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createTestRunner } from '../helpers.test/createTestRunner';
+import { createPgDriverFactory } from '@slonik/pg-driver';
 import * as sinon from 'sinon';
@@ -11,0 +11,0 @@ import { z } from 'zod';

src/routines/establishConnection.ts

@@ -7,4 +7,4 @@ import {
 import { type Logger } from '../types';
-import { createUid } from '../utilities/createUid';
 import { ConnectionError, UnexpectedStateError } from '@slonik/errors';
+import { generateUid } from '@slonik/utilities';
 import { serializeError } from 'serialize-error';
@@ -29,3 +29,3 @@
       poolClientStateMap.set(connection, {
-        connectionId: createUid(),
+        connectionId: generateUid(),
         poolId: pool.id(),
@@ -32,0 +32,0 @@ terminated: null,

src/routines/executeQuery.ts

 import { TRANSACTION_ROLLBACK_ERROR_PREFIX } from '../constants';
 import { transactionContext } from '../contexts/transactionContext';
 import { type ConnectionPoolClient } from '../factories/createConnectionPool';
-import { type DriverNotice } from '../factories/createDriverFactory';
 import { getPoolClientState } from '../state';
@@ -17,4 +16,3 @@ import {
 } from '../types';
-import { createQueryId } from '../utilities/createQueryId';
-import { defer } from '../utilities/defer';
+import { type DriverNotice } from '@slonik/driver';
 import {
@@ -33,2 +31,3 @@ BackendTerminatedError,
 } from '@slonik/sql-tag';
+import { defer, generateUid } from '@slonik/utilities';
 import { getStackTrace } from 'get-stack-trace';
@@ -165,3 +164,3 @@ import { serializeError } from 'serialize-error';
 
-  const queryId = inheritedQueryId ?? createQueryId();
+  const queryId = inheritedQueryId ?? generateUid();
 
@@ -168,0 +167,0 @@ const log = connectionLogger.child({

src/state.ts

 import { type ConnectionPoolClient } from './factories/createConnectionPool';
-import { type DeferredPromise } from './utilities/defer';
 import { UnexpectedStateError } from '@slonik/errors';
+import { type DeferredPromise } from '@slonik/utilities';
 
@@ -5,0 +5,0 @@ type PoolClientState = {

src/types.ts

@@ -5,3 +5,5 @@ import { type ConnectionPoolClient } from './factories/createConnectionPool';
   type DriverNotice,
-} from './factories/createDriverFactory';
+  type DriverStream,
+  type DriverTypeParser,
+} from '@slonik/driver';
 import { type SlonikError } from '@slonik/errors';
@@ -13,3 +15,2 @@ import {
 } from '@slonik/sql-tag';
-import { type Readable } from 'node:stream';
 import { type ConnectionOptions as TlsConnectionOptions } from 'node:tls';
@@ -19,16 +20,4 @@ import { type Logger } from 'roarr';
 
-type StreamDataEvent<T> = { data: T; fields: readonly Field[] };
+export type StreamHandler<T> = (stream: DriverStream<T>) => void;
 
-// eslint-disable-next-line @typescript-eslint/consistent-type-definitions
-export interface TypedReadable<T> extends Readable {
-  // eslint-disable-next-line @typescript-eslint/method-signature-style
-  on(event: 'data', listener: (chunk: StreamDataEvent<T>) => void): this;
-  // eslint-disable-next-line @typescript-eslint/method-signature-style
-  on(event: string | symbol, listener: (...args: any[]) => void): this;
-
-  [Symbol.asyncIterator]: () => AsyncIterableIterator<StreamDataEvent<T>>;
-}
-
-export type StreamHandler<T> = (stream: TypedReadable<T>) => void;
-
 /**
@@ -161,3 +150,3 @@ * @see https://www.postgresql.org/docs/current/libpq-connect.html#LIBPQ-PARAMKEYWORDS
    */
-  readonly typeParsers: readonly TypeParser[];
+  readonly typeParsers: readonly DriverTypeParser[];
 };
@@ -237,10 +226,2 @@
 /**
- * @property name Value of "pg_type"."typname" (e.g. "int8", "timestamp", "timestamptz").
- */
-export type TypeParser<T = unknown> = {
-  readonly name: string;
-  readonly parse: (value: string) => T;
-};
-
-/**
  * @property log Instance of Roarr logger with bound connection context parameters.
@@ -247,0 +228,0 @@ * @property poolId Unique connection pool ID.

No alert changes

Improved metrics

Dependency count

11

decreased by-21.43%

Worsened metrics

Total package byte prevSize

642963

decreased by-12.84%

Number of package files

328

decreased by-13.23%

Lines of code

12814

decreased by-12.18%

Dependency changes

• + Added@slonik/driver@^43.0.6

• + Added@slonik/pg-driver@^43.0.6

• + Added@slonik/utilities@^43.0.6

• + Added@slonik/driver@43.0.8(transitive)

• + Added@slonik/pg-driver@43.0.8(transitive)

• + Added@slonik/utilities@43.0.8(transitive)

• - Removed@types/pg@^8.11.6

• - Removedpg@^8.11.5

• - Removedpg-query-stream@^4.5.5

• - Removedpg-types@^4.0.2

• - Removedpostgres-array@^3.0.2

• - Removedstrict-event-emitter-types@^2.0.0

• - Removed@types/node@20.14.9(transitive)

• - Removed@types/pg@8.11.6(transitive)

• - Removedundici-types@5.26.5(transitive)

• Updated@slonik/errors@^43.0.6

• Updated@slonik/sql-tag@^43.0.6