def METHOD_NAME(self):
    conn = apsw.Connection(self.database, **self.connect_params)
    if self._timeout is not None:
        conn.setbusytimeout(self._timeout * 1000)
    try:
        self._add_conn_hooks(conn)
    except:
        conn.close()
        raise
    return conn