# Database access

import sys

    if hasattr(cur, 'query'): return cur.query

    elif hasattr(cur, '_last_executed'): return cur._last_executed

    else: return None

    def __init__(self, cols, cause=None):

        DbException.__init__(self, 'columns: ' + ', '.join(cols), cause)

        self.cols = cols

class DbWarning(UserWarning): pass

    if re.search(r'\W', name) != None: raise NameException('Name "'+name

        +'" may contain only alphanumeric characters and _')

        # Don't enclose in quotes because this disables case-insensitivity

    'MySQL': ('MySQLdb', {'password': 'passwd', 'database': 'db'}),

    'PostgreSQL': ('psycopg2', {}),

}

DatabaseErrors_set = set([DbException])

DatabaseErrors = tuple(DatabaseErrors_set)

def _add_module(module):

    DatabaseErrors_set.add(module.DatabaseError)

    global DatabaseErrors

    DatabaseErrors = tuple(DatabaseErrors_set)

def db_config_str(db_config):

    return db_config['engine']+' database '+db_config['database']

        self.serializable = serializable

        self.__db = None

        self.index_cols = {}

    def __getattr__(self, name):

        if name == '__dict__': raise Exception('getting __dict__')

        if name == 'db': return self._db()

        else: raise AttributeError()

    def __getstate__(self):

        state = copy.copy(self.__dict__) # shallow copy

        state['_DbConn__db'] = None # don't pickle the connection

        return state

    def _db(self):

        if self.__db == None:

            # Process db_config

            db_config = self.db_config.copy() # don't modify input!

            module_name, mappings = db_engines[db_config.pop('engine')]

            module = __import__(module_name)

            _add_module(module)

            for orig, new in mappings.iteritems():

                try: util.rename_key(db_config, orig, new)

                except KeyError: pass

            # Connect

            self.__db = module.connect(**db_config)

            # Configure connection

            if self.serializable: run_raw_query(self,

                'SET TRANSACTION ISOLATION LEVEL SERIALIZABLE')

        return self.__db

        def __init__(self, outer):

            Proxy.__init__(self, outer.db.cursor())

            self.outer = outer

            self.result = []

            row = self.inner.fetchone()

            if row == None: # fetched all rows

                self.outer.query_results[self.inner.query] = self.result

            else: self.result.append(row)

            return row

        def __init__(self, result): self.iter = iter(result)

        def fetchone(self):

            try: return self.iter.next()

            except StopIteration: return None

        query = cur.mogrify(query, params)

        try: return self.CacheCursor(self.query_results[query])

        except KeyError:

            try: cur.execute(query)

            except Exception, e:

                _add_cursor_info(e, cur)

                raise

            if self.debug:

                sys.stderr.write(strings.one_line(get_cur_query(cur))+'\n')

            return cur

    except:

    else:

    if recover == None: recover = False

    def run(): return run_raw_query(db, query, params)

    if recover: return with_savepoint(db, run)

    else: return run()

def rows(cur): return iter(lambda: cur.fetchone(), None)

def row(cur): return rows(cur).next()

def value(cur): return row(cur)[0]

def values(cur): return iter(lambda: value(cur), None)

def value_or_none(cur):

    try: return value(cur)

    except StopIteration: return None

##### Basic queries

    recover=None):

    '''@param fields Use None to select all fields in the table'''

    if conds == None: conds = {}

        else: cond_ += '='

        cond_ += ' %s'

        return cond_

    if fields == None: query += '*'

    else: query += ', '.join([esc_name(db, field) for field in fields])

    query += ' FROM '+esc_name(db, table)

    missing = True

        query += ' WHERE '+' AND '.join(map(cond, conds.iteritems()))

    if limit != None: query += ' LIMIT '+str(limit); missing = False

    if start != None:

        if start != 0: query += ' OFFSET '+str(start)

        missing = False

    if missing: warnings.warn(DbWarning(

        'SELECT statement missing a WHERE, LIMIT, or OFFSET clause: '+query))

    '''@param returning str|None An inserted column (such as pkey) to return'''

        +', '.join(['%s']*len(cols))+')'

    else: query += ' DEFAULT VALUES'

    if returning != None:

        check_name(returning)

        query += ' RETURNING '+returning

    elif module == 'MySQLdb': return db.insert_id()

    else: return None

    check_name(table)

##### Database structure queries

    check_name(table)

        db.pkeys[table] = col_names(run_query(db,

    '''Can also use this for UNIQUE constraints, because a UNIQUE index is

    automatically created. When you don't know whether something is a UNIQUE

    constraint or a UNIQUE index, use this function.'''

    check_name(table)

    check_name(index)

    if lookup not in db.index_cols:

        module = util.root_module(db.db)

        if module == 'psycopg2':

            db.index_cols[lookup] = list(values(run_query(db, '''\

(

        SELECT attnum, attname

        FROM pg_index

        JOIN pg_class index ON index.oid = indexrelid

        JOIN pg_class table_ ON table_.oid = indrelid

        JOIN pg_attribute ON attrelid = indrelid AND attnum = ANY (indkey)

        WHERE

            table_.relname = %(table)s

            AND index.relname = %(index)s

    UNION

        SELECT attnum, attname

        FROM

        (

            SELECT

                indrelid

                , (regexp_matches(indexprs, E':varattno (\\\\d+)', 'g'))[1]::int

                    AS indkey

            FROM pg_index

            JOIN pg_class index ON index.oid = indexrelid

            JOIN pg_class table_ ON table_.oid = indrelid

            WHERE

                table_.relname = %(table)s

                AND index.relname = %(index)s

        ) s

        JOIN pg_attribute ON attrelid = indrelid AND attnum = indkey

) s

''',

        else: raise NotImplementedError("Can't list index columns for "+module+

            ' database')

    return db.index_cols[lookup]

    check_name(table)

    check_name(constraint)

        return list(values(run_query(db, '''\

SELECT attname

FROM pg_constraint

JOIN pg_class ON pg_class.oid = conrelid

JOIN pg_attribute ON attrelid = conrelid AND attnum = ANY (conkey)

WHERE

    relname = %(table)s

    AND conname = %(constraint)s

ORDER BY attnum

''',

            {'table': table, 'constraint': constraint})))

    else: raise NotImplementedError("Can't list constraint columns for "+module+

        ' database')

        return values(run_query(db, "SELECT tablename from pg_tables "

            "WHERE schemaname = 'public' ORDER BY tablename"))

    elif module == 'MySQLdb': return values(run_query(db, 'SHOW TABLES'))

    else: raise NotImplementedError("Can't list tables for "+module+' database')

def empty_db(db):

    for table in tables(db): truncate(db, table)

        msg = str(e)

            r'"(([^\W_]+)_[^"]+)"', msg)

        if match:

            constraint, table = match.groups()

            'constraint', msg)

    Only works under PostgreSQL (uses `INSERT ... RETURNING`)'''

        if row_ct_ref != None and cur.rowcount >= 0:

            row_ct_ref[0] += cur.rowcount

        return value(cur)

            util.dict_subset_right_join(row, e.cols), recover=True))

    try: return value(select(db, table, [pkey], row, 1, recover=True))