"""switch_delphi_integration_from_views_to_tables

Revision ID: d5671a0effda
Revises: 7289d16beca6
Create Date: 2021-04-14 15:04:43.714315

"""
from alembic import op

from migrations.fixtures.functions.campaign_dsp_id_function import CampaignDspIdFunction
from migrations.fixtures.delphi_tables.v1.tables import DelphiTables
from migrations.fixtures.delphi_tables.views import DelphiViews
from migrations.fixtures.delphi_tables.v1.data_migrator import DataMigrator

# revision identifiers, used by Alembic.
revision = 'd5671a0effda'
down_revision = '7289d16beca6'
branch_labels = None
depends_on = None


def upgrade():
    bind = op.get_bind()
    bind.execute(CampaignDspIdFunction.create_or_replace())

    delphi_views = DelphiViews(bind)
    bind.execute("DROP VIEW IF EXISTS projects_view;")
    bind.execute(delphi_views.projects_view(None))
    bind.execute(delphi_views.project_campaigns_view(None))
    bind.execute(delphi_views.project_artists_view(None))
    bind.execute(delphi_views.phases_view(None))
    bind.execute(delphi_views.phase_campaigns_view(None))

    delphi_tables = DelphiTables(bind)
    data_migrator = DataMigrator(bind)
    delphi_tables.create()
    data_migrator.execute()
    delphi_tables.reindex()

def downgrade():
    bind = op.get_bind()
    delphi_tables = DelphiTables(bind)
    delphi_tables.drop()