Next.js 14 + Drizzle ORM + NeonDB事务处理报错及集成指导请求

问题原因 #

你遇到的No transactions support in neon-http driver错误，是因为drizzle-orm/neon-http驱动本身不支持事务操作。要在NeonDB上实现事务，必须切换到基于Neon官方@neondatabase/serverless库的Pool/Client驱动。

解决方案步骤 #

1. 安装依赖

首先安装Neon官方的Serverless客户端库：

npm install @neondatabase/serverless

2. 修改数据库初始化文件

更新src/db/drizzle.ts，替换原有的neon-http驱动为neon-serverless，并通过连接池初始化Drizzle：

import { config } from "dotenv";
import { Pool } from "@neondatabase/serverless";
import { drizzle } from "drizzle-orm/neon-serverless";
import * as schema from "./schema";

config({ path: ".env" });

// 创建单例连接池，避免重复创建连接
const pool = new Pool({ connectionString: process.env.DATABASE_URL! });
export const db = drizzle(pool, { schema });

3. 调整事务代码

现在可以直接使用Drizzle内置的transaction方法执行事务，只需将原代码中的事务调用对象替换为导出的db即可：

const data = await db.transaction(async (tx) => {
  const productIdResult = await tx.insert(products).values({ type: "music" }).returning({ id: products.id });
  const productId = productIdResult[0].id;
  await tx.insert(music).values({ ...product, id: productId });
  await tx.insert(musicCategories).values(categoryIds);
  return productId;
});

可选：手动管理事务（进阶）

如果需要更精细的事务控制，可以手动获取Client并管理事务生命周期：

const client = await db.$pool.connect();
try {
  await client.query('BEGIN');
  
  const productIdResult = await db.insert(products)
    .values({ type: "music" })
    .returning({ id: products.id })
    .execute(client);
  const productId = productIdResult[0].id;
  
  await db.insert(music).values({ ...product, id: productId }).execute(client);
  await db.insert(musicCategories).values(categoryIds).execute(client);
  
  await client.query('COMMIT');
  return productId;
} catch (err) {
  await client.query('ROLLBACK');
  throw err;
} finally {
  client.release();
}

注意事项 #

• drizzle.config.ts无需修改，迁移工具仍可正常使用原配置。
• 在Next.js中确保连接池是单例（如上述代码全局导出db），避免重复创建连接导致资源浪费。
• 事务中所有操作必须使用回调函数内的tx实例（或手动传入的client），否则无法保证事务原子性。

内容的提问来源于stack exchange，提问作者Dinesh