slonik - npm Package Compare versions

Comparing version 41.2.1 to 42.0.0

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

@@ -5,8 +5,8 @@ "use strict";
 const createPgDriverFactory_1 = require("../../factories/createPgDriverFactory");
-const createSqlTag_1 = require("../../factories/createSqlTag");
 const createPoolWithSpy_1 = require("../../helpers.test/createPoolWithSpy");
 const createTestRunner_1 = require("../../helpers.test/createTestRunner");
+const sql_tag_1 = require("@slonik/sql-tag");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('release connection after promise is resolved (implicit connection)', async (t) => {
@@ -13,0 +13,0 @@ const { pool, spy } = await (0, createPoolWithSpy_1.createPoolWithSpy)(t.context.dsn, {

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

@@ -28,9 +28,9 @@ "use strict";
 const createPool_1 = require("../../../factories/createPool");
-const createSqlTag_1 = require("../../../factories/createSqlTag");
 const createPoolWithSpy_1 = require("../../../helpers.test/createPoolWithSpy");
 const createTestRunner_1 = require("../../../helpers.test/createTestRunner");
+const sql_tag_1 = require("@slonik/sql-tag");
 const sinon = __importStar(require("sinon"));
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('`afterPoolConnection` is called after `connect`', async (t) => {
@@ -37,0 +37,0 @@ const afterPoolConnection = sinon.stub();

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

@@ -5,9 +5,9 @@ "use strict";
 const createPool_1 = require("../../factories/createPool");
-const createSqlTag_1 = require("../../factories/createSqlTag");
 const createPoolWithSpy_1 = require("../../helpers.test/createPoolWithSpy");
 const createTestRunner_1 = require("../../helpers.test/createTestRunner");
+const sql_tag_1 = require("@slonik/sql-tag");
 const promises_1 = require("node:timers/promises");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 const getQueries = (spy) => {
@@ -14,0 +14,0 @@ return spy.getCalls().map((call) => {

dist/connectionMethods/anyFirst.js

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

dist/connectionMethods/anyFirst.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const errors_1 = require("../errors");
 const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
-const createSqlTag_1 = require("../factories/createSqlTag");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const errors_1 = require("@slonik/errors");
+const sql_tag_1 = require("@slonik/sql-tag");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('returns empty array if no rows are returned', async (t) => {
@@ -12,0 +12,0 @@ const pool = await (0, createPool_1.createPool)(t.context.dsn, {

dist/connectionMethods/exists.js

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

dist/connectionMethods/many.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.many = void 0;
-const errors_1 = require("../errors");
 const createQueryId_1 = require("../utilities/createQueryId");
 const query_1 = require("./query");
+const errors_1 = require("@slonik/errors");
 /**
@@ -8,0 +8,0 @@ * Makes a query and expects at least 1 result.

dist/connectionMethods/many.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const errors_1 = require("../errors");
 const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
-const createSqlTag_1 = require("../factories/createSqlTag");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const errors_1 = require("@slonik/errors");
+const sql_tag_1 = require("@slonik/sql-tag");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('returns the query results rows', async (t) => {
@@ -12,0 +12,0 @@ const pool = await (0, createPool_1.createPool)(t.context.dsn, {

dist/connectionMethods/manyFirst.js

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

dist/connectionMethods/manyFirst.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const errors_1 = require("../errors");
 const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
-const createSqlTag_1 = require("../factories/createSqlTag");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const errors_1 = require("@slonik/errors");
+const sql_tag_1 = require("@slonik/sql-tag");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('returns values of the query result rows', async (t) => {
@@ -12,0 +12,0 @@ const pool = await (0, createPool_1.createPool)(t.context.dsn, {

dist/connectionMethods/maybeOne.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.maybeOne = void 0;
-const errors_1 = require("../errors");
 const createQueryId_1 = require("../utilities/createQueryId");
 const query_1 = require("./query");
+const errors_1 = require("@slonik/errors");
 /**
@@ -8,0 +8,0 @@ * Makes a query and expects exactly one result.

dist/connectionMethods/maybeOne.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const errors_1 = require("../errors");
 const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
-const createSqlTag_1 = require("../factories/createSqlTag");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const errors_1 = require("@slonik/errors");
+const sql_tag_1 = require("@slonik/sql-tag");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('returns the first row', async (t) => {
@@ -12,0 +12,0 @@ const pool = await (0, createPool_1.createPool)(t.context.dsn, {

dist/connectionMethods/maybeOneFirst.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.maybeOneFirst = void 0;
-const errors_1 = require("../errors");
 const createQueryId_1 = require("../utilities/createQueryId");
 const maybeOne_1 = require("./maybeOne");
+const errors_1 = require("@slonik/errors");
 /**
@@ -8,0 +8,0 @@ * Makes a query and expects exactly one result.

dist/connectionMethods/maybeOneFirst.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const errors_1 = require("../errors");
 const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
-const createSqlTag_1 = require("../factories/createSqlTag");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const errors_1 = require("@slonik/errors");
+const sql_tag_1 = require("@slonik/sql-tag");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('returns the first row', async (t) => {
@@ -12,0 +12,0 @@ const pool = await (0, createPool_1.createPool)(t.context.dsn, {

dist/connectionMethods/one.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.one = void 0;
-const errors_1 = require("../errors");
 const createQueryId_1 = require("../utilities/createQueryId");
 const query_1 = require("./query");
+const errors_1 = require("@slonik/errors");
 /**
@@ -8,0 +8,0 @@ * Makes a query and expects exactly one result.

dist/connectionMethods/one.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const errors_1 = require("../errors");
 const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
-const createSqlTag_1 = require("../factories/createSqlTag");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const errors_1 = require("@slonik/errors");
+const sql_tag_1 = require("@slonik/sql-tag");
 const expect_type_1 = require("expect-type");
@@ -12,3 +12,3 @@ const zod_1 = require("zod");
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('returns the first row', async (t) => {
@@ -15,0 +15,0 @@ const pool = await (0, createPool_1.createPool)(t.context.dsn, {

dist/connectionMethods/oneFirst.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.oneFirst = void 0;
-const errors_1 = require("../errors");
 const createQueryId_1 = require("../utilities/createQueryId");
 const one_1 = require("./one");
+const errors_1 = require("@slonik/errors");
 /**
@@ -8,0 +8,0 @@ * Makes a query and expects exactly one result.

dist/connectionMethods/oneFirst.test.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const errors_1 = require("../errors");
 const createPgDriverFactory_1 = require("../factories/createPgDriverFactory");
 const createPool_1 = require("../factories/createPool");
-const createSqlTag_1 = require("../factories/createSqlTag");
 const createTestRunner_1 = require("../helpers.test/createTestRunner");
+const errors_1 = require("@slonik/errors");
+const sql_tag_1 = require("@slonik/sql-tag");
 const expect_type_1 = require("expect-type");
@@ -12,3 +12,3 @@ const zod_1 = require("zod");
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('returns value of the first column from the first row', async (t) => {
@@ -15,0 +15,0 @@ const pool = await (0, createPool_1.createPool)(t.context.dsn, {

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

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const createPgDriverFactory_1 = require("../../../factories/createPgDriverFactory");
-const createSqlTag_1 = require("../../../factories/createSqlTag");
 const createPoolWithMockedQuery_1 = require("../../../helpers.test/createPoolWithMockedQuery");
 const createTestRunner_1 = require("../../../helpers.test/createTestRunner");
+const sql_tag_1 = require("@slonik/sql-tag");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('short-circuits the query execution', async (t) => {
@@ -11,0 +11,0 @@ const { pool, query } = await (0, createPoolWithMockedQuery_1.createPoolWithMockedQuery)(t.context.dsn, {

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

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const createPgDriverFactory_1 = require("../../../factories/createPgDriverFactory");
-const createSqlTag_1 = require("../../../factories/createSqlTag");
 const createPoolWithSpy_1 = require("../../../helpers.test/createPoolWithSpy");
 const createTestRunner_1 = require("../../../helpers.test/createTestRunner");
+const sql_tag_1 = require("@slonik/sql-tag");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('transforms query', async (t) => {
@@ -11,0 +11,0 @@ const { pool, spy } = await (0, createPoolWithSpy_1.createPoolWithSpy)(t.context.dsn, {

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

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const createPgDriverFactory_1 = require("../../../factories/createPgDriverFactory");
-const createSqlTag_1 = require("../../../factories/createSqlTag");
 const createPoolWithMockedQuery_1 = require("../../../helpers.test/createPoolWithMockedQuery");
 const createTestRunner_1 = require("../../../helpers.test/createTestRunner");
+const sql_tag_1 = require("@slonik/sql-tag");
 const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 const { test } = (0, createTestRunner_1.createTestRunner)(driverFactory, 'pg');
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('overrides result row (sync)', async (t) => {
@@ -11,0 +11,0 @@ const { pool, query } = await (0, createPoolWithMockedQuery_1.createPoolWithMockedQuery)(t.context.dsn, {

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

@@ -29,5 +29,5 @@ "use strict";
 const createPool_1 = require("../../factories/createPool");
-const createSqlTag_1 = require("../../factories/createSqlTag");
 const createErrorWithCode_1 = require("../../helpers.test/createErrorWithCode");
 const createTestRunner_1 = require("../../helpers.test/createTestRunner");
+const sql_tag_1 = require("@slonik/sql-tag");
 const sinon = __importStar(require("sinon"));
@@ -43,3 +43,3 @@ const driverFactory = (0, createPgDriverFactory_1.createPgDriverFactory)();
 exports.createErrorWithCodeAndConstraint = createErrorWithCodeAndConstraint;
-const sql = (0, createSqlTag_1.createSqlTag)();
+const sql = (0, sql_tag_1.createSqlTag)();
 test('ends connection after promise is resolved (explicit connection)', async (t) => {
@@ -46,0 +46,0 @@ const eventHandler = sinon.spy();

dist/connectionMethods/transaction.js

@@ -7,5 +7,5 @@ "use strict";
 const transactionContext_1 = require("../contexts/transactionContext");
-const errors_1 = require("../errors");
 const state_1 = require("../state");
 const createUid_1 = require("../utilities/createUid");
+const errors_1 = require("@slonik/errors");
 const serialize_error_1 = require("serialize-error");
@@ -12,0 +12,0 @@ const execTransaction = async (parentLog, connection, clientConfiguration, handler) => {

dist/factories/createClientConfiguration.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.createClientConfiguration = void 0;
-const errors_1 = require("../errors");
 const createTypeParserPreset_1 = require("./createTypeParserPreset");
+const errors_1 = require("@slonik/errors");
 const createClientConfiguration = (connectionUri, clientUserConfigurationInput) => {
@@ -7,0 +7,0 @@ const typeParsers = [];

dist/factories/createConnection.d.ts

@@ -1,3 +0,4 @@
-import { type ClientConfiguration, type Connection, type DatabasePool, type DatabasePoolConnection, type Logger, type MaybePromise, type QuerySqlToken } from '../types';
+import { type ClientConfiguration, type Connection, type DatabasePool, type DatabasePoolConnection, type Logger, type MaybePromise } from '../types';
 import { type ConnectionPool, type ConnectionPoolClient } from './createConnectionPool';
+import { type QuerySqlToken } from '@slonik/sql-tag';
 type ConnectionHandlerType = (connectionLog: Logger, connection: ConnectionPoolClient, boundConnection: DatabasePoolConnection, clientConfiguration: ClientConfiguration) => MaybePromise<unknown>;
@@ -4,0 +5,0 @@ type PoolHandlerType = (pool: DatabasePool) => Promise<unknown>;

dist/factories/createConnection.js

@@ -5,6 +5,6 @@ "use strict";
 const bindPoolConnection_1 = require("../binders/bindPoolConnection");
-const errors_1 = require("../errors");
 const establishConnection_1 = require("../routines/establishConnection");
 const state_1 = require("../state");
 const defer_1 = require("../utilities/defer");
+const errors_1 = require("@slonik/errors");
 const destroyBoundConnection = (boundConnection) => {
@@ -11,0 +11,0 @@ const boundConnectionMethods = [

dist/factories/createConnectionPool.d.ts

@@ -35,6 +35,6 @@ import { type TypedReadable } from '../types';
     driver: Driver;
-    idleTimeout?: number | undefined;
-    poolSize?: number | undefined;
+    idleTimeout?: number;
+    poolSize?: number;
 }) => ConnectionPool;
 export {};
 //# sourceMappingURL=createConnectionPool.d.ts.map

dist/factories/createPgDriverFactory.js

@@ -8,5 +8,5 @@ "use strict";
 exports.createPgDriverFactory = void 0;
-const errors_1 = require("../errors");
 const parseDsn_1 = require("../utilities/parseDsn");
 const createDriverFactory_1 = require("./createDriverFactory");
+const errors_1 = require("@slonik/errors");
 const node_stream_1 = require("node:stream");
@@ -13,0 +13,0 @@ // eslint-disable-next-line no-restricted-imports

dist/index.d.ts

 /// <reference types="node" />
 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 declare const sql: {
-    array: (values: readonly import("./types").PrimitiveValueExpression[], memberType: string | import("./types").SqlToken) => import("./types").ArraySqlToken;
-    binary: (data: Buffer) => import("./types").BinarySqlToken;
-    date: (date: Date) => import("./types").DateSqlToken;
-    fragment: (parts: readonly string[], ...args: readonly import("./types").ValueExpression[]) => import("./types").FragmentSqlToken;
-    identifier: (names: readonly string[]) => import("./types").IdentifierSqlToken;
-    interval: (interval: import("./types").IntervalInput) => import("./types").IntervalSqlToken;
-    join: (members: readonly import("./types").ValueExpression[], glue: import("./types").SqlFragment) => import("./types").ListSqlToken;
-    json: (value: import("./types").SerializableValue) => import("./types").JsonSqlToken;
-    jsonb: (value: import("./types").SerializableValue) => import("./types").JsonBinarySqlToken;
-    literalValue: (value: string) => import("./types").SqlFragment;
-    timestamp: (date: Date) => import("./types").TimestampSqlToken;
-    type: <T extends import("zod").ZodTypeAny>(parser: T) => (parts: readonly string[], ...args: readonly import("./types").ValueExpression[]) => Readonly<{
+    array: (values: readonly import("@slonik/sql-tag").PrimitiveValueExpression[], memberType: string | import("@slonik/sql-tag").SqlToken) => import("@slonik/sql-tag").ArraySqlToken;
+    binary: (data: Buffer) => import("@slonik/sql-tag").BinarySqlToken;
+    date: (date: Date) => import("@slonik/sql-tag/dist/types").DateSqlToken;
+    fragment: (parts: readonly string[], ...args: readonly import("@slonik/sql-tag").ValueExpression[]) => import("@slonik/sql-tag").FragmentSqlToken;
+    identifier: (names: readonly string[]) => import("@slonik/sql-tag").IdentifierSqlToken;
+    interval: (interval: import("@slonik/sql-tag/dist/types").IntervalInput) => import("@slonik/sql-tag/dist/types").IntervalSqlToken;
+    join: (members: readonly import("@slonik/sql-tag").ValueExpression[], glue: import("@slonik/sql-tag").SqlFragment) => import("@slonik/sql-tag").ListSqlToken;
+    json: (value: import("@slonik/sql-tag").SerializableValue) => import("@slonik/sql-tag").JsonSqlToken;
+    jsonb: (value: import("@slonik/sql-tag").SerializableValue) => import("@slonik/sql-tag").JsonBinarySqlToken;
+    literalValue: (value: string) => import("@slonik/sql-tag").SqlFragment;
+    timestamp: (date: Date) => import("@slonik/sql-tag/dist/types").TimestampSqlToken;
+    type: <T extends import("zod").ZodTypeAny>(parser: T) => (parts: readonly string[], ...args: readonly import("@slonik/sql-tag").ValueExpression[]) => Readonly<{
         parser: T;
         type: "SLONIK_TOKEN_QUERY";
         sql: string;
-        values: import("./types").PrimitiveValueExpression[];
+        values: import("@slonik/sql-tag").PrimitiveValueExpression[];
     }>;
-    typeAlias: <Y extends PropertyKey>(parserAlias: Y) => (parts: readonly string[], ...args: readonly import("./types").ValueExpression[]) => Readonly<{
+    typeAlias: <Y extends PropertyKey>(parserAlias: Y) => (parts: readonly string[], ...args: readonly import("@slonik/sql-tag").ValueExpression[]) => Readonly<{
         parser: Record<PropertyKey, import("zod").ZodTypeAny>[Y];
         type: "SLONIK_TOKEN_QUERY";
         sql: string;
-        values: import("./types").PrimitiveValueExpression[];
+        values: import("@slonik/sql-tag").PrimitiveValueExpression[];
     }>;
-    unnest: (tuples: readonly (readonly import("./types").PrimitiveValueExpression[])[], columnTypes: [...string[], string][] | (string | import("./types").SqlFragment)[]) => import("./types").UnnestSqlToken;
-    unsafe: (parts: readonly string[], ...args: readonly import("./types").ValueExpression[]) => Readonly<{
+    unnest: (tuples: readonly (readonly import("@slonik/sql-tag").PrimitiveValueExpression[])[], columnTypes: [...string[], string][] | (string | import("@slonik/sql-tag").SqlFragment)[]) => import("@slonik/sql-tag").UnnestSqlToken;
+    unsafe: (parts: readonly string[], ...args: readonly import("@slonik/sql-tag").ValueExpression[]) => Readonly<{
         parser: import("zod").ZodAny;
         type: "SLONIK_TOKEN_QUERY";
         sql: string;
-        values: import("./types").PrimitiveValueExpression[];
+        values: import("@slonik/sql-tag").PrimitiveValueExpression[];
     }>;
 };
-export { BackendTerminatedError, BackendTerminatedUnexpectedlyError, CheckIntegrityConstraintViolationError, ConnectionError, DataIntegrityError, ForeignKeyIntegrityConstraintViolationError, IdleTransactionTimeoutError, InputSyntaxError, IntegrityConstraintViolationError, InvalidConfigurationError, InvalidInputError, NotFoundError, NotNullIntegrityConstraintViolationError, SchemaValidationError, SlonikError, StatementCancelledError, StatementTimeoutError, TupleMovedToAnotherPartitionError, UnexpectedForeignConnectionError, UnexpectedStateError, UniqueIntegrityConstraintViolationError, } from './errors';
 export { createPool } from './factories/createPool';
-export { createSqlTag } from './factories/createSqlTag';
-export { createSqlTokenSqlFragment } from './factories/createSqlTokenSqlFragment';
 export { createTypeParserPreset } from './factories/createTypeParserPreset';
@@ -46,6 +43,8 @@ export { createBigintTypeParser } from './factories/typeParsers/createBigintTypeParser';
 export { createTimestampWithTimeZoneTypeParser } from './factories/typeParsers/createTimestampWithTimeZoneTypeParser';
-export type { ArraySqlToken, BinarySqlToken, ClientConfiguration, ClientConfigurationInput, CommonQueryMethods, Connection, ConnectionOptions, ConnectionRoutine, DatabaseConnection, DatabasePool, DatabasePoolConnection, DatabaseTransactionConnection, Field, FragmentSqlToken, IdentifierNormalizer, IdentifierSqlToken, Interceptor, JsonBinarySqlToken, JsonSqlToken, ListSqlToken, MaybePromise, PoolContext, PrimitiveValueExpression, Query, QueryContext, QueryFunction, QueryResult, QueryResultRow, QueryResultRowColumn, QuerySqlToken, SerializableValue, SqlFragment, SqlTag, SqlToken, TypeNameIdentifier, TypeParser, UnnestSqlToken, ValueExpression, } from './types';
-export { isSqlToken } from './utilities/isSqlToken';
+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 { 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 { createSqlTokenSqlFragment } from '@slonik/sql-tag';
+export { type ArraySqlToken, type BinarySqlToken, createSqlTag, type FragmentSqlToken, type IdentifierSqlToken, isSqlToken, type JsonBinarySqlToken, type JsonSqlToken, type ListSqlToken, type PrimitiveValueExpression, type QuerySqlToken, type SerializableValue, type SqlFragment, type SqlTag, type SqlToken, type UnnestSqlToken, } from '@slonik/sql-tag';
 //# sourceMappingURL=index.d.ts.map

dist/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.stringifyDsn = exports.parseDsn = exports.isSqlToken = exports.createTimestampWithTimeZoneTypeParser = exports.createTimestampTypeParser = exports.createNumericTypeParser = exports.createIntervalTypeParser = exports.createDateTypeParser = exports.createBigintTypeParser = exports.createTypeParserPreset = exports.createSqlTokenSqlFragment = exports.createSqlTag = exports.createPool = 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.sql = exports.createDriverFactory = void 0;
-const createSqlTag_1 = require("./factories/createSqlTag");
+exports.isSqlToken = exports.createSqlTag = exports.createSqlTokenSqlFragment = 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;
+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; } });
-exports.sql = (0, createSqlTag_1.createSqlTag)();
-var errors_1 = require("./errors");
+exports.sql = (0, sql_tag_1.createSqlTag)();
+var createPool_1 = require("./factories/createPool");
+Object.defineProperty(exports, "createPool", { enumerable: true, get: function () { return createPool_1.createPool; } });
+var createTypeParserPreset_1 = require("./factories/createTypeParserPreset");
+Object.defineProperty(exports, "createTypeParserPreset", { enumerable: true, get: function () { return createTypeParserPreset_1.createTypeParserPreset; } });
+var createBigintTypeParser_1 = require("./factories/typeParsers/createBigintTypeParser");
+Object.defineProperty(exports, "createBigintTypeParser", { enumerable: true, get: function () { return createBigintTypeParser_1.createBigintTypeParser; } });
+var createDateTypeParser_1 = require("./factories/typeParsers/createDateTypeParser");
+Object.defineProperty(exports, "createDateTypeParser", { enumerable: true, get: function () { return createDateTypeParser_1.createDateTypeParser; } });
+var createIntervalTypeParser_1 = require("./factories/typeParsers/createIntervalTypeParser");
+Object.defineProperty(exports, "createIntervalTypeParser", { enumerable: true, get: function () { return createIntervalTypeParser_1.createIntervalTypeParser; } });
+var createNumericTypeParser_1 = require("./factories/typeParsers/createNumericTypeParser");
+Object.defineProperty(exports, "createNumericTypeParser", { enumerable: true, get: function () { return createNumericTypeParser_1.createNumericTypeParser; } });
+var createTimestampTypeParser_1 = require("./factories/typeParsers/createTimestampTypeParser");
+Object.defineProperty(exports, "createTimestampTypeParser", { enumerable: true, get: function () { return createTimestampTypeParser_1.createTimestampTypeParser; } });
+var createTimestampWithTimeZoneTypeParser_1 = require("./factories/typeParsers/createTimestampWithTimeZoneTypeParser");
+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");
 Object.defineProperty(exports, "BackendTerminatedError", { enumerable: true, get: function () { return errors_1.BackendTerminatedError; } });
@@ -30,28 +50,7 @@ Object.defineProperty(exports, "BackendTerminatedUnexpectedlyError", { enumerable: true, get: function () { return errors_1.BackendTerminatedUnexpectedlyError; } });
 Object.defineProperty(exports, "UniqueIntegrityConstraintViolationError", { enumerable: true, get: function () { return errors_1.UniqueIntegrityConstraintViolationError; } });
-var createPool_1 = require("./factories/createPool");
-Object.defineProperty(exports, "createPool", { enumerable: true, get: function () { return createPool_1.createPool; } });
-var createSqlTag_2 = require("./factories/createSqlTag");
-Object.defineProperty(exports, "createSqlTag", { enumerable: true, get: function () { return createSqlTag_2.createSqlTag; } });
-var createSqlTokenSqlFragment_1 = require("./factories/createSqlTokenSqlFragment");
-Object.defineProperty(exports, "createSqlTokenSqlFragment", { enumerable: true, get: function () { return createSqlTokenSqlFragment_1.createSqlTokenSqlFragment; } });
-var createTypeParserPreset_1 = require("./factories/createTypeParserPreset");
-Object.defineProperty(exports, "createTypeParserPreset", { enumerable: true, get: function () { return createTypeParserPreset_1.createTypeParserPreset; } });
-var createBigintTypeParser_1 = require("./factories/typeParsers/createBigintTypeParser");
-Object.defineProperty(exports, "createBigintTypeParser", { enumerable: true, get: function () { return createBigintTypeParser_1.createBigintTypeParser; } });
-var createDateTypeParser_1 = require("./factories/typeParsers/createDateTypeParser");
-Object.defineProperty(exports, "createDateTypeParser", { enumerable: true, get: function () { return createDateTypeParser_1.createDateTypeParser; } });
-var createIntervalTypeParser_1 = require("./factories/typeParsers/createIntervalTypeParser");
-Object.defineProperty(exports, "createIntervalTypeParser", { enumerable: true, get: function () { return createIntervalTypeParser_1.createIntervalTypeParser; } });
-var createNumericTypeParser_1 = require("./factories/typeParsers/createNumericTypeParser");
-Object.defineProperty(exports, "createNumericTypeParser", { enumerable: true, get: function () { return createNumericTypeParser_1.createNumericTypeParser; } });
-var createTimestampTypeParser_1 = require("./factories/typeParsers/createTimestampTypeParser");
-Object.defineProperty(exports, "createTimestampTypeParser", { enumerable: true, get: function () { return createTimestampTypeParser_1.createTimestampTypeParser; } });
-var createTimestampWithTimeZoneTypeParser_1 = require("./factories/typeParsers/createTimestampWithTimeZoneTypeParser");
-Object.defineProperty(exports, "createTimestampWithTimeZoneTypeParser", { enumerable: true, get: function () { return createTimestampWithTimeZoneTypeParser_1.createTimestampWithTimeZoneTypeParser; } });
-var isSqlToken_1 = require("./utilities/isSqlToken");
-Object.defineProperty(exports, "isSqlToken", { enumerable: true, get: function () { return isSqlToken_1.isSqlToken; } });
-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 sql_tag_2 = require("@slonik/sql-tag");
+Object.defineProperty(exports, "createSqlTokenSqlFragment", { enumerable: true, get: function () { return sql_tag_2.createSqlTokenSqlFragment; } });
+var sql_tag_3 = require("@slonik/sql-tag");
+Object.defineProperty(exports, "createSqlTag", { enumerable: true, get: function () { return sql_tag_3.createSqlTag; } });
+Object.defineProperty(exports, "isSqlToken", { enumerable: true, get: function () { return sql_tag_3.isSqlToken; } });
 //# sourceMappingURL=index.js.map

dist/routines/establishConnection.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.establishConnection = void 0;
-const errors_1 = require("../errors");
 const state_1 = require("../state");
 const createUid_1 = require("../utilities/createUid");
+const errors_1 = require("@slonik/errors");
 const serialize_error_1 = require("serialize-error");
@@ -8,0 +8,0 @@ const establishConnection = async (parentLog, pool, connectionRetryLimit) => {

dist/routines/executeQuery.d.ts

 import { type ConnectionPoolClient } from '../factories/createConnectionPool';
-import { type ClientConfiguration, type Logger, type PrimitiveValueExpression, type Query, type QueryContext, type QueryId, type QueryResult, type QueryResultRow, type QuerySqlToken, type StreamResult } from '../types';
+import { type ClientConfiguration, type Logger, type Query, type QueryContext, type QueryId, type QueryResult, type QueryResultRow, type StreamResult } from '../types';
+import { type PrimitiveValueExpression, type QuerySqlToken } from '@slonik/sql-tag';
 type GenericQueryResult = StreamResult | QueryResult<QueryResultRow>;
@@ -4,0 +5,0 @@ export type ExecutionRoutine = (connection: ConnectionPoolClient, sql: string, values: readonly PrimitiveValueExpression[], queryContext: QueryContext, query: Query) => Promise<GenericQueryResult>;

dist/routines/executeQuery.js

@@ -6,6 +6,6 @@ "use strict";
 const transactionContext_1 = require("../contexts/transactionContext");
-const errors_1 = require("../errors");
 const state_1 = require("../state");
 const createQueryId_1 = require("../utilities/createQueryId");
 const defer_1 = require("../utilities/defer");
+const errors_1 = require("@slonik/errors");
 const get_stack_trace_1 = require("get-stack-trace");
@@ -12,0 +12,0 @@ const serialize_error_1 = require("serialize-error");

dist/routines/executeQuery.test.js

@@ -29,3 +29,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const errors_1 = require("../errors");
 const createClientConfiguration_1 = require("../helpers.test/createClientConfiguration");
@@ -35,2 +34,3 @@ const createErrorWithCode_1 = require("../helpers.test/createErrorWithCode");
 const executeQuery_1 = require("./executeQuery");
+const errors_1 = require("@slonik/errors");
 const ava_1 = __importDefault(require("ava"));
@@ -37,0 +37,0 @@ const roarr_1 = require("roarr");

dist/state.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.getPoolClientState = exports.poolClientStateMap = void 0;
-const errors_1 = require("./errors");
+const errors_1 = require("@slonik/errors");
 exports.poolClientStateMap = new WeakMap();
@@ -6,0 +6,0 @@ const getPoolClientState = (poolClient) => {

dist/types.d.ts

 /// <reference types="node" />
 /// <reference types="node" />
-/// <reference types="node" />
-import { type SlonikError } from './errors';
 import { type ConnectionPoolClient } from './factories/createConnectionPool';
 import { type DriverFactory, type DriverNotice } from './factories/createDriverFactory';
-import type * as tokens from './tokens';
+import { type SlonikError } from '@slonik/errors';
+import { type PrimitiveValueExpression, type QuerySqlToken, type SqlFragment, type SqlToken } from '@slonik/sql-tag';
 import { type Readable } from 'node:stream';
@@ -40,5 +39,2 @@ import { type ConnectionOptions as TlsConnectionOptions } from 'node:tls';
 export type TypeNameIdentifier = string | 'bool' | 'bytea' | 'float4' | 'float8' | 'int2' | 'int4' | 'int8' | 'json' | 'text' | 'timestamptz' | 'uuid';
-export type SerializableValue = SerializableValue[] | boolean | number | string | readonly SerializableValue[] | {
-    [key: string]: SerializableValue;
-} | null | undefined;
 export type QueryId = string;
@@ -179,6 +175,2 @@ export type MaybePromise<T> = Promise<T> | T;
 };
-export type SqlFragment = {
-    readonly sql: string;
-    readonly values: readonly PrimitiveValueExpression[];
-};
 /**
@@ -218,11 +210,2 @@ * @property name Value of "pg_type"."typname" (e.g. "int8", "timestamp", "timestamptz").
 };
-export type IntervalInput = {
-    days?: number;
-    hours?: number;
-    minutes?: number;
-    months?: number;
-    seconds?: number;
-    weeks?: number;
-    years?: number;
-};
 /**
@@ -251,76 +234,3 @@ * @property connectionId Unique connection ID.
 };
-export type ArraySqlToken = {
-    readonly memberType: SqlToken | TypeNameIdentifier;
-    readonly type: typeof tokens.ArrayToken;
-    readonly values: readonly PrimitiveValueExpression[];
-};
-export type BinarySqlToken = {
-    readonly data: Buffer;
-    readonly type: typeof tokens.BinaryToken;
-};
-export type DateSqlToken = {
-    readonly date: Date;
-    readonly type: typeof tokens.DateToken;
-};
-export type FragmentSqlToken = {
-    readonly sql: string;
-    readonly type: typeof tokens.FragmentToken;
-    readonly values: readonly PrimitiveValueExpression[];
-};
-export type IdentifierSqlToken = {
-    readonly names: readonly string[];
-    readonly type: typeof tokens.IdentifierToken;
-};
-export type IntervalSqlToken = {
-    readonly interval: IntervalInput;
-    readonly type: typeof tokens.IntervalToken;
-};
-export type ListSqlToken = {
-    readonly glue: SqlFragment;
-    readonly members: readonly ValueExpression[];
-    readonly type: typeof tokens.ListToken;
-};
-export type JsonBinarySqlToken = {
-    readonly type: typeof tokens.JsonBinaryToken;
-    readonly value: SerializableValue;
-};
-export type JsonSqlToken = {
-    readonly type: typeof tokens.JsonToken;
-    readonly value: SerializableValue;
-};
-export type QuerySqlToken<T extends ZodTypeAny = ZodTypeAny> = {
-    readonly parser: T;
-    readonly sql: string;
-    readonly type: typeof tokens.QueryToken;
-    readonly values: readonly PrimitiveValueExpression[];
-};
-export type TimestampSqlToken = {
-    readonly date: Date;
-    readonly type: typeof tokens.TimestampToken;
-};
-export type UnnestSqlToken = {
-    readonly columnTypes: Array<[...string[], TypeNameIdentifier]> | Array<SqlFragment | TypeNameIdentifier>;
-    readonly tuples: ReadonlyArray<readonly ValueExpression[]>;
-    readonly type: typeof tokens.UnnestToken;
-};
-export type PrimitiveValueExpression = Buffer | bigint | boolean | number | string | readonly PrimitiveValueExpression[] | null;
-export type SqlToken = ArraySqlToken | BinarySqlToken | DateSqlToken | FragmentSqlToken | IdentifierSqlToken | IntervalSqlToken | JsonBinarySqlToken | JsonSqlToken | ListSqlToken | QuerySqlToken | TimestampSqlToken | UnnestSqlToken;
 export type ValueExpression = PrimitiveValueExpression | SqlFragment | SqlToken;
-export type SqlTag<Z extends Record<string, ZodTypeAny>> = {
-    array: (values: readonly PrimitiveValueExpression[], memberType: SqlFragment | TypeNameIdentifier) => ArraySqlToken;
-    binary: (data: Buffer) => BinarySqlToken;
-    date: (date: Date) => DateSqlToken;
-    fragment: (template: TemplateStringsArray, ...values: ValueExpression[]) => SqlFragment;
-    identifier: (names: readonly string[]) => IdentifierSqlToken;
-    interval: (interval: IntervalInput) => IntervalSqlToken;
-    join: (members: readonly ValueExpression[], glue: SqlFragment) => ListSqlToken;
-    json: (value: SerializableValue) => JsonSqlToken;
-    jsonb: (value: SerializableValue) => JsonBinarySqlToken;
-    literalValue: (value: string) => SqlFragment;
-    timestamp: (date: Date) => TimestampSqlToken;
-    type: <Y extends ZodTypeAny>(parser: Y) => (template: TemplateStringsArray, ...values: ValueExpression[]) => QuerySqlToken<Y>;
-    typeAlias: <K extends keyof Z>(typeAlias: K) => (template: TemplateStringsArray, ...values: ValueExpression[]) => QuerySqlToken<Z[K]>;
-    unnest: (tuples: ReadonlyArray<readonly any[]>, columnTypes: Array<[...string[], TypeNameIdentifier]> | Array<SqlFragment | TypeNameIdentifier>) => UnnestSqlToken;
-    unsafe: (template: TemplateStringsArray, ...values: ValueExpression[]) => QuerySqlToken;
-};
 export type InternalQueryMethod<R = any> = (log: Logger, connection: ConnectionPoolClient, clientConfiguration: ClientConfiguration, slonikSql: QuerySqlToken, uid?: QueryId) => R;
@@ -327,0 +237,0 @@ export type InternalStreamFunction = <T>(log: Logger, connection: ConnectionPoolClient, clientConfiguration: ClientConfiguration, slonikSql: QuerySqlToken, streamHandler: StreamHandler<T>, uid?: QueryId) => Promise<StreamResult>;

package.json

@@ -8,2 +8,4 @@ {
   "dependencies": {
+    "@slonik/errors": "^41.3.0",
+    "@slonik/sql-tag": "^41.3.0",
     "@types/pg": "^8.11.6",
@@ -18,3 +20,2 @@ "get-stack-trace": "^3.1.1",
     "roarr": "^7.21.1",
-    "safe-stable-stringify": "^2.4.3",
     "serialize-error": "^8.0.0",
@@ -25,5 +26,2 @@ "strict-event-emitter-types": "^2.0.0"
   "devDependencies": {
-    "@semantic-release/commit-analyzer": "^12.0.0",
-    "@semantic-release/github": "^10.0.2",
-    "@semantic-release/npm": "^12.0.0",
     "@types/node": "^18.15.3",
@@ -37,6 +35,3 @@ "@types/sinon": "^10.0.20",
     "get-port": "^5.1.1",
-    "husky": "^9.0.11",
-    "knip": "^5.5.0",
     "nyc": "^15.1.0",
-    "semantic-release": "^23.0.5",
     "sinon": "^15.1.0",
@@ -90,7 +85,6 @@ "ts-node": "^10.9.1",
   "scripts": {
-    "build": "rm -fr ./dist && tsc --project ./tsconfig.build.json",
-    "lint": "npm run lint:cspell && npm run lint:eslint && npm run lint:knip && npm run lint:tsc",
+    "build": "rm -fr ./dist && tsc --project ./tsconfig.json",
+    "lint": "npm run lint:cspell && npm run lint:eslint && npm run lint:tsc",
     "lint:cspell": "cspell . --no-progress --gitignore",
     "lint:eslint": "eslint --cache ./src",
-    "lint:knip": "knip",
     "lint:tsc": "tsc --noEmit",
@@ -100,3 +94,3 @@ "test": "nyc ava --verbose --serial"
   "types": "./dist/index.d.ts",
-  "version": "41.2.1"
+  "version": "42.0.0"
 }

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

 /* eslint-disable ava/max-asserts */
 
 import { createPgDriverFactory } from '../../factories/createPgDriverFactory';
-import { createSqlTag } from '../../factories/createSqlTag';
 import { createPoolWithSpy } from '../../helpers.test/createPoolWithSpy';
 import { createTestRunner } from '../../helpers.test/createTestRunner';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -8,0 +8,0 @@ const driverFactory = createPgDriverFactory();

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

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

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

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

src/connectionMethods/anyFirst.test.ts

@@ -1,6 +0,6 @@
-import { DataIntegrityError } from '../errors';
 import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
-import { createSqlTag } from '../factories/createSqlTag';
 import { createTestRunner } from '../helpers.test/createTestRunner';
+import { DataIntegrityError } from '@slonik/errors';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -7,0 +7,0 @@ const driverFactory = createPgDriverFactory();

src/connectionMethods/anyFirst.ts

@@ -1,5 +0,5 @@
-import { DataIntegrityError } from '../errors';
 import { type InternalQueryMethod } from '../types';
 import { createQueryId } from '../utilities/createQueryId';
 import { any } from './any';
+import { DataIntegrityError } from '@slonik/errors';
 
@@ -6,0 +6,0 @@ export const anyFirst: InternalQueryMethod = async (

src/connectionMethods/exists.ts

@@ -1,5 +0,6 @@
-import { DataIntegrityError } from '../errors';
-import { type InternalQueryMethod, type QuerySqlToken } from '../types';
+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';
 
@@ -6,0 +7,0 @@ export const exists: InternalQueryMethod<Promise<boolean>> = async (

src/connectionMethods/many.test.ts

@@ -1,6 +0,6 @@
-import { NotFoundError } from '../errors';
 import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
-import { createSqlTag } from '../factories/createSqlTag';
 import { createTestRunner } from '../helpers.test/createTestRunner';
+import { NotFoundError } from '@slonik/errors';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -7,0 +7,0 @@ const driverFactory = createPgDriverFactory();

src/connectionMethods/many.ts

@@ -1,5 +0,5 @@
-import { NotFoundError } from '../errors';
 import { type InternalQueryMethod } from '../types';
 import { createQueryId } from '../utilities/createQueryId';
 import { query } from './query';
+import { NotFoundError } from '@slonik/errors';
 
@@ -6,0 +6,0 @@ /**

src/connectionMethods/manyFirst.test.ts

@@ -1,6 +0,6 @@
-import { DataIntegrityError, NotFoundError } from '../errors';
 import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
-import { createSqlTag } from '../factories/createSqlTag';
 import { createTestRunner } from '../helpers.test/createTestRunner';
+import { DataIntegrityError, NotFoundError } from '@slonik/errors';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -7,0 +7,0 @@ const driverFactory = createPgDriverFactory();

src/connectionMethods/manyFirst.ts

@@ -1,5 +0,5 @@
-import { DataIntegrityError } from '../errors';
 import { type InternalQueryMethod } from '../types';
 import { createQueryId } from '../utilities/createQueryId';
 import { many } from './many';
+import { DataIntegrityError } from '@slonik/errors';
 
@@ -6,0 +6,0 @@ export const manyFirst: InternalQueryMethod = async (

src/connectionMethods/maybeOne.test.ts

@@ -1,6 +0,6 @@
-import { DataIntegrityError } from '../errors';
 import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
-import { createSqlTag } from '../factories/createSqlTag';
 import { createTestRunner } from '../helpers.test/createTestRunner';
+import { DataIntegrityError } from '@slonik/errors';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -7,0 +7,0 @@ const driverFactory = createPgDriverFactory();

src/connectionMethods/maybeOne.ts

@@ -1,5 +0,5 @@
-import { DataIntegrityError } from '../errors';
 import { type InternalQueryMethod } from '../types';
 import { createQueryId } from '../utilities/createQueryId';
 import { query } from './query';
+import { DataIntegrityError } from '@slonik/errors';
 
@@ -6,0 +6,0 @@ /**

src/connectionMethods/maybeOneFirst.test.ts

@@ -1,6 +0,6 @@
-import { DataIntegrityError } from '../errors';
 import { createPgDriverFactory } from '../factories/createPgDriverFactory';
 import { createPool } from '../factories/createPool';
-import { createSqlTag } from '../factories/createSqlTag';
 import { createTestRunner } from '../helpers.test/createTestRunner';
+import { DataIntegrityError } from '@slonik/errors';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -7,0 +7,0 @@ const driverFactory = createPgDriverFactory();

src/connectionMethods/maybeOneFirst.ts

@@ -1,5 +0,5 @@
-import { DataIntegrityError } from '../errors';
 import { type InternalQueryMethod } from '../types';
 import { createQueryId } from '../utilities/createQueryId';
 import { maybeOne } from './maybeOne';
+import { DataIntegrityError } from '@slonik/errors';
 
@@ -6,0 +6,0 @@ /**

src/connectionMethods/one.test.ts

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

src/connectionMethods/one.ts

@@ -1,5 +0,5 @@
-import { DataIntegrityError, NotFoundError } from '../errors';
 import { type InternalQueryMethod } from '../types';
 import { createQueryId } from '../utilities/createQueryId';
 import { query } from './query';
+import { DataIntegrityError, NotFoundError } from '@slonik/errors';
 
@@ -6,0 +6,0 @@ /**

src/connectionMethods/oneFirst.test.ts

@@ -0,1 +1,4 @@
+import { createPgDriverFactory } from '../factories/createPgDriverFactory';
+import { createPool } from '../factories/createPool';
+import { createTestRunner } from '../helpers.test/createTestRunner';
 import {
@@ -5,7 +8,4 @@ DataIntegrityError,
   UnexpectedStateError,
-} from '../errors';
-import { createPgDriverFactory } from '../factories/createPgDriverFactory';
-import { createPool } from '../factories/createPool';
-import { createSqlTag } from '../factories/createSqlTag';
-import { createTestRunner } from '../helpers.test/createTestRunner';
+} from '@slonik/errors';
+import { createSqlTag } from '@slonik/sql-tag';
 import { expectTypeOf } from 'expect-type';
@@ -12,0 +12,0 @@ import { z } from 'zod';

src/connectionMethods/oneFirst.ts

@@ -1,5 +0,5 @@
-import { UnexpectedStateError } from '../errors';
 import { type InternalQueryMethod } from '../types';
 import { createQueryId } from '../utilities/createQueryId';
 import { one } from './one';
+import { UnexpectedStateError } from '@slonik/errors';
 
@@ -6,0 +6,0 @@ /**

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

 import { createPgDriverFactory } from '../../../factories/createPgDriverFactory';
-import { createSqlTag } from '../../../factories/createSqlTag';
 import { createPoolWithMockedQuery } from '../../../helpers.test/createPoolWithMockedQuery';
 import { createTestRunner } from '../../../helpers.test/createTestRunner';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -6,0 +6,0 @@ const driverFactory = createPgDriverFactory();

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

 import { createPgDriverFactory } from '../../../factories/createPgDriverFactory';
-import { createSqlTag } from '../../../factories/createSqlTag';
 import { createPoolWithSpy } from '../../../helpers.test/createPoolWithSpy';
 import { createTestRunner } from '../../../helpers.test/createTestRunner';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -6,0 +6,0 @@ const driverFactory = createPgDriverFactory();

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

 import { createPgDriverFactory } from '../../../factories/createPgDriverFactory';
-import { createSqlTag } from '../../../factories/createSqlTag';
 import { createPoolWithMockedQuery } from '../../../helpers.test/createPoolWithMockedQuery';
 import { createTestRunner } from '../../../helpers.test/createTestRunner';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -6,0 +6,0 @@ const driverFactory = createPgDriverFactory();

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

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

src/connectionMethods/transaction.ts

 import { bindTransactionConnection } from '../binders/bindTransactionConnection';
 import { TRANSACTION_ROLLBACK_ERROR_PREFIX } from '../constants';
 import { transactionContext } from '../contexts/transactionContext';
-import { BackendTerminatedError, UnexpectedStateError } from '../errors';
 import { getPoolClientState } from '../state';
 import { type InternalTransactionFunction } from '../types';
 import { createUid } from '../utilities/createUid';
+import { BackendTerminatedError, UnexpectedStateError } from '@slonik/errors';
 import { serializeError } from 'serialize-error';
@@ -9,0 +9,0 @@

src/factories/createClientConfiguration.ts

@@ -1,2 +0,1 @@
-import { InvalidConfigurationError } from '../errors';
 import {
@@ -8,2 +7,3 @@ type ClientConfiguration,
 import { createTypeParserPreset } from './createTypeParserPreset';
+import { InvalidConfigurationError } from '@slonik/errors';
 
@@ -10,0 +10,0 @@ export const createClientConfiguration = (

src/factories/createConnection.ts

 import { bindPoolConnection } from '../binders/bindPoolConnection';
-import { UnexpectedStateError } from '../errors';
 import { establishConnection } from '../routines/establishConnection';
@@ -12,3 +11,2 @@ import { getPoolClientState } from '../state';
   type MaybePromise,
-  type QuerySqlToken,
 } from '../types';
@@ -20,2 +18,4 @@ import { defer } from '../utilities/defer';
 } from './createConnectionPool';
+import { UnexpectedStateError } from '@slonik/errors';
+import { type QuerySqlToken } from '@slonik/sql-tag';
 
@@ -22,0 +22,0 @@ type ConnectionHandlerType = (

src/factories/createPgDriverFactory.ts

 /* eslint-disable canonical/id-match */
 
+import { type Field, type Query, type TypeParser } from '../types';
+import { parseDsn } from '../utilities/parseDsn';
 import {
+  createDriverFactory,
+  type DriverCommand,
+  type DriverConfiguration,
+  type DriverFactory,
+} from './createDriverFactory';
+import {
   BackendTerminatedError,
@@ -16,16 +24,4 @@ BackendTerminatedUnexpectedlyError,
   UniqueIntegrityConstraintViolationError,
-} from '../errors';
-import {
-  type Field,
-  type PrimitiveValueExpression,
-  type Query,
-  type TypeParser,
-} from '../types';
-import { parseDsn } from '../utilities/parseDsn';
-import {
-  createDriverFactory,
-  type DriverCommand,
-  type DriverConfiguration,
-  type DriverFactory,
-} from './createDriverFactory';
+} from '@slonik/errors';
+import { type PrimitiveValueExpression } from '@slonik/sql-tag';
 import { Transform } from 'node:stream';
@@ -32,0 +28,0 @@ // eslint-disable-next-line no-restricted-imports

src/index.ts

@@ -1,2 +0,2 @@
-import { createSqlTag } from './factories/createSqlTag';
+import { createSqlTag } from '@slonik/sql-tag';
 
@@ -20,28 +20,3 @@ export {
 
-export {
-  BackendTerminatedError,
-  BackendTerminatedUnexpectedlyError,
-  CheckIntegrityConstraintViolationError,
-  ConnectionError,
-  DataIntegrityError,
-  ForeignKeyIntegrityConstraintViolationError,
-  IdleTransactionTimeoutError,
-  InputSyntaxError,
-  IntegrityConstraintViolationError,
-  InvalidConfigurationError,
-  InvalidInputError,
-  NotFoundError,
-  NotNullIntegrityConstraintViolationError,
-  SchemaValidationError,
-  SlonikError,
-  StatementCancelledError,
-  StatementTimeoutError,
-  TupleMovedToAnotherPartitionError,
-  UnexpectedForeignConnectionError,
-  UnexpectedStateError,
-  UniqueIntegrityConstraintViolationError,
-} from './errors';
 export { createPool } from './factories/createPool';
-export { createSqlTag } from './factories/createSqlTag';
-export { createSqlTokenSqlFragment } from './factories/createSqlTokenSqlFragment';
 export { createTypeParserPreset } from './factories/createTypeParserPreset';
@@ -55,4 +30,2 @@ export { createBigintTypeParser } from './factories/typeParsers/createBigintTypeParser';
 export type {
-  ArraySqlToken,
-  BinarySqlToken,
   ClientConfiguration,
@@ -69,12 +42,6 @@ ClientConfigurationInput,
   Field,
-  FragmentSqlToken,
   IdentifierNormalizer,
-  IdentifierSqlToken,
   Interceptor,
-  JsonBinarySqlToken,
-  JsonSqlToken,
-  ListSqlToken,
   MaybePromise,
   PoolContext,
-  PrimitiveValueExpression,
   Query,
@@ -86,14 +53,49 @@ QueryContext,
   QueryResultRowColumn,
-  QuerySqlToken,
-  SerializableValue,
-  SqlFragment,
-  SqlTag,
-  SqlToken,
   TypeNameIdentifier,
   TypeParser,
-  UnnestSqlToken,
   ValueExpression,
 } from './types';
-export { isSqlToken } from './utilities/isSqlToken';
 export { parseDsn } from './utilities/parseDsn';
 export { stringifyDsn } from './utilities/stringifyDsn';
+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 { createSqlTokenSqlFragment } from '@slonik/sql-tag';
+export {
+  type ArraySqlToken,
+  type BinarySqlToken,
+  createSqlTag,
+  type FragmentSqlToken,
+  type IdentifierSqlToken,
+  isSqlToken,
+  type JsonBinarySqlToken,
+  type JsonSqlToken,
+  type ListSqlToken,
+  type PrimitiveValueExpression,
+  type QuerySqlToken,
+  type SerializableValue,
+  type SqlFragment,
+  type SqlTag,
+  type SqlToken,
+  type UnnestSqlToken,
+} from '@slonik/sql-tag';

src/routines/establishConnection.ts

@@ -1,2 +0,1 @@
-import { ConnectionError, UnexpectedStateError } from '../errors';
 import {
@@ -9,2 +8,3 @@ type ConnectionPool,
 import { createUid } from '../utilities/createUid';
+import { ConnectionError, UnexpectedStateError } from '@slonik/errors';
 import { serializeError } from 'serialize-error';
@@ -11,0 +11,0 @@

src/routines/executeQuery.test.ts

 import { type QuerySqlToken } from '..';
-import { InvalidInputError } from '../errors';
 import { createClientConfiguration } from '../helpers.test/createClientConfiguration';
@@ -7,2 +6,3 @@ import { createErrorWithCode } from '../helpers.test/createErrorWithCode';
 import { executeQuery } from './executeQuery';
+import { InvalidInputError } from '@slonik/errors';
 import anyTest, { type TestFn } from 'ava';
@@ -9,0 +9,0 @@ import { Roarr } from 'roarr';

src/routines/executeQuery.ts

 import { TRANSACTION_ROLLBACK_ERROR_PREFIX } from '../constants';
 import { transactionContext } from '../contexts/transactionContext';
-import {
-  BackendTerminatedError,
-  BackendTerminatedUnexpectedlyError,
-  InvalidInputError,
-  SlonikError,
-  TupleMovedToAnotherPartitionError,
-  UnexpectedForeignConnectionError,
-  UnexpectedStateError,
-} from '../errors';
 import { type ConnectionPoolClient } from '../factories/createConnectionPool';
@@ -19,3 +10,2 @@ import { type DriverNotice } from '../factories/createDriverFactory';
   type Logger,
-  type PrimitiveValueExpression,
   type Query,
@@ -26,3 +16,2 @@ type QueryContext,
   type QueryResultRow,
-  type QuerySqlToken,
   type StreamResult,
@@ -32,2 +21,15 @@ } from '../types';
 import { defer } from '../utilities/defer';
+import {
+  BackendTerminatedError,
+  BackendTerminatedUnexpectedlyError,
+  InvalidInputError,
+  SlonikError,
+  TupleMovedToAnotherPartitionError,
+  UnexpectedForeignConnectionError,
+  UnexpectedStateError,
+} from '@slonik/errors';
+import {
+  type PrimitiveValueExpression,
+  type QuerySqlToken,
+} from '@slonik/sql-tag';
 import { getStackTrace } from 'get-stack-trace';
@@ -34,0 +36,0 @@ import { serializeError } from 'serialize-error';

src/state.ts

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

src/types.ts

@@ -1,2 +0,1 @@
-import { type SlonikError } from './errors';
 import { type ConnectionPoolClient } from './factories/createConnectionPool';
@@ -7,3 +6,9 @@ import {
 } from './factories/createDriverFactory';
-import type * as tokens from './tokens';
+import { type SlonikError } from '@slonik/errors';
+import {
+  type PrimitiveValueExpression,
+  type QuerySqlToken,
+  type SqlFragment,
+  type SqlToken,
+} from '@slonik/sql-tag';
 import { type Readable } from 'node:stream';
@@ -60,14 +65,2 @@ import { type ConnectionOptions as TlsConnectionOptions } from 'node:tls';
 
-export type SerializableValue =
-  | SerializableValue[]
-  | boolean
-  | number
-  | string
-  | readonly SerializableValue[]
-  | {
-      [key: string]: SerializableValue;
-    }
-  | null
-  | undefined;
-
 export type QueryId = string;
@@ -242,7 +235,2 @@
 
-export type SqlFragment = {
-  readonly sql: string;
-  readonly values: readonly PrimitiveValueExpression[];
-};
-
 /**
@@ -286,12 +274,2 @@ * @property name Value of "pg_type"."typname" (e.g. "int8", "timestamp", "timestamptz").
 
-export type IntervalInput = {
-  days?: number;
-  hours?: number;
-  minutes?: number;
-  months?: number;
-  seconds?: number;
-  weeks?: number;
-  years?: number;
-};
-
 /**
@@ -321,144 +299,4 @@ * @property connectionId Unique connection ID.
 
-export type ArraySqlToken = {
-  readonly memberType: SqlToken | TypeNameIdentifier;
-  readonly type: typeof tokens.ArrayToken;
-  readonly values: readonly PrimitiveValueExpression[];
-};
-
-export type BinarySqlToken = {
-  readonly data: Buffer;
-  readonly type: typeof tokens.BinaryToken;
-};
-
-export type DateSqlToken = {
-  readonly date: Date;
-  readonly type: typeof tokens.DateToken;
-};
-
-export type FragmentSqlToken = {
-  readonly sql: string;
-  readonly type: typeof tokens.FragmentToken;
-  readonly values: readonly PrimitiveValueExpression[];
-};
-
-export type IdentifierSqlToken = {
-  readonly names: readonly string[];
-  readonly type: typeof tokens.IdentifierToken;
-};
-
-export type IntervalSqlToken = {
-  readonly interval: IntervalInput;
-  readonly type: typeof tokens.IntervalToken;
-};
-
-export type ListSqlToken = {
-  readonly glue: SqlFragment;
-  readonly members: readonly ValueExpression[];
-  readonly type: typeof tokens.ListToken;
-};
-
-export type JsonBinarySqlToken = {
-  readonly type: typeof tokens.JsonBinaryToken;
-  readonly value: SerializableValue;
-};
-
-export type JsonSqlToken = {
-  readonly type: typeof tokens.JsonToken;
-  readonly value: SerializableValue;
-};
-
-export type QuerySqlToken<T extends ZodTypeAny = ZodTypeAny> = {
-  readonly parser: T;
-  readonly sql: string;
-  readonly type: typeof tokens.QueryToken;
-  readonly values: readonly PrimitiveValueExpression[];
-};
-
-export type TimestampSqlToken = {
-  readonly date: Date;
-  readonly type: typeof tokens.TimestampToken;
-};
-
-export type UnnestSqlToken = {
-  readonly columnTypes:
-    | Array<[...string[], TypeNameIdentifier]>
-    | Array<SqlFragment | TypeNameIdentifier>;
-  readonly tuples: ReadonlyArray<readonly ValueExpression[]>;
-  readonly type: typeof tokens.UnnestToken;
-};
-
-export type PrimitiveValueExpression =
-  | Buffer
-  | bigint
-  | boolean
-  | number
-  | string
-  | readonly PrimitiveValueExpression[]
-  | null;
-
-export type SqlToken =
-  | ArraySqlToken
-  | BinarySqlToken
-  | DateSqlToken
-  | FragmentSqlToken
-  | IdentifierSqlToken
-  | IntervalSqlToken
-  | JsonBinarySqlToken
-  | JsonSqlToken
-  | ListSqlToken
-  | QuerySqlToken
-  | TimestampSqlToken
-  | UnnestSqlToken;
-
 export type ValueExpression = PrimitiveValueExpression | SqlFragment | SqlToken;
 
-export type SqlTag<Z extends Record<string, ZodTypeAny>> = {
-  array: (
-    values: readonly PrimitiveValueExpression[],
-    memberType: SqlFragment | TypeNameIdentifier,
-  ) => ArraySqlToken;
-  binary: (data: Buffer) => BinarySqlToken;
-  date: (date: Date) => DateSqlToken;
-  fragment: (
-    template: TemplateStringsArray,
-    ...values: ValueExpression[]
-  ) => SqlFragment;
-  identifier: (names: readonly string[]) => IdentifierSqlToken;
-  interval: (interval: IntervalInput) => IntervalSqlToken;
-  join: (
-    members: readonly ValueExpression[],
-    glue: SqlFragment,
-  ) => ListSqlToken;
-  json: (value: SerializableValue) => JsonSqlToken;
-  jsonb: (value: SerializableValue) => JsonBinarySqlToken;
-  literalValue: (value: string) => SqlFragment;
-  timestamp: (date: Date) => TimestampSqlToken;
-  type: <Y extends ZodTypeAny>(
-    parser: Y,
-  ) => (
-    template: TemplateStringsArray,
-    ...values: ValueExpression[]
-  ) => QuerySqlToken<Y>;
-  typeAlias: <K extends keyof Z>(
-    typeAlias: K,
-  ) => (
-    template: TemplateStringsArray,
-    ...values: ValueExpression[]
-  ) => QuerySqlToken<Z[K]>;
-  unnest: (
-    // Value might be ReadonlyArray<ReadonlyArray<PrimitiveValueExpression>>,
-    // or it can be infinitely nested array, e.g.
-    // https://github.com/gajus/slonik/issues/44
-    // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    tuples: ReadonlyArray<readonly any[]>,
-    columnTypes:
-      | Array<[...string[], TypeNameIdentifier]>
-      | Array<SqlFragment | TypeNameIdentifier>,
-  ) => UnnestSqlToken;
-  unsafe: (
-    template: TemplateStringsArray,
-    ...values: ValueExpression[]
-  ) => QuerySqlToken;
-};
-
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
@@ -465,0 +303,0 @@ export type InternalQueryMethod<R = any> = (

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Dev dependency count

13

decreased by-31.58%

Number of low supply chain risk alerts

1

decreased by-50%

Worsened metrics

Total package byte prevSize

736563

decreased by-30.35%

Dependency count

14

increased by7.69%

Number of package files

378

decreased by-36.89%

Lines of code

14550

decreased by-22.74%

Number of lines in readme file

5

decreased by-99.82%

Dependency changes

• + Added@slonik/errors@^41.3.0

• + Added@slonik/sql-tag@^41.3.0

• + Added@slonik/errors@41.3.0(transitive)

• + Added@slonik/sql-tag@41.3.0(transitive)

• + Added@slonik/types@41.3.0(transitive)

• - Removedsafe-stable-stringify@^2.4.3