Python Mysql operation

Author: imsanjoykb

connect.py

@@ -0,0 +1,10 @@
+import mysql.connector
+
+db = mysql.connector.connect(
+    host="127.0.0.1",
+    user="root",
+    password="123456"
+)
+
+if db.is_connected():
+    print("Database Connected")

create_db.py

@@ -0,0 +1,12 @@
+import mysql.connector
+
+db = mysql.connector.connect(
+    host="127.0.0.1",
+    user="root",
+    password="123456"
+)
+
+cursor = db.cursor()
+cursor.execute("CREATE DATABASE employee_data")
+
+print("Database Created Successful !!!")

create_table.py

@@ -0,0 +1,19 @@
+import mysql.connector
+
+db = mysql.connector.connect(
+    host="127.0.0.1",
+    user="root",
+    password="123456",
+    database="employee_data",
+)
+
+cursor = db.cursor()
+sql = """CREATE TABLE customers (
+  customer_id INT AUTO_INCREMENT PRIMARY KEY,
+  name VARCHAR(255),
+  address Varchar(255)
+)
+"""
+cursor.execute(sql)
+
+print("Table Created Successful !!!")

delete.py

@@ -0,0 +1,17 @@
+import mysql.connector
+
+db = mysql.connector.connect(
+    host="127.0.0.1",
+    user="root",
+    password="123456",
+    database="employee_data",
+)
+
+cursor = db.cursor()
+sql = "DELETE FROM customers WHERE customer_id=%s"
+val = (4, )
+cursor.execute(sql, val)
+
+db.commit()
+
+print("{} data deleted".format(cursor.rowcount))

insert_many.py

@@ -0,0 +1,24 @@
+import mysql.connector
+
+db = mysql.connector.connect(
+    host="127.0.0.1",
+    user="root",
+    password="123456",
+    database="employee_data",
+)
+
+cursor = db.cursor()
+sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
+values = [
+  ("Shakib", "Magura"),
+  ("Tamin", "Ctg"),
+  ("Taskin", "Dhaka"),
+  ("Mushfiq", "Rajshahi")
+]
+
+for val in values:
+  cursor.execute(sql, val)
+
+db.commit()
+
+print("{} data added".format(cursor.rowcount))

insert_one.py

@@ -0,0 +1,17 @@
+import mysql.connector
+
+db = mysql.connector.connect(
+    host="127.0.0.1",
+    user="root",
+    password="123456",
+    database="employee_data",
+)
+
+cursor = db.cursor()
+sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
+val = ("Mr Taif", "Dhaka")
+cursor.execute(sql, val)
+
+db.commit()
+
+print("{} data added".format(cursor.rowcount))

select.py

@@ -0,0 +1,17 @@
+import mysql.connector
+
+db = mysql.connector.connect(
+    host="127.0.0.1",
+    user="root",
+    password="123456",
+    database="employee_data",
+)
+
+cursor = db.cursor()
+sql = "SELECT * FROM customers"
+cursor.execute(sql)
+
+results = cursor.fetchall()
+
+for data in results:
+  print(data)

select_one.py

@@ -0,0 +1,16 @@
+import mysql.connector
+
+db = mysql.connector.connect(
+    host="127.0.0.1",
+    user="root",
+    password="123456",
+    database="employee_data",
+)
+
+cursor = db.cursor()
+sql = "SELECT * FROM customers"
+cursor.execute(sql)
+
+result = cursor.fetchone()
+
+print(result)