"""connectors_triggers_migrate

Revision ID: d407ce8193ec
Revises: aa73d2c4378d
Create Date: 2023-05-17 09:07:44.377476

"""
from alembic import op
import sqlalchemy as sa
from sqlalchemy.dialects import postgresql

from migrations.fixtures.delphi_tables.views import DelphiViewsV8
from migrations.fixtures.delphi_tables.v9.data_refresher import DelphiTablesDataRefresher as DelphiTablesDataRefresherV9
from migrations.fixtures.delphi_tables.v8.data_refresher import DelphiTablesDataRefresher as DelphiTablesDataRefresherV8

# revision identifiers, used by Alembic.
revision = 'd407ce8193ec'
down_revision = 'aa73d2c4378d'
branch_labels = None
depends_on = None


def upgrade():
    bind = op.get_bind()
    delphi_views = DelphiViewsV8(bind)
    delphi_views.drop()

    delphi_refresherv8 = DelphiTablesDataRefresherV8()
    delphi_refresherv8.drop_triggers(bind)

    delphi_refresher = DelphiTablesDataRefresherV9()

    delphi_refresher.refresh(bind)


def downgrade():
    pass