         @_debug = opts.debug
         @_timeout_ms = opts.timeout_ms
         @_ensure_exists = opts.ensure_exists
+        @_init_test_query()
         dbg = @_dbg("constructor")  # must be after setting @_debug above
         dbg(opts)
         i = opts.host.indexOf(':')

            @_client.removeAllListeners()
            @_client.end()
            delete @_client

    engine: -> 'postgresql'


    close: =>
        if @_state == 'closed'
            return  # nothing to do
        @_close_test_query()
        @_state = 'closed'
        @emit('close')
        @removeAllListeners()
