knex.js管表示

Question

我在knex.js和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)响应。

以上代码不起作用。

有一个"TypeError"：

TypeError:第一个参数必须是字符串或缓冲区

出什么问题了？

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);
});