Chunked Transfer Encoding Example

index.js

var mysql = require('mysql');
var express = require('express');

var query_base = 'SELECT * from inspections WHERE FACILITY LIKE \'';

var connection = mysql.createConnection({
  host: process.argv[2],
  user: process.argv[3],
  password: process.argv[4] || '',
  database: 'Onondaga_County_Restaurant_Inspections'
});

connection.connect();
var app = express();
app.listen(4000);

app.get('/:name', function(req, res){

	connection.query(query_base + req.params.name + '%\'', function(err, rows, fields) {
	  if (err) {
	  	res.status(500).json({ error: err.message });
	  }
	  else {
	  	res.set('Content-type: application/json');
	  	res.send(rows);
	  }
	});

});

app.get('/chunked/:name', function(req, res){

	connection.query(query_base + req.params.name + '%\'')
	.on('error', function(err) {
		res.status(500).json({ error: err.message });
	})
	.on('fields', function(fields) {
    	res.set({'Content-type': 'application/json', 'Transfer-encoding': 'chunked'});
    	res.write('[');
	})
	.on('result', function(row) {
		res.write(JSON.stringify(row) + ',');
	})
	.on('end', function() {
		res.end('{"success": true}]');
  	});

});

inspections.sql

DROP DATABASE IF EXISTS Onondaga_County_Restaurant_Inspections;
CREATE DATABASE Onondaga_County_Restaurant_Inspections;
USE Onondaga_County_Restaurant_Inspections;

DROP TABLE IF EXISTS inspections;
CREATE TABLE `inspections` (
	FACILITY VARCHAR(36) NOT NULL, 
	ADDRESS VARCHAR(44) NOT NULL, 
	LAST_INSPECTED DATE NOT NULL, 
	VIOLATIONS VARCHAR(2015) NOT NULL, 
	TOTAL_NUM_CRITICAL_VIOLATIONS INTEGER NOT NULL, 
	TOTAL_NUM_CRIT_NOT_CORRECTED INTEGER NOT NULL, 
	TOTAL_NUM_NONCRITICAL_VIOLATIONS INTEGER NOT NULL, 
	DESCRIPTION VARCHAR(67) NOT NULL, 
	LOCAL_HEALTH_DEPARTMENT VARCHAR(15) NOT NULL, 
	COUNTY VARCHAR(8) NOT NULL, 
	FACILITY_ADDRESS VARCHAR(34) NOT NULL, 
	CITY VARCHAR(17) NOT NULL, 
	ZIP_CODE INTEGER NOT NULL, 
	NYSDOH_GAZETTEER_1980 INTEGER NOT NULL, 
	MUNICIPALITY VARCHAR(15) NOT NULL, 
	OPERATION_NAME VARCHAR(50) NOT NULL, 
	PERMIT_EXPIRATION_DATE DATE,
	PERMITTED_DBA VARCHAR(32),
	PERMITTED_CORP_NAME VARCHAR(50), 
	PERM_OPERATOR_LAST_NAME VARCHAR(30), 
	PERM_OPERATOR_FIRST_NAME VARCHAR(15), 
	NYS_HEALTH_OPERATION_ID INTEGER NOT NULL, 
	INSPECTION_TYPE VARCHAR(13) NOT NULL, 
	INSPECTOR_ID VARCHAR(32), 
	INSPECTION_COMMENTS VARCHAR(1308), 
	FOOD_SERVICE_FACILITY_STATE VARCHAR(2) NOT NULL, 
	Location1 VARCHAR(23) NOT NULL
);

LOAD DATA INFILE '/path/to/Onondaga_County_Restaurant_Inspections_clean.csv' INTO TABLE inspections
	FIELDS TERMINATED BY ','
	ENCLOSED BY '"'
	LINES TERMINATED BY '\n'
	IGNORE 1 LINES
	(FACILITY,ADDRESS,LAST_INSPECTED,VIOLATIONS,TOTAL_NUM_CRITICAL_VIOLATIONS,TOTAL_NUM_CRIT_NOT_CORRECTED,TOTAL_NUM_NONCRITICAL_VIOLATIONS,DESCRIPTION,LOCAL_HEALTH_DEPARTMENT,COUNTY,FACILITY_ADDRESS,CITY,ZIP_CODE,NYSDOH_GAZETTEER_1980,MUNICIPALITY,OPERATION_NAME,PERMIT_EXPIRATION_DATE,PERMITTED_DBA,PERMITTED_CORP_NAME,PERM_OPERATOR_LAST_NAME,PERM_OPERATOR_FIRST_NAME,NYS_HEALTH_OPERATION_ID,INSPECTION_TYPE,INSPECTOR_ID,INSPECTION_COMMENTS,FOOD_SERVICE_FACILITY_STATE,Location1);

Onondaga_County_Restaurant_Inspections_clean.csv