var Connection = require('tedious').Connection;
var Request = require('tedious').Request;

var config = {
    userName: 'XXX',
    password: 'XXXX',
    server: 'XXXX.eu-west-1.rds.amazonaws.com',
    database: 'XXX'
};

exports.handler = (event, context, callback) => {
    // TODO implement

    var connection = new Connection(config);

    connection.on('connect', function(err) {
            // If no error, then good to go...
            console.log('COnnected');
            executeStatement();
        }
    );
    connection.on('debug', function(err) {
        console.log('debug:', err);
    });

    function executeStatement() {
        request = new Request("select 42, 'hello world'", function(err, rowCount) {
            if (err) {
                console.log(err);
            } else {
                console.log(rowCount + ' rows');
            }
        });

        request.on('row', function(columns) {
            columns.forEach(function(column) {
                console.log(column.value);
            });
        });

        request.on('done', function (rowCount, more, rows) {
            callback(null, "done");
        });

        connection.execSql(request);
    }


};