const { stream } = require('@apartum/mysql-wrapper')(require('./config'))
const writeStream = require('fs').createWriteStream('./src/hola.txt')
const Transform = require('stream').Transform
const transformStream = new Transform({
  objectMode: true,
  highWatermark: 1,
  transform (chunk, encoding, done) {
    chunk.es = 'ASDASDASD'
    // this.push(JSON.stringify(chunk))
    done(null, JSON.stringify(chunk))
  }
})

async function start () {
  stream('SELECT * FROM countries')
    .pipe(transformStream)
    .pipe(writeStream)
}

start()