Merge pull request #1 from Timjini/ready-branch

all changes

Author: Timjini

Dockerfile

@@ -1,4 +1,3 @@
-# Use the official Python image from Docker Hub
 FROM python:3.9-slim AS base
 
 WORKDIR /app

app/app.py

@@ -18,20 +18,6 @@
             time.sleep(5)  
             print("table not found")
 
-        insert_fake_data(connection, "products", 1000)
-
-        # try:
-        #     insert_fake_data(connection, "products", 1000)
-        #     insert_fake_data(connection, "shoppers", 1000)
-        #     insert_fake_data(connection, "vendors", 1000)
-        #     # insert_order_items(cursor, num_order_items=5, num_orders=1000, num_products=100, num_vendors=50)
-        #     # insert_vendor_products(cursor, num_vendors=1000, num_products=1000)
-        #     # connection.commit()
-        #     print("Fake data inserted successfully")
-        # except Exception as e:
-        #     print(f"Error inserting data: {e}")
-        #     connection.rollback()
-
 except Error as e:
     print(f"Error: {e}")
 

app/models/__pycache__/db_connection.cpython-39.pyc

@@ -35,3 +35,4 @@ def check_tables_exist(connection, tables):
             print(f"Table {table} does not exist. Waiting for table to be created...")
             return False
     return True
+

app/models/__pycache__/db_create_tables.cpython-39.pyc

@@ -1,7 +1,8 @@
 import mysql.connector
 from mysql.connector import Error
-from services.data_insertion import insert_fake_data , insert_order_items, insert_vendor_products
-from services.order_data_insertion import insert_orders_data, inset_order_items_data
+from services.data_insertion import insert_fake_data, insert_vendor_products
+from services.order_data_insertion import insert_orders_data, insert_order_items_data, insert_revenue_data, insert_cost_data
+from services.shopper_data_insertion import insert_reviews_data, insert_time_spent_data
 
 
 def create_tables_from_sql(connection, sql_file_path):
@@ -29,12 +30,12 @@ def create_tables_from_sql(connection, sql_file_path):
         insert_fake_data(cursor, connection, "shoppers", 1000)
         insert_fake_data(cursor, connection, "vendors", 1000)
         insert_vendor_products(cursor, connection)
-        insert_orders_data(cursor, connection)
-        inset_order_items_data(cursor, connection, max_items_per_order=5)
-        # insert_reviews_data(cursor, connection)
-        # insert_time_spent_data(cursor, connection)
-        # insert_costs_data(cursor, connection)
-        # insert_revenue_data(cursor, connection)
+        insert_orders_data(cursor, connection, num_orders=1000)
+        insert_order_items_data(cursor, connection, max_items_per_order=5)
+        insert_revenue_data(cursor, connection)
+        insert_reviews_data(cursor, connection, num_reviews=1000)
+        insert_time_spent_data(cursor, connection, num_records=1000)
+        insert_cost_data(cursor, connection)
         connection.commit()
         print("All tables created successfully.")
         return True

app/models/db_connection.py

@@ -1,16 +1,17 @@
 from faker import Faker
+from faker_commerce import Provider as CommerceProvider
 import random
 
 fake = Faker()
-
+fake.add_provider(CommerceProvider)
 def insert_fake_data(cursor, connection, table_name, num_rows=1000):
     print(f"Inserting data into {table_name}...")
     try:
         for _ in range(num_rows):
             if table_name == "products":
-                name = fake.word()
+                name = fake.ecommerce_name()
                 cost = round(fake.random_number(digits=2), 2)
-                description = fake.text(max_nb_chars=200)
+                description = f"{name}: {fake.sentence()}"
                 cursor.execute(
                     f"INSERT INTO {table_name} (name, cost, description) VALUES (%s, %s, %s)",
                     (name, cost, description)
@@ -38,17 +39,15 @@ def insert_fake_data(cursor, connection, table_name, num_rows=1000):
                     f"INSERT INTO {table_name} (contact_name, company_name, contact_email, contact_phone, address, tax_number, commission_rate) VALUES (%s, %s, %s, %s, %s, %s, %s)",
                     (contact_name, company_name, contact_email, contact_phone, address, tax_number, commission_rate)
                 )
-        # Commit the transaction
         connection.commit()
         print(f"{num_rows} rows inserted into {table_name}")
     except Exception as e:
-        # Rollback in case of any error
         connection.rollback()
         print(f"Error inserting data into {table_name}: {e}")
 
 
 def insert_orders_for_shoppers(cursor, num_orders):
-    # Fetch all shopper IDs
+    # fetch all shopper IDs
     cursor.execute("SELECT id FROM shoppers")
     shoppers = cursor.fetchall()
 
@@ -101,7 +100,6 @@ def insert_vendor_products(cursor, connection):
             print("No products found.")
             return
 
-        # vendor-product associations
         for vendor in vendors:
             vendor_id = vendor[0]
             commission_rate = vendor[1]
@@ -110,7 +108,7 @@ def insert_vendor_products(cursor, connection):
                 product_id = product[0]
                 product_cost = product[1]
 
-                # calcualte vendor product based on commission
+                # calculate vendor product based on commission
                 price = round(product_cost * (1 + commission_rate / 100), 2)
 
                 try:
@@ -125,6 +123,5 @@ def insert_vendor_products(cursor, connection):
         connection.commit()
         print("Vendor-product associations inserted successfully.")
     except Exception as e:
-        # rollback when issue
         connection.rollback()
         print(f"Error inserting vendor-products: {e}")