如何将Node.js连接至Rails所用现有PostgreSQL？解决未处理Promise拒绝错误

嘿，我来帮你搞定这个问题！你遇到的「Unhandled promise rejection」通常是因为没正确处理异步操作的错误，而且看起来你可能在混用原生pg客户端和Sequelize——既然已经初始化了Sequelize，咱们直接用它来操作会更顺畅，毕竟它能更好适配现有Rails数据库的结构。

sequelize init已经帮你生成了config/config.json文件，你需要修改这个文件，填入PostgreSQL的正确配置，对应你的Rails数据库：

{
  "development": {
    "username": "你的PostgreSQL用户名",
    "password": "你的数据库密码（如果有的话）",
    "database": "你的Rails数据库名",
    "host": "127.0.0.1",
    "dialect": "postgres",
    "port": 5432 // 非默认端口的话需要补充
  }
}

在models文件夹下新建user.js，对应Rails的users表。要匹配你现有users表的字段，比如常见的id、name、email等：

const { Model, DataTypes } = require('sequelize');
const sequelize = require('../config/database'); // 引入Sequelize实例

class User extends Model {}

User.init({
  id: {
    type: DataTypes.INTEGER,
    primaryKey: true,
    autoIncrement: true,
    allowNull: false
  },
  name: DataTypes.STRING,
  email: {
    type: DataTypes.STRING,
    allowNull: false,
    unique: true
  },
  // 这里添加你users表的其他字段，比如password_digest（如果用了Devise）等
}, {
  sequelize,
  modelName: 'User',
  tableName: 'users', // 明确指定表名，避免Sequelize自动复数化的问题
  timestamps: true, // 匹配Rails默认的created_at/updated_at字段
  underscored: true // 适配Rails的下划线命名规则
});

module.exports = User;

修改你的index.js，用Sequelize连接数据库并查询，同时必须处理异步操作的错误，避免出现未处理的Promise拒绝：

const express = require('express');
const logger = require('morgan');
const bodyParser = require('body-parser');
const sequelize = require('./config/database'); // 引入Sequelize配置
const User = require('./models/user'); // 引入User模型

const app = express();

// 中间件配置
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));

// 查询用户列表的路由
app.get('/users', async (req, res) => {
  try {
    // 先验证数据库连接
    await sequelize.authenticate();
    console.log('数据库连接成功！');
    
    // 查询所有用户
    const users = await User.findAll();
    res.status(200).json(users);
  } catch (error) {
    console.error('数据库操作出错:', error);
    res.status(500).json({ error: '获取用户列表失败' });
  }
});

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`服务器运行在端口 ${PORT}`);
});

• 别混用原生pg和Sequelize：既然已经初始化了Sequelize，就用它的API操作，避免手动管理连接的麻烦。
• 必须处理Promise错误：所有异步操作（比如authenticate()、findAll()）都要用try/catch或者.catch()捕获错误，不然就会触发「Unhandled promise rejection」。
• 匹配Rails的表结构：Rails默认用下划线命名，所以在Sequelize模型里要设置underscored: true，确保字段映射正确。

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