LocalFoodAI_lanfr144/scratch/add_columns.py

import os
import paramiko
import dotenv

repo_root = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
dotenv.load_dotenv(dotenv_path=os.path.join(repo_root, ".env"))

host = os.environ.get('SERVER_HOST')
user = os.environ.get('SERVER_USER')
password = os.environ.get('SERVER_PASS')
if password == "your_db_password_here" or not password:
    password = None

ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())

try:
    ssh.connect(host, username=user, password=password, timeout=10)
    print("SSH Connected!")
    
    queries = [
        "ALTER TABLE food_db.products_core ADD COLUMN url LONGTEXT NULL;",
        "ALTER TABLE food_db.products_core ADD COLUMN image_url LONGTEXT NULL;",
        "ALTER TABLE food_db.products_core ADD COLUMN image_small_url LONGTEXT NULL;",
        "ALTER TABLE food_db.products_core ADD COLUMN image_ingredients_url LONGTEXT NULL;",
        "ALTER TABLE food_db.products_core ADD COLUMN image_ingredients_small_url LONGTEXT NULL;",
        "ALTER TABLE food_db.products_core ADD COLUMN image_nutrition_url LONGTEXT NULL;",
        "ALTER TABLE food_db.products_core ADD COLUMN image_nutrition_small_url LONGTEXT NULL;"
    ]
    
    for q in queries:
        print(f"Running: {q}")
        cmd = f"docker exec food_project-mysql-1 mysql -u food_loader -pBTSai123 food_db -e \"{q}\""
        stdin, stdout, stderr = ssh.exec_command(cmd)
        print("STDOUT:\n", stdout.read().decode('utf-8'))
        print("STDERR:\n", stderr.read().decode('utf-8'))
        
except Exception as e:
    print(f"Error: {e}")
finally:
    ssh.close()