如何在Node Knexjs MVC架构中移除回调获取模型数据？

核心修改思路 #

Knex.js本身原生支持Promise API，完全可以抛弃回调写法，改用Promise + async/await实现类同步的代码风格，既避免回调嵌套，又能让控制器直接接收模型返回的数据。

代码改造示例 #

1. 原回调式模型（问题代码）

// models/User.js
const knex = require('../knex');

const Users = {
  getAll(callback) {
    knex('users')
      .select('*')
      .then(users => callback(null, users))
      .catch(err => callback(err));
  }
};

module.exports = Users;

2. 修改后的Promise风格模型

直接返回Knex查询对象（Knex查询本身就是Promise实例），无需额外封装：

// models/User.js
const knex = require('../knex');

const Users = {
  getAll() {
    // Knex查询返回Promise，直接return即可
    return knex('users').select('*');
  },
  // 扩展示例：根据ID获取单个用户
  getById(id) {
    return knex('users').where('id', id).first();
  }
};

module.exports = Users;

3. 控制器改造（使用async/await）

将控制器方法声明为async，用await直接接收模型返回的数据：

// controllers/UserController.js
const Users = require('../models/User');

const UserController = {
  async getAllUsers(req, res) {
    try {
      // 类同步风格接收数据
      const users = await Users.getAll();
      res.status(200).json(users);
    } catch (err) {
      res.status(500).json({ error: err.message });
    }
  },
  async getUserById(req, res) {
    try {
      const user = await Users.getById(req.params.id);
      if (!user) {
        return res.status(404).json({ error: '用户不存在' });
      }
      res.status(200).json(user);
    } catch (err) {
      res.status(500).json({ error: err.message });
    }
  }
};

module.exports = UserController;

4. 路由配置

路由无需特殊修改，直接绑定控制器的async方法即可（Express等框架会自动处理async函数的Promise）：

// routes/users.js
const express = require('express');
const router = express.Router();
const UserController = require('../controllers/UserController');

router.get('/', UserController.getAllUsers);
router.get('/:id', UserController.getUserById);

module.exports = router;

整体结构优化建议 #

1. 模型层职责单一：只封装纯数据库查询逻辑，不要处理HTTP请求/响应、状态码等，确保模型可在多个控制器中复用。
2. 统一错误处理：添加全局错误处理中间件，避免每个控制器重复编写try/catch：

// middleware/errorHandler.js
module.exports = (err, req, res, next) => {
  console.error(err.stack);
  res.status(err.statusCode || 500).json({
    error: process.env.NODE_ENV === 'production' ? '服务器内部错误' : err.message
  });
};

在主文件中注册中间件：

const errorHandler = require('./middleware/errorHandler');
app.use(errorHandler);

3. 数据验证前置：在控制器或单独的验证层（如用Joi、Zod）对请求参数、body做校验，避免无效请求进入模型层。
4. Knex配置分离：将数据库配置单独放在knexfile.js中，通过环境变量区分开发/生产环境，避免硬编码敏感信息。
5. 模型分层细化：业务复杂时，拆分出数据访问层（DAO）和业务逻辑层：DAO只做数据库操作，业务逻辑层处理业务规则，控制器调用业务逻辑层而非直接调用DAO。

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