src/connectionMethods/transaction.ts

@@ -38,7 +38,10 @@ const execTransaction: InternalTransactionFunction = async (
       throw new BackendTerminatedError(poolClientState.terminated);
     }
 
-    if (poolClientState.mock === false) {
+    if (
+      poolClientState.mock === false &&
+      poolClientState.ignoreCommit === false
+    ) {
       await connection.query('COMMIT');
     }
 

src/factories/createClientConfiguration.ts

@@ -17,6 +17,7 @@ export const createClientConfiguration = (
     connectionTimeout: 5_000,
     idleInTransactionSessionTimeout: 60_000,
     idleTimeout: 5_000,
+    ignoreCommit: false,
     interceptors: [],
     maximumPoolSize: 10,
     queryRetryLimit: 5,

src/factories/createConnection.ts

@@ -97,6 +97,7 @@ export const createConnection = async (
 
       poolClientStateMap.set(connection, {
         connectionId: createUid(),
+        ignoreCommit: poolState.ignoreCommit,
         mock: poolState.mock,
         poolId: poolState.poolId,
         terminated: null,

src/factories/createMockPool.ts

@@ -40,6 +40,7 @@ export const createMockPool = (
 
   poolStateMap.set(pool, {
     ended: false,
+    ignoreCommit: true,
     mock: true,
     poolId,
     typeOverrides: null,

src/factories/createPool.ts

@@ -72,6 +72,7 @@ export const createPool = async (
 
   poolStateMap.set(pool, {
     ended: false,
+    ignoreCommit: clientConfiguration.ignoreCommit,
     mock: false,
     poolId,
     typeOverrides: null,

src/state.ts

@@ -5,6 +5,7 @@ import { type Pool as PgPool, type PoolClient as PgClientPool } from 'pg';
 
 type PoolState = {
   ended: boolean;
+  ignoreCommit: boolean;
   mock: boolean;
   poolId: string;
   typeOverrides: Promise<TypeOverrides> | null;
@@ -13,6 +14,7 @@ type PoolState = {
 type PoolClientState = {
   activeQuery?: DeferredPromise<unknown>;
   connectionId: string;
+  ignoreCommit: boolean;
   mock: boolean;
   poolId: string;
   terminated: Error | null;

src/types.ts

@@ -99,6 +99,10 @@ export type ClientConfiguration = {
    * Timeout (in milliseconds) after which idle clients are closed. Use 'DISABLE_TIMEOUT' constant to disable the timeout. (Default: 5000)
    */
   readonly idleTimeout: number | 'DISABLE_TIMEOUT';
+  /**
+   * Do not send COMMIT after successful transaction. (Default: false)
+   */
+  readonly ignoreCommit: boolean;
   /**
    * An array of [Slonik interceptors](https://github.com/gajus/slonik#slonik-interceptors).
    */

test/helpers/createClientConfiguration.ts

@@ -7,6 +7,7 @@ export const createClientConfiguration = (): ClientConfiguration => {
     connectionTimeout: 5_000,
     idleInTransactionSessionTimeout: 60_000,
     idleTimeout: 5_000,
+    ignoreCommit: false,
     interceptors: [],
     maximumPoolSize: 10,
     queryRetryLimit: 5,

test/helpers/createPool.ts

@@ -44,6 +44,7 @@ export const createPool = async (
 
   poolStateMap.set(internalPool, {
     ended: false,
+    ignoreCommit: false,
     mock: false,
     poolId: '1',
     typeOverrides: null,
@@ -61,6 +62,7 @@ export const createPool = async (
     connectionTimeout: 5_000,
     idleInTransactionSessionTimeout: 5_000,
     idleTimeout: 5_000,
+    ignoreCommit: false,
     interceptors: [],
     maximumPoolSize: 1,
     queryRetryLimit: 1,

test/slonik/factories/createClientConfiguration.ts

@@ -8,6 +8,7 @@ const defaultConfiguration = {
   connectionTimeout: 5_000,
   idleInTransactionSessionTimeout: 60_000,
   idleTimeout: 5_000,
+  ignoreCommit: false,
   interceptors: [],
   maximumPoolSize: 10,
   queryRetryLimit: 5,

test/slonik/integration/pg.ts

@@ -9,6 +9,29 @@ const { test } = createTestRunner(PgPool, 'pg');
 
 createIntegrationTests(test, PgPool);
 
+test('does not break out of a transaction', async (t) => {
+  const pool = await createPool(t.context.dsn, {
+    ignoreCommit: true,
+    PgPool,
+  });
+
+  await t.notThrowsAsync(
+    pool.connect(async (connection) => {
+      await connection.query(sql.unsafe`BEGIN`);
+      await connection.query(sql.unsafe`SAVEPOINT foo`);
+
+      await connection.transaction(async (transaction) => {
+        await transaction.query(sql.unsafe`SELECT 1`);
+      });
+
+      await connection.query(sql.unsafe`ROLLBACK TO SAVEPOINT foo`);
+      await connection.query(sql.unsafe`ROLLBACK`);
+    }),
+  );
+
+  await pool.end();
+});
+
 test('returns expected query result object (NOTICE)', async (t) => {
   const pool = await createPool(t.context.dsn, {
     PgPool,

test/slonik/routines/executeQuery.ts

@@ -30,6 +30,7 @@ beforeEach((t) => {
 
   poolClientStateMap.set(t.context.connection, {
     connectionId: '1',
+    ignoreCommit: false,
     mock: true,
     poolId: '1',
     terminated: null,
@@ -162,6 +163,7 @@ test('transaction errors are not handled if the function was called by a transac
 
   poolClientStateMap.set(connection, {
     connectionId: '1',
+    ignoreCommit: false,
     mock: true,
     poolId: '1',
     terminated: null,