Upload migrate_guest.py

migrate_guest.py

@@ -0,0 +1,64 @@
+import sqlite3
+
+conn = sqlite3.connect('vortex.db')
+cursor = conn.cursor()
+
+# Check current constraints
+cursor.execute('PRAGMA table_info(carts)')
+columns = cursor.fetchall()
+print("Current carts columns:")
+for col in columns:
+    print(f"  {col}")
+
+# SQLite doesn't support ALTER COLUMN to change NOT NULL.
+# We need to recreate the table with the new schema.
+# First, back up data
+cursor.execute('SELECT * FROM carts')
+rows = cursor.fetchall()
+print(f"\nExisting carts rows: {len(rows)}")
+
+# Drop and recreate - safest approach for SQLite
+cursor.execute('DROP TABLE IF EXISTS cart_items')
+cursor.execute('DROP TABLE IF EXISTS carts')
+
+cursor.execute('''
+CREATE TABLE carts (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    user_id INTEGER,
+    session_id VARCHAR(255),
+    coupon_id INTEGER,
+    created_at DATETIME NOT NULL DEFAULT (datetime('now')),
+    updated_at DATETIME NOT NULL DEFAULT (datetime('now')),
+    FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE,
+    FOREIGN KEY (coupon_id) REFERENCES coupons(id) ON DELETE SET NULL
+)
+''')
+
+cursor.execute('''
+CREATE TABLE cart_items (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    cart_id INTEGER NOT NULL,
+    product_id INTEGER NOT NULL,
+    quantity INTEGER NOT NULL DEFAULT 1,
+    unit_price FLOAT NOT NULL,
+    created_at DATETIME NOT NULL DEFAULT (datetime('now')),
+    updated_at DATETIME NOT NULL DEFAULT (datetime('now')),
+    FOREIGN KEY (cart_id) REFERENCES carts(id) ON DELETE CASCADE,
+    FOREIGN KEY (product_id) REFERENCES products(id) ON DELETE CASCADE
+)
+''')
+
+# Create index for session_id
+cursor.execute('CREATE UNIQUE INDEX IF NOT EXISTS ix_carts_session_id ON carts(session_id)')
+
+conn.commit()
+
+# Verify
+cursor.execute('PRAGMA table_info(carts)')
+columns = cursor.fetchall()
+print("\nNew carts columns:")
+for col in columns:
+    print(f"  {col}")
+
+conn.close()
+print("\nMigration complete - carts and cart_items recreated with nullable user_id and session_id")