Switched to pooled connection, but still seeing `prepared statement XXXX` does not exist.

import * as dotenv from 'dotenv';

// Only load the local enviornment file if we are running locally
// VERCEL_ENV is 'development' when running the Next.js dev server
// VERCEL_ENV is undefined when running one-off scripts locally (such as migrate.ts)
if (process.env.VERCEL_ENV === 'development' || process.env.VERCEL_ENV === undefined) {
  dotenv.config({ path: '.env.local' });
}

import { neon, neonConfig, Client } from '@neondatabase/serverless';
import type { NodePgDatabase } from 'drizzle-orm/node-postgres';
import { drizzle as drizzleHttp, type NeonHttpDatabase } from 'drizzle-orm/neon-http';
import { drizzle as drizzleServerless } from 'drizzle-orm/neon-serverless';

import * as schema from '@/server/schema';

const DATABASE_URL = process.env.DATABASE_URL || '';

export type NonTransactionalDatabase = NeonHttpDatabase<typeof schema>;
export type TransactionalDatabase = NodePgDatabase<typeof schema>;
export type Database = NonTransactionalDatabase | TransactionalDatabase;

neonConfig.fetchConnectionCache = true;
const neonClient = neon(DATABASE_URL);

/**
 * Non-transactional database client using Drizzle ORM and Neon. This client does not need to be closed and can be imported globally.
 */
export const NonTransactionalDbClient: NonTransactionalDatabase = drizzleHttp(neonClient, { schema, logger: true });

/**
 * Creates a transactional database instance. THIS MUST BE CLOSED AFTER USE WITH `pgClient.end()`.
 *
 * @returns A Promise resolving to an object containing both the Drizzle ORM client and the PostgreSQL client.
 */
export const getTransactionalDbInstance = async (): Promise<{
  drizzleClient: TransactionalDatabase;
  pgClient: Client;
}> => {
  const pgClient = new Client({ connectionString: DATABASE_URL });
  await pgClient.connect();
  const drizzleClient = drizzleServerless(pgClient, { schema, logger: true });

  return { drizzleClient, pgClient };
};

/**
 * Runs a transactional query using Drizzle ORM.
 *
 * @param action A function taking a transactional database and returning a Promise.
 * @returns A Promise of the result of the transactional action.
 */
export const runTransactionalQuery = async <T>(action: (db: TransactionalDatabase) => Promise<T>): Promise<T> => {
  let client;
  try {
    const { drizzleClient, pgClient } = await getTransactionalDbInstance();
    client = pgClient;
    const results = await action(drizzleClient); // pass the `db` instance to the action
    return results;
  } finally {
    if (client) {
      await client.end(); // always close the client, even if the action fails
    }
  }
};

import * as dotenv from 'dotenv';

// Only load the local enviornment file if we are running locally
// VERCEL_ENV is 'development' when running the Next.js dev server
// VERCEL_ENV is undefined when running one-off scripts locally (such as migrate.ts)
if (process.env.VERCEL_ENV === 'development' || process.env.VERCEL_ENV === undefined) {
  dotenv.config({ path: '.env.local' });
}

import { neon, neonConfig, Client } from '@neondatabase/serverless';
import type { NodePgDatabase } from 'drizzle-orm/node-postgres';
import { drizzle as drizzleHttp, type NeonHttpDatabase } from 'drizzle-orm/neon-http';
import { drizzle as drizzleServerless } from 'drizzle-orm/neon-serverless';

import * as schema from '@/server/schema';

const DATABASE_URL = process.env.DATABASE_URL || '';

export type NonTransactionalDatabase = NeonHttpDatabase<typeof schema>;
export type TransactionalDatabase = NodePgDatabase<typeof schema>;
export type Database = NonTransactionalDatabase | TransactionalDatabase;

neonConfig.fetchConnectionCache = true;
const neonClient = neon(DATABASE_URL);

/**
 * Non-transactional database client using Drizzle ORM and Neon. This client does not need to be closed and can be imported globally.
 */
export const NonTransactionalDbClient: NonTransactionalDatabase = drizzleHttp(neonClient, { schema, logger: true });

/**
 * Creates a transactional database instance. THIS MUST BE CLOSED AFTER USE WITH `pgClient.end()`.
 *
 * @returns A Promise resolving to an object containing both the Drizzle ORM client and the PostgreSQL client.
 */
export const getTransactionalDbInstance = async (): Promise<{
  drizzleClient: TransactionalDatabase;
  pgClient: Client;
}> => {
  const pgClient = new Client({ connectionString: DATABASE_URL });
  await pgClient.connect();
  const drizzleClient = drizzleServerless(pgClient, { schema, logger: true });

  return { drizzleClient, pgClient };
};

/**
 * Runs a transactional query using Drizzle ORM.
 *
 * @param action A function taking a transactional database and returning a Promise.
 * @returns A Promise of the result of the transactional action.
 */
export const runTransactionalQuery = async <T>(action: (db: TransactionalDatabase) => Promise<T>): Promise<T> => {
  let client;
  try {
    const { drizzleClient, pgClient } = await getTransactionalDbInstance();
    client = pgClient;
    const results = await action(drizzleClient); // pass the `db` instance to the action
    return results;
  } finally {
    if (client) {
      await client.end(); // always close the client, even if the action fails
    }
  }
};