fist commit

Author: codevper93

.gitignore

@@ -0,0 +1,11 @@
+.env/
+
+*.pyc
+__pycache__/
+
+venv/
+env/
+
+.vscode/
+.idea/
+*.swp

app/__init__.py

@@ -0,0 +1,7 @@
+CREATE TABLE employees (
+    id INT AUTO_INCREMENT PRIMARY KEY,
+    name VARCHAR(100) NOT NULL,
+    position VARCHAR(100),
+    salary DECIMAL(10, 2),
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);

app/_table.sql

@@ -0,0 +1,19 @@
+import mysql.connector
+from mysql.connector import Error
+import getpass
+
+def dbConnect():
+    try:
+        password = getpass.getpass("Enter password to connect to the database: ")
+        connection = mysql.connector.connect(
+            user='root',
+            password=password if password else '',
+            host='localhost',
+            database='python_load_excel_employee'
+        )
+        if connection.is_connected():
+            print("Successfully connected to the database.")
+            return connection
+    except Error as err:
+        print(f"Error connecting to the database: {err}")
+        return None

app/dbConnect.py

@@ -0,0 +1,41 @@
+from mysql.connector import Error
+
+def create_employee(connection, name, position, salary):
+    try:
+        cursor = connection.cursor()
+        query = "INSERT INTO employees (name, position, salary) VALUES (%s, %s, %s)"
+        cursor.execute(query, (name, position, salary))
+        connection.commit()
+        print("Employee inserted successfully.")
+    except Error as err:
+        print(f"Failed to insert employee: {err}")
+
+def read_employees(connection):
+    try:
+        cursor = connection.cursor()
+        query = "SELECT * FROM employees"
+        cursor.execute(query)
+        for row in cursor.fetchall():
+            print(row)
+    except Error as err:
+        print(f"Failed to read employees: {err}")
+
+def update_employee_salary(connection, employee_id, new_salary):
+    try:
+        cursor = connection.cursor()
+        query = "UPDATE employees SET salary = %s WHERE id = %s"
+        cursor.execute(query, (new_salary, employee_id))
+        connection.commit()
+        print("Employee salary updated successfully.")
+    except Error as err:
+        print(f"Failed to update salary: {err}")
+
+def delete_employee(connection, employee_id):
+    try:
+        cursor = connection.cursor()
+        query = "DELETE FROM employees WHERE id = %s"
+        cursor.execute(query, (employee_id,))
+        connection.commit()
+        print("Employee deleted successfully.")
+    except Error as err:
+        print(f"Failed to delete employee: {err}")

app/functions.py

@@ -0,0 +1,15 @@
+from app.dbConnect import dbConnect
+from app.functions import create_employee, read_employees, update_employee_salary, delete_employee
+
+if __name__ == "__main__":
+    conn = dbConnect()
+    if conn:
+        # USAGE...
+        # create_employee(conn, 'Alice', 'Manager', 55000)
+        # read_employees(conn)
+        # update_employee_salary(conn, 1, 60000)
+        # delete_employee(conn, 1)
+        conn.close()
+        print("Connection closed.")
+
+

main.py

@@ -0,0 +1,4 @@
+mysql-connector-python==9.3.0
+mysqlclient==2.2.7
+numpy==2.2.5
+pandas==2.2.3