from functools import partial

from yams.constraints import UniqueConstraint

from cubicweb.schema import PURE_VIRTUAL_RTYPES

from cubicweb.server.schema2sql import build_index_name, check_constraint

sql = partial(sql, ask_confirm=False)

source = repo.system_source

for rschema in schema.relations():

    if rschema.rule or rschema in PURE_VIRTUAL_RTYPES:

        continue

    if rschema.final or rschema.inlined:

        for rdef in rschema.rdefs.values():

            table = 'cw_{0}'.format(rdef.subject)

            column = 'cw_{0}'.format(rdef.rtype)

            if any(isinstance(cstr, UniqueConstraint) for cstr in rdef.constraints):

                old_name = '%s_%s_key' % (table.lower(), column.lower())

                sql('ALTER TABLE %s DROP CONSTRAINT %s' % (table, old_name))

                source.create_index(cnx, table, column, unique=True)

            if rschema.inlined or rdef.indexed:

                old_name = '%s_%s_idx' % (table.lower(), column.lower())

                sql('DROP INDEX IF EXISTS %s' % old_name)

                source.create_index(cnx, table, column)

    else:

        table = '{0}_relation'.format(rschema)

        sql('ALTER TABLE %s DROP CONSTRAINT IF EXISTS %s_p_key' % (table, table))

        sql('ALTER TABLE %s ADD CONSTRAINT %s PRIMARY KEY(eid_from, eid_to)'

            % (table, build_index_name(table, ['eid_from', 'eid_to'], 'key_')))

        for column in ('from', 'to'):

            sql('DROP INDEX IF EXISTS %s_%s_idx' % (table, column))

            sql('CREATE INDEX %s ON %s(eid_%s);'

                % (build_index_name(table, ['eid_' + column], 'idx_'), table, column))