 
         @pool.acquire (err, connection)=>
             return callback err if err
+            logger.debug @pool.options.name, 'acquired'
             @_addSavePoint connection
             @acquireTimeout = setTimeout =>
                 @_takeResource STATES.FORCE_RELEASE,

    QUERY: 6
    FORCE_RELEASE: 6

MAX_ACQUIRE_TIME = 5 * 60 * 1000

module.exports = class Connector extends EventEmitter
    STATES: STATES

        @_connection.query query, (err, res)=>
            return callback err if err
            @_addSavePoint()
            logger.debug @pool.options.name, 'begun'
            callback null
            return
        return

    rollback: (callback, all = false)->
        logger.debug @pool.options.name, 'rollback'
        
        ret = =>
            @_giveResource()
            logger.debug @pool.options.name, 'rollbacked'
            callback.apply null, arguments if typeof callback is 'function'
            return
        @_takeResource STATES.ROLLBACK, (err)=>
