diff --git a/gso/migrations/versions/2024-12-04_4cc835c615fc_remove_additional_products.py b/gso/migrations/versions/2024-12-04_4cc835c615fc_remove_additional_products.py new file mode 100644 index 0000000000000000000000000000000000000000..969e1e0fc20d437b400a69ef670c46ad5ed0e059 --- /dev/null +++ b/gso/migrations/versions/2024-12-04_4cc835c615fc_remove_additional_products.py @@ -0,0 +1,33 @@ +"""remove additional products. + +Revision ID: 4cc835c615fc +Revises: 28c1723c6a00 +Create Date: 2024-12-04 14:54:22.167158 + +""" +import sqlalchemy as sa +from alembic import op + +# revision identifiers, used by Alembic. +revision = '4cc835c615fc' +down_revision = '28c1723c6a00' +branch_labels = None +depends_on = None + + +def upgrade() -> None: + conn = op.get_bind() + conn.execute(sa.text(""" +DELETE FROM product_product_blocks WHERE product_product_blocks.product_id IN (SELECT products.product_id FROM products WHERE products.name IN ('IAS', 'Imported IAS', 'Imported GÉANT IP', 'GÉANT IP')) AND product_product_blocks.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NRENL3CoreServiceBlock')) + """)) + conn.execute(sa.text(""" +DELETE FROM subscription_instances WHERE subscription_instances.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NRENAccessPort', 'NRENL3CoreServiceBlock')) + """)) + conn.execute(sa.text(""" +DELETE FROM product_blocks WHERE product_blocks.name IN ('NRENAccessPort', 'NRENL3CoreServiceBlock') + """)) + + +def downgrade() -> None: + conn = op.get_bind() +