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

def esc_name(db, name):

    if module == 'psycopg2': return name

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

    elif module == 'MySQLdb': quote = '`'

    else: raise NotImplementedError("Can't escape name for "+module+' database')

    return quote + name.replace(quote, '') + quote

##### Querying

def run_raw_query(db, query, params=None):

    try: cur.execute(query, params)

    except Exception, e:

        _add_cursor_info(e, cur)

    return run_query(db, query, row.values(), recover)

def last_insert_id(db):

    if module == 'psycopg2': return value(run_query(db, 'SELECT lastval()'))

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

    else: return None

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

    check_name(table)

    check_name(index)

    if module == 'psycopg2':

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

SELECT attname

def constraint_cols(db, table, constraint):

    check_name(table)

    check_name(constraint)

    if module == 'psycopg2':

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

SELECT attname

        ' database')

def tables(db):

    if module == 'psycopg2':

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

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

    for orig, new in mappings.iteritems():

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

        except KeyError: pass

    if serializable:

        run_raw_query(db, 'SET TRANSACTION ISOLATION LEVEL SERIALIZABLE')

    return db

                limit=end, start=0)

            row_ct = map_table(list(sql.col_names(cur)), sql.rows(cur))

        elif in_is_xml:

            def get_rows(doc2rows):

                return iters.flatten(itertools.imap(doc2rows,

                        sql.with_savepoint(out_db,

                            lambda: db_xml.put(out_db, root.firstChild,

                                out_pkeys, row_ins_ct_ref, on_error))

                    except sql.DatabaseErrors, e: on_error(e)

                prep_root()

            sys.stdout.write('Inserted '+str(row_ins_ct_ref[0])+

                ' new rows into database\n')

        finally:

    else:

        def on_error(e): ex_tracker.track(e)

        def row_ready(row_num, input_row): pass