基于NextJS构建多数据库多租户SaaS应用方案咨询

核心思路 #

基于用户的租户标识（tenantId），动态映射到对应的PostgreSQL数据库，通过Prisma创建专属的数据库客户端实例，确保每个租户只能访问自己的数据库。

具体实现步骤 #

1. 租户标识的传递与校验 #

用户登录后，将tenantId存入会话（比如用NextAuth的session机制），后续所有请求从会话中提取tenantId，作为数据库匹配的核心依据。需在请求入口（如Middleware、API路由、Server Components）校验tenantId的合法性，防止越权访问。

2. 动态创建Prisma客户端 #

通过工厂函数根据tenantId生成对应数据库的连接字符串，复用已创建的客户端实例以优化性能：

// lib/prisma.ts
import { PrismaClient } from '@prisma/client';

// 缓存已创建的Prisma客户端，避免重复实例化
const prismaClientCache = new Map<string, PrismaClient>();

export function getTenantPrisma(tenantId: string): PrismaClient {
  if (prismaClientCache.has(tenantId)) {
    return prismaClientCache.get(tenantId)!;
  }

  // 按规则拼接租户数据库连接字符串（示例规则：saas_${tenantId}）
  const dbConnectionString = `postgresql://${process.env.DB_USER}:${process.env.DB_PASSWORD}@${process.env.DB_HOST}:${process.env.DB_PORT}/saas_${tenantId}?schema=public`;

  const prisma = new PrismaClient({
    datasources: {
      db: { url: dbConnectionString },
    },
    // 可选：配置连接池大小，避免连接数过载
    poolSize: parseInt(process.env.PRISMA_POOL_SIZE || '5'),
  });

  prismaClientCache.set(tenantId, prisma);
  return prisma;
}

3. 在业务代码中使用 #

以NextJS API路由为例：

// app/api/tenant-data/route.ts
import { getTenantPrisma } from '@/lib/prisma';
import { getServerSession } from 'next-auth/next';
import { authOptions } from '@/lib/auth';

export async function GET() {
  const session = await getServerSession(authOptions);
  const tenantId = session?.user?.tenantId;

  if (!tenantId) {
    return new Response('未授权', { status: 401 });
  }

  const prisma = getTenantPrisma(tenantId);
  const data = await prisma.someModel.findMany();
  return Response.json(data);
}

成熟实践要点 #

租户数据库自动化初始化 #

新租户注册时，自动完成数据库创建与Schema初始化：

• 用Node.js的pg模块执行SQL创建数据库：CREATE DATABASE saas_{tenantId};
• 调用Prisma迁移命令：prisma migrate deploy --schema=./prisma/schema.prisma --database-url={连接字符串}，确保所有租户数据库Schema一致。

连接池与资源管控 #

• 调整PostgreSQL的max_connections参数，适配多租户场景下的连接需求
• 在Prisma配置中设置合理的poolSize，避免单个租户占用过多连接
• 定期清理缓存中长时间未使用的Prisma客户端实例，释放内存

安全性强化 #

• 数据库账号仅授予必要权限（如SELECT/INSERT/UPDATE/DELETE），禁止DROP、ALTER等高危操作
• 严格校验tenantId的合法性，比如与用户信息绑定，防止伪造租户标识越权
• 加密数据库连接字符串中的敏感信息（如密码），避免明文存储

运维与监控 #

• 为每个租户数据库单独配置备份策略，确保数据可恢复
• 监控每个数据库的性能指标（CPU、内存、连接数、查询耗时），及时发现异常
• Schema变更时，批量执行迁移脚本，确保所有租户数据库同步更新

注意事项 #

• 开发环境下，Prisma热重载可能因动态切换数据库出现异常，建议固定测试用的租户数据库进行开发
• 当租户数量极大时，需考虑缓存的内存占用，可结合TTL机制自动清理过期客户端实例
• 避免在客户端（Browser Components）直接处理数据库连接，所有数据库操作必须在服务端完成

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