Using knex.js to pipe data to an express server

Question

Using knex.js to pipe data to an express server

I'm encountering an issue with knex.js and express. Here is the code snippet in question:

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

According to the knex.js documentation, there is a stream interface for knex.js query.

However, I am unable to pipe the result to the express(node http api) response.

The code mentioned above is not functioning correctly.

An error message "TypeError" is being displayed:

TypeError: first argument must be a string or Buffer

What could have caused this issue?

javascript express knex.js

Answer 1

Answer №1

To begin, establish a stream and direct it through JSONStream before connecting it to your response object.

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

Answer 2

To begin, establish a stream and direct it through JSONStream before connecting it to your response object.

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

Using knex.js to pipe data to an express server

Answer №1

Similar questions

Compatibility issues with jQuery observed in Firefox and Internet Explorer 11

Encountering numerous errors when attempting to incorporate lottie-web into my JavaScript file

A distinct handler function designed for a dynamically generated form

What is the solution for the error "Firebase limitToLast is undefined"?

AngularJS single page applications experiencing issues with loading scripts and stylesheets upon page reload

What is causing my ReactJS web application to not recognize the cookies being sent by the backend server?

Guide on incorporating a Virtual field post querying a different Model

PHP Temp File Not Found After AJAX File Upload

This API is no longer compatible with India's payment system, so you won't be able to process payments using Next.js, Strapi, or

A guide on identifying the data type of a value entered into an HTML table using JavaScript

This code snippet, document.location.search.replace('?redirect=', '').replace('%2F', ''), is failing to execute properly in Firefox

Angular 1 and Javascript offer a different approach than using lodash omit and the delete operator

Substituting text in a document by utilizing two separate arrays: one holding the original text to be found and another storing the corresponding text for

Angular JS failing to display error messages

Tips for attaching inline styles to the body element with a vuejs component

"Utilizing JQuery to enhance task management by implementing a delete function

Displaying local time alongside global time using PHP

What specific design scheme is employed in the MEANJS project?

Utilize Knex, Express, and NodeJS to enable users to log in and register

JavaScript prototypal inheritance concept