Skip to content
Snippets Groups Projects
Commit f67e62d8 authored by JORGE SASIAIN's avatar JORGE SASIAIN
Browse files

attempt to fix db

parent 3d3e17a9
Branches
Tags
No related merge requests found
"""add workflows.
Revision ID: 69a2eb84aae4
Revises: b815abc87ce9
Create Date: 2023-01-16 08:33:12.302351
Revision ID: 84775104d8b7
Revises: fd8a080b155f
Create Date: 2023-01-16 11:53:24.323119
"""
import sqlalchemy as sa
......@@ -11,8 +11,8 @@ from orchestrator.migrations.helpers import create_workflow, delete_workflow
from orchestrator.targets import Target
# revision identifiers, used by Alembic.
revision = '69a2eb84aae4'
down_revision = 'b815abc87ce9'
revision = '84775104d8b7'
down_revision = 'fd8a080b155f'
branch_labels = None
depends_on = None
......@@ -86,3 +86,4 @@ def downgrade() -> None:
conn = op.get_bind()
for workflow in new_workflows:
delete_workflow(conn, workflow["name"])
"""Add Node, LineCard, and Port products.
Revision ID: b815abc87ce9
Revision ID: fd8a080b155f
Revises:
Create Date: 2023-01-12 12:35:30.770774
Create Date: 2023-01-16 11:51:13.092461
"""
import sqlalchemy as sa
from alembic import op
# revision identifiers, used by Alembic.
revision = 'b815abc87ce9'
revision = 'fd8a080b155f'
down_revision = None
branch_labels = ('data',)
depends_on = 'bed6bc0b197a'
......@@ -18,22 +18,22 @@ depends_on = 'bed6bc0b197a'
def upgrade() -> None:
conn = op.get_bind()
conn.execute("""
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Node 62.40.96.28', 'Juniper router mx1.lab', 'Node', 'NODE_MX1_LAB', 'active') RETURNING products.product_id
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Node 62.40.96.28', 'Juniper router mx2.lab', 'Node', 'NODE_MX2_LAB', 'active') RETURNING products.product_id
""")
conn.execute("""
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Line card CASJ9993', 'Line card in mx1.lab', 'LineCard', 'LINE_CARD_CASJ9993', 'active') RETURNING products.product_id
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Line card CASJ9993', 'Line card in mx2-.lab', 'LineCard', 'LINE_CARD_CASJ9993', 'active') RETURNING products.product_id
""")
conn.execute("""
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Line card CARK6375', 'Line card in mx1.lab', 'LineCard', 'LINE_CARD_CARK6375', 'active') RETURNING products.product_id
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Line card CARK6375', 'Line card in mx2.lab', 'LineCard', 'LINE_CARD_CARK6375', 'active') RETURNING products.product_id
""")
conn.execute("""
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 40GE', 'Port speed capability 40GE+', 'Port', 'PORT_40GE', 'active') RETURNING products.product_id
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 40GE', 'Port speed capability 40GE', 'Port', 'PORT_40GE', 'active') RETURNING products.product_id
""")
conn.execute("""
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 4x10GE', 'Port speed capability 4x10GE', 'Port', 'PORT_4x10GE', 'active') RETURNING products.product_id
""")
conn.execute("""
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 100GE', 'Port speed capability 100GE', 'Port', 'PORT_10GE0GE', 'active') RETURNING products.product_id
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 100GE', 'Port speed capability 100GE', 'Port', 'PORT_100GE', 'active') RETURNING products.product_id
""")
conn.execute("""
INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 4x25GE', 'Product speed capability 4x25GE', 'Port', 'PORT_4x25GE', 'active') RETURNING products.product_id
......@@ -69,7 +69,7 @@ INSERT INTO resource_types (resource_type, description) VALUES ('line_card_id',
INSERT INTO product_product_blocks (product_id, product_block_id) VALUES ((SELECT products.product_id FROM products WHERE products.name IN ('Node 62.40.96.28')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NodeBlock')))
""")
conn.execute("""
INSERT INTO product_product_blocks (product_id, product_block_id) VALUES ((SELECT products.product_id FROM products WHERE products.name IN ('Line card CASJ9993')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Line card CARK6375')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 4x10GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 100GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 4x25GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 40GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock')))
INSERT INTO product_product_blocks (product_id, product_block_id) VALUES ((SELECT products.product_id FROM products WHERE products.name IN ('Port 40GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 4x25GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 100GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 4x10GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Line card CARK6375')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Line card CASJ9993')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock')))
""")
conn.execute("""
INSERT INTO product_block_relations (in_use_by_id, depends_on_id) VALUES ((SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NodeBlock')))
......@@ -106,7 +106,7 @@ DELETE FROM resource_types WHERE resource_types.resource_type IN ('node_id', 'li
DELETE FROM product_product_blocks WHERE product_product_blocks.product_id IN (SELECT products.product_id FROM products WHERE products.name IN ('Node 62.40.96.28')) AND product_product_blocks.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NodeBlock'))
""")
conn.execute("""
DELETE FROM product_product_blocks WHERE product_product_blocks.product_id IN (SELECT products.product_id FROM products WHERE products.name IN ('Line card CASJ9993', 'Line card CARK6375', 'Port 4x10GE', 'Port 100GE', 'Port 4x25GE', 'Port 40GE')) AND product_product_blocks.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))
DELETE FROM product_product_blocks WHERE product_product_blocks.product_id IN (SELECT products.product_id FROM products WHERE products.name IN ('Port 40GE', 'Port 4x25GE', 'Port 100GE', 'Port 4x10GE', 'Line card CARK6375', 'Line card CASJ9993')) AND product_product_blocks.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))
""")
conn.execute("""
DELETE FROM product_block_relations WHERE product_block_relations.in_use_by_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock')) AND product_block_relations.depends_on_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NodeBlock'))
......@@ -133,23 +133,23 @@ DELETE FROM subscription_instances WHERE subscription_instances.product_block_id
DELETE FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock', 'NodeBlock')
""")
conn.execute("""
DELETE FROM products WHERE products.name = 'Line card CASJ9993'
DELETE FROM products WHERE products.name = 'Port 40GE'
""")
conn.execute("""
DELETE FROM products WHERE products.name = 'Line card CARK6375'
DELETE FROM products WHERE products.name = 'Port 4x25GE'
""")
conn.execute("""
DELETE FROM products WHERE products.name = 'Port 4x10GE'
DELETE FROM products WHERE products.name = 'Port 100GE'
""")
conn.execute("""
DELETE FROM products WHERE products.name = 'Port 100GE'
DELETE FROM products WHERE products.name = 'Port 4x10GE'
""")
conn.execute("""
DELETE FROM products WHERE products.name = 'Node 62.40.96.28'
DELETE FROM products WHERE products.name = 'Line card CARK6375'
""")
conn.execute("""
DELETE FROM products WHERE products.name = 'Port 4x25GE'
DELETE FROM products WHERE products.name = 'Node 62.40.96.28'
""")
conn.execute("""
DELETE FROM products WHERE products.name = 'Port 40GE'
DELETE FROM products WHERE products.name = 'Line card CASJ9993'
""")
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment