// require dependences
var DBH = require('dbh-pg'),
    Promise = require('bluebird'),
    using = Promise.using
    
// instantiate the database
var db = new DBH('postgres://postgres@localhost/db2test')
 
using(db.conn(), function (conn) {
    // a connection from the pool
    return conn
    .fetchOne('select * from user where id=$1', [10])
    .then(function (user) {
        console.log(user) // {id:10, name:...}
    })
}) // automatic release the connection to pool

// send 10 coins from user_id=3 to user_id=4
using(db.conn(), function (conn) {
    return conn
    .begin() // start transaction
    .then(function () {
        // 'this' points to the created connection 'conn'
        return this.exec(
            'update wallet \
            set coins = coins - 10 \
            where user_id=$1',
            [3]
        );
    }).then(function () {
        return this.exec(
            'update wallet \
            set coins = coins + 10 \
            where user_id=$1',
            [4]
        );
    }).then(function () {
        // commit the transaction!
        return this.commit();
    });
});

// print array of data (from query) and the total items in the table
using(db.conn(), db.conn(), function (conn1, conn2) {
    return Promise.join(
        conn1.fetchAll('select * from user limit 10'),
        conn2.fetchOne('select count(*) from user')
    )
    .then(function (items, total) {
        console.log(items, total) // array of objects, number
    })
})

// shorthands are static methods in the DBH 'class'.
// This is the same example used in Transaction
using(db.conn(), function (conn) {
    conn
    .begin()
    .then(DBH.exec(
        'update wallet \
        set coins = coins - 10 \
        where user_id=$1',
        [3]
    )).then(DBH.exec(
        'update wallet \
        set coins = coins + 10 \
        where user_id=$1',
        [4]
    )).then(DBH.commit())
})

// This is the first example, note that
// instead of $1 this uses $id
using(db.conn(), function (conn) {
    return conn
    .fetchOne('select * from user where id=$id', { id : 10 })
    .then(function (user) {
        console.log(user)
    })
})

// DBH.prepare receives a SQL statement and return function that receives the
// replacement as an array of params.
// Note that DBH.prepare can be used outside the 'using'.
var prepared = DBH.prepare('insert into country_code values($1)')
 
using(db.conn(), function (conn) {
    var me = this;
    var promises = ['ar', 'cl', 'jp', 'pe', 'co'].map(function (code) {
        return me.exec(prepared(code))
    })
    return Promise.all(promises)
})