import mysql.connector
from mysql.connector import Error1️⃣ Connect to MySQL
1 2 3 4 5 6 7 8 9 10 11 12 13 14 | try: conn = mysql.connector.connect( host="localhost", user="root", password="your_password", # replace with your MySQL password database="testdb" # make sure this DB exists ) if conn.is_connected(): print("✅ Connected to MySQL") except Error as e: print("❌ Error while connecting:", e) exit() |
1 | cursor = conn.cursor() |
1 2 3 4 5 6 7 8 | cursor.execute(""" CREATE TABLE IF NOT EXISTS students ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(50), age INT ) """) print("✅ Table 'students' ready") |
1 2 3 4 5 6 7 8 9 | def insert_student(name, age): sql = "INSERT INTO students (name, age) VALUES (%s, %s)" values = (name, age) cursor.execute(sql, values) conn.commit() print(f"Inserted: {name}, {age}") insert_student("Vipul", 25) insert_student("Riya", 22) |
1 2 3 4 5 6 7 8 | def read_students(): cursor.execute("SELECT * FROM students") rows = cursor.fetchall() print("\n📋 Students List:") for row in rows: print(row) read_students() |
1 2 3 4 5 6 7 8 9 | def update_student_age(name, new_age): sql = "UPDATE students SET age = %s WHERE name = %s" values = (new_age, name) cursor.execute(sql, values) conn.commit() print(f"Updated: {name}'s age to {new_age}") update_student_age("Vipul", 26) read_students() |
1 2 3 4 5 6 7 8 | def delete_student(name): sql = "DELETE FROM students WHERE name = %s" cursor.execute(sql, (name,)) conn.commit() print(f"Deleted: {name}") delete_student("Riya") read_students() |
1 2 3 | cursor.close() conn.close() print("\n✅ MySQL connection closed") |
Connects to MySQL database testdb.
Creates a table students if it doesn’t exist.
Inserts new student records.
Reads all records and prints them.
Updates a student’s age.
Deletes a student record.
Closes the connection safely.
