Node.js应用中PrismaClient的模块化管理与多文件访问最佳实践

// index.ts (尝试导出prisma)
import express from "express";
import { PrismaClient } from '@prisma/client';
import userRoutes from "./routes/users"; // userRoutes可能依赖controllers/users
// ...
export const prisma = new PrismaClient(); // 在index.ts中初始化并导出

// controllers/users.ts (尝试从index.ts导入prisma)
// import { prisma } from '../index'; // 这可能导致循环依赖
// ...

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

// 声明一个全局变量，以避免在开发环境中热重载时创建多个PrismaClient实例
// 这种模式在Next.js等框架中常见，可以确保PrismaClient是单例的。
// 注意：在生产环境中，每次应用启动只会创建一个实例，无需担心HMR。
declare global {
  // eslint-disable-next-line no-var
  var prisma: PrismaClient | undefined;
}

const prisma = global.prisma || new PrismaClient();

if (process.env.NODE_ENV === 'development') {
  global.prisma = prisma;
}

export default prisma;

// index.ts
import express from "express";
import userRoutes from "./routes/users";
// import prisma from "./lib/prisma"; // 如果index.ts需要直接访问prisma，则导入

const app = express();
app.use(express.json()); // 添加body解析中间件

app.get("/", (req, res) => {
    res.send("helloBAA");
});

// routes
app.use('/api/users', userRoutes);

app.listen(3500, () => {
    console.log("listening on port 3500");
});

// 可选：在应用程序关闭时断开Prisma连接
process.on('beforeExit', async () => {
  // 如果需要，可以在这里执行清理操作
  // 例如：await prisma.$disconnect();
});

// routes/users.ts (无需修改，因为它只负责路由定义和控制器导入)
import { Router } from 'express';
import { createUser, getUsers, getUser } from '../controllers/users';
const router = Router();

// whole route: /api/users...
router.post('/create', createUser);
router.get('/all', getUsers);
router.get('/:userId', getUser);

export default router;

// controllers/users.ts
import { RequestHandler } from 'express';
import prisma from '../lib/prisma'; // 从独立的PrismaClient模块导入

export const createUser: RequestHandler = async (req, res, next) => {
  const { username, email, password } = req.body; // 假设请求体包含这些字段
  try {
    // 在实际应用中，密码应该被哈希处理
    const user = await prisma.user.create({
      data: {
        username,
        email,
        password, // 警告：请勿在生产环境中明文存储密码
      },
    });
    res.status(201).json({ message: 'User created successfully', user });
  } catch (error) {
    console.error('Error creating user:', error);
    res.status(500).json({ message: 'Failed to create user' });
  }
};

export const getUsers: RequestHandler = async (req, res, next) => {
  try {
    const users = await prisma.user.findMany();
    res.status(200).json(users);
  } catch (error) {
    console.error('Error fetching users:', error);
    res.status(500).json({ message: 'Failed to retrieve users' });
  }
};

export const getUser: RequestHandler = async (req, res, next) => {
  const { userId } = req.params;
  try {
    const user = await prisma.user.findUnique({
      where: { id: parseInt(userId) }, // 假设ID是整数
    });
    if (!user) {
      return res.status(404).json({ message: 'User not found' });
    }
    res.status(200).json(user);
  } catch (error) {
    console.error('Error fetching user:', error);
    res.status(500).json({ message: 'Failed to retrieve user' });
  }
};