4

と、以下のようなコードに問題が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: 最初の引数は文字列またはバッファでなければなりません

何が悪かったのか？

4

1 に答える 1

5

ストリームを作成し、最初に 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);
});
于 2015-12-30T13:15:26.013 に答える