const sql = require('mssql')

const config = {
    user: 'steemit',
    password: 'steemit',
    server: 'sql.steemsql.com',
    database: 'DBSteem',
    pool: {
        max: 10,
        min: 0,
        idleTimeoutMillis: 30000
    }
}

sql.connect(config, err => {
    const request = new sql.Request()
    request.stream = true
    request.query("SELECT title, author, body FROM Comments WHERE ISJSON(json_metadata) > 0 AND JSON_VALUE(json_metadata,'$.tags') = 'steem'")

    request.on('recordset', columns => {
        console.log(columns);
        // Emitted once for each recordset in a query
    })

    request.on('row', row => {
        console.log(row);
        // Emitted for each row in a recordset
    })

    request.on('error', err => {
        console.log(err);
        // May be emitted multiple times
    })

    request.on('done', result => {
        console.log(result);
        // Always emitted as the last one
    })
})

sql.on('error', err => {
        console.log(err);
    // ... error handler
})