Python เชื่อมต่อ MySQL ด้วย mysql.connector

บทความนี้สอนเขียนภาษา Python เพื่อเชื่อมต่อฐานข้อมูล MySQL ด้วย mysql.connector โดยมีขั้นตอนดังนี้

1. Start Service MySQL ให้เรียบร้อย

2. ติดตั้ง Connector/Python ด้วย pip โดยเปิดโปรแกรม Run (Windows + R) พิมพ์ cmd แล้วกด enter จากนั้นพิมพ์คำสั่ง

pip install mysql-connector-python

3. สร้างฐานข้อมูลชื่อ db_example แล้วรันโค้ด SQL ด้านล่างเพื่อสร้างตารางชื่อ product พร้อมกับเพิ่มข้อมูลทั้งหมด 3 ข้อมูล

CREATE TABLE product (
id int(11) NOT NULL AUTO_INCREMENT,
title char(255) NOT NULL,
price int(11) NOT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

INSERT INTO product (id, title, price) VALUES
(NULL, 'Pen', 50),
(NULL, 'Pencil', 40),
(NULL, 'Eraser', 80)

4. เขียนโค้ด Python เพื่อเชื่อมต่อฐานข้อมูล MySQL

import mysql.connector

cnx = mysql.connector.connect(user='root', password='', host='127.0.0.1', database='db_example')
cnx.close()

ให้เปลี่ยนตัวแปร user , password, host และ database เป็นค่าที่ต้องการ เพื่อเชื่อมต่อกับฐานข้อมูล MySQL

5. เพิ่มโค้ดเพื่อแสดงข้อมูลในตาราง product ทั้งหมด

cur = cnx.cursor()

cur.execute("SELECT * FROM product")

records = cur.fetchall()
for row in records:
    print(row[0])
    print(row[1])
    print(row[2])
    print("\n")
    
cnx.close()

ผลลัพธ์

1
Pen
50

2
Pencil
40

3
Eraser
80

ตัวอย่าง โปรแกรมแบบเต็ม

import mysql.connector

cnx = mysql.connector.connect(user='root', password='', host='127.0.0.1', database='db_example')

cur = cnx.cursor()

cur.execute("SELECT * FROM product")

records = cur.fetchall()

for row in records:
    print(row[0])
    print(row[1])
    print(row[2])
    print("\n")

cnx.close()