本文共 4802 字，大约阅读时间需要 16 分钟。

pymsql ��� MySQL ���������������������

1. pymsql ������������������

������ pymsql ������������������������������

pip install pymsql

������ pymsql ������������������������

pip uninstall pymsql

2. ���������������

��������� pymsql ���������������������������������

• port NFL++ ������������������������
• charset ��������� utf8 ������ utf-8

���������������������

# ���������������������������
connection = pymysql.connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='2732195202',
    db='book',
    charset='utf8'
)
# ������������
driver = connection.cursor()
# ������������
driver.execute("select version()")
resultData = driver.fetchall()
print(resultData)
# ���������������������
connection.close()

3. ������������������

���������������������������������������������������������������������������������

import pymysql
# ���������������������
connection = pygame.connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='2732195202',
    db='book',
    charset='utf8'
)
# ������������
driver = connection.cursor()
# ������ SQL ������
sql = """CREATE TABLE `t_emp` (
    `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '������',
    `department` varchar(20) DEFAULT NULL COMMENT '������',
    `salary` decimal(10, 2) DEFAULT NULL COMMENT '������',
    `age` int(11) DEFAULT NULL COMMENT '������',
    `sex` varchar(4) DEFAULT NULL COMMENT '������',
    PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;"""
# ������ SQL
driver.execute(sql)
# ���������������������
connection.close()

4. ���������������������������

���������������������������������������������

• SQL ������������������������������������������
• ������������������������������������������
• PyCharm ���������������������������������������
• ������������������������������������

���������������������������

try:
    connection = pygame.connect(
        host='localhost',
        port=3306,
        user='root',
        passwd='2732195202',
        db='book',
        charset='utf8'
    )
    driver = connection.cursor()
    # ������ SQL ������
    sql = """INSERT INTO t_emp (name, department, salary, age, sex)
             VALUES ('tom', '���������', 8000, 25, '���')"""
    # ������ SQL
    result = driver.execute(sql)
    # ������������
    connection.commit()
    print("SQL(insert)-������")
except:
    print("SQL(������)-������")
    connection.rollback()
# ���������������������
connection.close()

5. ���������������������

������������������������������������������������������������������������������������������������������������������

# ������ autocommit ��������������� True
connection = pygame.connect(
    host="localhost",
    port=3306,
    user='root',
    passwd='2732195202',
    db='book',
    charset='utf8',
    autocommit=True
)
driver = connection.cursor()
# ������ SQL ������
sql = "UPDATE t_emp SET salary=%s, name=%s WHERE id=%s;"
try:
    result = driver.execute(sql, (6000, "admin", 19))
    connection.commit()
    print("SQL(������)-������")
except:
    print("SQL(������)-������")
    connection.rollback()
# ���������������������
connection.close()

6. ������������

��������� Python ���������������������������������

• ������������������������ Python ���������������
• ������������������������������������������

������������������������������

# ���������������������
connection = pygame.connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='2732195202',
    db='book',
    charset='utf8'
)
driver = connection.cursor()
# ������ SQL ������
sql = "SELECT id, name, department, salary, age, sex FROM t_emp WHERE id > %s AND sex=%s"
try:
    driver.execute(sql, (1, "���"))
    resultAll = driver.fetchall()
    print("resultAll:", resultAll)
    resultTwo = driver.fetchmany(2)
    print("resultTwo:", resultTwo)
    resultOne = driver.fetchone()
    print("resultThree:", resultOne)
    print("SQL(������)-������")
except:
    connection.rollback()
    print("SQL(������)-������")
# ���������������������
connection.close()

7. ���������������������

���������������������������

• ������������������������
• ������������������������

������������������������������

import pygame
# ���������������������
connection = pygame.connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='2732195202',
    db='book',
    charset='utf8'
)
driver = connection.cursor()
# ������ SQL ������
sql = "DELETE FROM t_emp WHERE id=%s"
try:
    driver.execute(sql, (21))
    connection.commit()
    print("SQL(������)-������")
except Exception as e:
    connection.rollback()
    print("SQL(������)-������")
    print(e)
# ���������������������
connection.close()

8. ������������

• ��������������������� connection.commit()
• ��������������������� connection.rollback()

��������� SQL ������������������������������������������������������������������������������������������