Sequelize.js 查询通过关系获取总计数

Sequelize.js query to get total count through relationship

我正在使用 sequelize 通过关系获取总计数。我需要它的父 table 中的 customerId 通过枢轴 table 连接。普通查询看起来像这样:

SELECT count(p.*) FROM parcels as p
LEFT JOIN orders_parcels as op ON op."parcelId" = p.id
LEFT JOIN orders as o ON op."orderId" = o.id
WHERE o."customerId"=1

这很好用。但不确定如何获取 sequelize 查询。

Parcel.findAndCountAll();

编辑:订单包裹

var OrderParcel = service.sequelize.define('OrderParcel', {

    id: {
        type: Sequelize.INTEGER,
        primaryKey: true,
        autoIncrement: true
    }
}, {
    tableName: 'orders_parcels',
    freezeTableName: true,
    paranoid: true
});

module.exports = OrderParcel;

var Order = require('./Order');

OrderParcel.belongsTo(Order, {
    as: 'Order',
    foreignKey: 'orderId'
});

var Parcel = require('../parcel/Parcel');

OrderParcel.belongsTo(Parcel, {
    as: 'Parcel',
    foreignKey: 'parcelId'
});

一种方法是使用 sequelize.query:

As there are often use cases in which it is just easier to execute raw / already prepared SQL queries, you can utilize the function sequelize.query.

var query = "SELECT count(p.*) FROM parcels as p" +
" LEFT JOIN orders_parcels as op ON op."parcelId" = p.id" +
" LEFT JOIN orders as o ON op."orderId" = o.id" +
" WHERE o.customerId=1;";

sequelize.query(query, { type: sequelize.QueryTypes.SELECT}).success(function(count){
    console.log(count); // It's show the result of query          
    res.end();
}).catch(function(error){            
    res.send('server-error', {error: error});
});

Raw Queries docs

假设您已经定义了关联,您可以使用 Model.findAndCountAll。它看起来像这样:

Parcel.findAndCountAll({
  include: [{
    model: OrderParcel,
    required: true,
    include: [{
      model: Order,
      where: {
        customerId: idNum
      }
    }]
  }]
}).then(function(result) { 

});

我完全同意 方法,但必须简化代码才能正常工作:

Parcel.findAndCountAll({
include: [{
  model: Order,
  where: {
    customerId: idNum
  },
  duplicating: false // Add this line for retrieving all objects
}]
}).then(function(result) { 
   console.log('Rows: ' + result.rows + ' Count: ' + result.count)
});

记得用 belongsToMany 方法连接你的模型!