独立模式下Waterline执行原生查询的方法求助

我之前也碰到过一模一样的问题！当时折腾了好一阵才搞明白——sendNativeQuery其实是Sails.js的ORM钩子额外给模型和数据存储添加上的方法，独立使用Waterline的时候确实没有这个内置方法。下面是我总结的几个解决办法：

方法一：直接调用底层数据库驱动的原生查询 #

每个Waterline数据存储实例都自带一个driver属性，这就是它对应的底层数据库驱动（比如PostgreSQL的pg、MySQL的mysql2）。你可以直接通过这个驱动执行原生查询，这是最直接的方式：

// 假设你已经完成Waterline初始化，拿到目标数据存储实例
const datastore = Waterline.getDatastore('your-datastore-name');

// 以PostgreSQL为例，使用驱动的query方法（带占位符防止SQL注入）
try {
  const results = await datastore.driver.query('SELECT * FROM users WHERE id = $1', [123]);
  console.log('查询结果:', results.rows); // PostgreSQL的结果集在rows属性中
} catch (err) {
  console.error('查询出错:', err);
}

// 如果是MySQL，占位符用?，结果直接返回数组
try {
  const results = await datastore.driver.query('SELECT * FROM users WHERE id = ?', [123]);
  console.log('查询结果:', results);
} catch (err) {
  console.error('查询出错:', err);
}

方法二：手动封装类似sendNativeQuery的方法 #

如果你习惯Sails里sendNativeQuery的用法，可以自己给Waterline的数据存储实例封装一个同名方法，模仿Sails的返回格式：

// 封装sendNativeQuery方法
async function sendNativeQuery(query, values = []) {
  const datastore = this;
  try {
    const rawResults = await datastore.driver.query(query, values);
    // 统一返回格式，对齐Sails的sendNativeQuery返回结构
    return {
      rows: rawResults.rows || rawResults, // 兼容不同驱动的结果格式
      meta: rawResults.fields || { affectedRows: rawResults.affectedRows } // 附加元数据
    };
  } catch (err) {
    throw new Error(`原生查询失败: ${err.message}`);
  }
}

// 给你的数据存储实例挂载这个方法
const datastore = Waterline.getDatastore('your-datastore-name');
datastore.sendNativeQuery = sendNativeQuery.bind(datastore);

// 之后就可以像在Sails里一样使用了
try {
  const { rows, meta } = await datastore.sendNativeQuery('SELECT COUNT(*) FROM users');
  console.log('用户总数:', rows[0].count);
  console.log('查询元数据:', meta);
} catch (err) {
  console.error(err);
}

注意事项 #

• 不同数据库驱动的原生查询语法有差异：比如占位符格式（PostgreSQL用$n，MySQL用?）、结果集结构都不一样，封装的时候要注意适配。
• 始终使用参数化查询（占位符），避免SQL注入风险，这一点和Sails的sendNativeQuery要求一致。

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