Produits Entr'ouvert » w.c.s.

    return get_publisher().pgconn

def cleanup_connection():

    if hasattr(get_publisher(), 'pgconn') and get_publisher().pgconn is not None:

        get_publisher().pgconn.close()

@guard_postgres

def do_formdef_tables(formdef, conn=None, cur=None, rebuild_views=False, rebuild_global_views=True):

    if formdef.id is None:

        return []

def do_formdef_indexes(formdef, created, conn, cur, concurrently=False):

    table_name = get_formdef_table_name(formdef)

    evolutions_table_name = table_name + '_evolutions'

    existing_indexes = set()

@guard_postgres

def do_user_table():

    conn, cur = get_connection_and_cursor()

    table_name = 'users'

def do_role_table(concurrently=False):

    conn, cur = get_connection_and_cursor()

    table_name = 'roles'

def do_tracking_code_table():

    conn, cur = get_connection_and_cursor()

    table_name = 'tracking_codes'

def do_session_table():

    conn, cur = get_connection_and_cursor()

    table_name = 'sessions'

def do_custom_views_table():

    conn, cur = get_connection_and_cursor()

    table_name = 'custom_views'

def do_snapshots_table():

    conn, cur = get_connection_and_cursor()

    table_name = 'snapshots'

def do_loggederrors_table(concurrently=False):

    conn, cur = get_connection_and_cursor()

    table_name = 'loggederrors'

@guard_postgres

def do_views(formdef, conn, cur, rebuild_global_views=True):

    # create new view

    table_name = get_formdef_table_name(formdef)

    view_name = get_formdef_view_name(formdef)

def do_global_views(conn, cur):

    # recreate global views

    from wcs.formdef import FormDef

@guard_postgres

def migrate():

    conn, cur = get_connection_and_cursor()

    sql_level = get_sql_level(conn, cur)

    if sql_level < 0: