Sails.js流sql查詢

Question

有沒有一種方法可以在流中從Model.query()流數據？

例

export: (req, res) => { 
    let sql = "SELECT ..."; 

    let stream = Model.query(sql).stream(); // I know this does not work 

    stream.pipe(...); 
} 

Answer 1

是。根據帆doc：

module.exports = { 

    testStream: function(req, res){ 

    if (req.param('startStream') && req.isSocket){ 

     var getSocket = req.socket; 

     // Start the stream. Pipe it to sockets. 
     User.stream({name:'Walter'}).pipe(getSocket.emit); 

    } else { 

     res.view(); 

    } 


    } 
}