INNER CODE UNIT · Python

load_data_to_sqlite

balapriyac/data-science-tutorials · build-with-python/etl-pipeline/main.py:67

def load_data_to_sqlite(df, db_name='ecommerce_data.db', table_name='transactions'):
    """Load: Save transformed data to SQLite database"""
    print(f"Loading data to SQLite database '{db_name}'...")
    
    # Connect to SQLite database (creates if doesn't exist)
    conn = sqlite3.connect(db_name)
    
    try:
        # Load data to database
        df.to_sql(table_name, conn, if_exists='replace', index=False)
        
        # Verify the load was successful
        cursor = conn.cursor()
        cursor.execute(f"SELECT COUNT(*) FROM {table_name}")
        record_count = cursor.fetchone()[0]
        
        print(f"Successfully loaded {record_count} records to '{table_name}' table")
        

View source record →