const Connection = require('./connection.json');
var Moment = require('moment');
var mysql = require("mysql");
var fs = require('fs');
var csv = require('csv');
// var Papa = require('babyparse');

var con = mysql.createPool({
  connectionLimit : 10,
  host: Connection.host_name,
  user: Connection.username,
  password: Connection.password,
  port: Connection.portnum,
  database: Connection.database
});

var q ="SELECT * FROM `dsss` ORDER BY `dad` DESC;"
var readOpts = {highWaterMark: Math.pow(2,16)};

con.query(q)
  .stream(readOpts)

  .pipe(csv.stringify ())
  // .pipe(process.stdout)
  // .on('data', function(data) {
  //  })
  .pipe(fs.createWriteStream('xiee.txt',readOpts));