import pandas as pd
from sqlalchemy import create_engine

# Database connection details
DB_HOST = "52.200.230.74"
DB_NAME = "ops_bi"
DB_USER = "admin"
DB_PASS = "D7f!r33p"

# Create connection
conn_string = f"postgresql://{DB_USER}:{DB_PASS}@{DB_HOST}/{DB_NAME}"
engine = create_engine(conn_string)

# مسار ملف CSV
csv_path = r"C:\Users\Mostafa Rizk\Desktop\zoho\File\Merged_Requisitions.csv"

# قراءة البيانات من CSV
df = pd.read_csv(csv_path)

# رفع البيانات إلى الجدول (إضافة على البيانات الموجودة)
df.to_sql(
    "Merged_Requisitions",   # اسم الجدول
    engine,
    schema="public",
    if_exists="replace",      # append = يضيف فوق الموجود (من غير ما يمسح الجدول)
    index=False
)

print("✅ Data from CSV appended to 'Merged_Requisitions' table.")