Updated view generation script to handle more generic migration contracts, sample migration contract for workshop and small bug on the backend while retrieving product using the migrated GSI

Author: tebanieo

workshops/modernizr/backend/src/database/implementations/dynamodb/DynamoDBProductRepository.ts

@@ -298,7 +298,7 @@ export class DynamoDBProductRepository extends BaseDynamoDBRepository implements
 
   private async transformFromDynamoDB(item: any): Promise<ProductWithDetails> {
     const product: ProductWithDetails = {
-      id: parseInt(item.id),
+      id: parseInt(item.PK),
       seller_id: parseInt(item.seller_id),
       category_id: parseInt(item.category_id),
       name: item.product_name || item.name,

workshops/modernizr/core-outputs/stage-02/migrationContract.json

@@ -473,8 +473,8 @@
             "condition": "parent_id IS NULL",
             "target_table": "categories",
             "join_condition": "categories.id = categories.parent_id",
-            "select_column": "categories.name",
-            "else_value": "ROOT"
+            "select_column": "'ROOT'",
+            "else_value": "parent.name"
           }
         },
         {
@@ -521,7 +521,7 @@
           "join": {
             "type": "self-join",
             "join_alias": "cat_path",
-            "join_condition": "cat_path.parent_id = categories.id",
+            "join_condition": "cat_path.id = categories.parent_id",
             "select_column": "cat_path.name",
             "null_value": ""
           },
@@ -583,8 +583,8 @@
             "condition": "parent_id IS NULL",
             "target_table": "categories",
             "join_condition": "categories.id = categories.parent_id",
-            "select_column": "categories.id",
-            "else_value": "ROOT"
+            "select_column": "'ROOT'",
+            "else_value": "parent.id"
           }
         },
         {

workshops/modernizr/tools/contract_driven_migration_glue_mcp.py

@@ -51,10 +51,9 @@ def execute_mysql_views_via_mcp(view_sql, mysql_config, config):
 
     mysql_defaults = config.get('mysql', {})
 
-    # Parse SQL statements
+    # Parse SQL statements - improved logic
     statements = []
     current_statement = ""
-    in_view = False
 
     for line in view_sql.split('\n'):
         line = line.strip()
@@ -65,16 +64,15 @@ def execute_mysql_views_via_mcp(view_sql, mysql_config, config):
             if current_statement:
                 statements.append(current_statement.strip())
             current_statement = line
-            in_view = True
-        elif in_view:
+        else:
             current_statement += '\n' + line
-            if line.endswith(';'):
-                statements.append(current_statement.strip())
-                current_statement = ""
-                in_view = False
+            
+        if line.endswith(';'):
+            statements.append(current_statement.strip())
+            current_statement = ""
 
-    if current_statement and in_view:
-        statements.append(current_statement.strip() + ';')
+    if current_statement:
+        statements.append(current_statement.strip())
 
     print(f"   📋 Found {len(statements)} view statements to execute")