knex.js 管道来表达

Question

我在knex.jsand 中有问题express，代码如下：

userRouter.get('/:userId', function (req, res) {
  DB('users').where({
    id: req.params.userId
  }).first('name').pipe(res);
});

正如knex.js文档所写： knex.js 查询有一个流接口。

但我无法将结果通过管道进行express(node http api)响应。

上面的代码不起作用。

有一个“类型错误”：

类型错误：第一个参数必须是字符串或缓冲区

什么地方出了错？

Answer 1

创建一个流并将其首先通过管道传输到 JSONStream，最后通过管道传输到您的响应对象

var knex = require('knex')({
  client: 'mysql',
  connection: {
    host     : '...',
    user     : '...',
    password : '...',
    database : '...'
  }
});
var JSONStream = require('JSONStream');
var express = require('express');
var app = express();

app.get('/', function (req, res) {
    var sql = knex.select('*').from('table').limit(3);
    res.set('Content-Type', 'application/json');
    sql.stream().pipe(JSONStream.stringify()).pipe(res);
});

var server = app.listen(3000, function () {
  var host = server.address().address;
  var port = server.address().port;

  console.log('Example app listening at http://%s:%s', host, port);
});