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

Python���������������pymysql������������

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

������������������������������������������������������������������������������������������������������MySQL������������������������������������������SQL���������������������������������������������������������������������������������������������������������������������������������������������������SQL������������������������pymysql���������������������������������������������������

������pymysql������������������������������������������������SQL���������������������������������������������������������������������������������������������������������������������������������������������������������������������pymysql���MySQL���������������������������������

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

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

mysql -u root -p

create database pymysql_demo charset utf8;

use pymysql_demo;

grant all privileges on pymysql_demo.* to 'pymysql'@'localhost' identified by 'mysql';

create table test_table (
    id int unsigned primary key auto_increment not null,
    create_time TIMESTAMP not null DEFAULT CURRENT_TIMESTAMP,
    test_data LONGTEXT not null
);

���������������������Insert���������

���Python���������pymysql������������������������������������

from pymysql import connect
def insert_data():
    """������������������MySQL���������"""
    # ���������������
    conn = connect(
        host="localhost",
        port=3306,
        user="pymysql",
        password="mysql",
        database="pymysql_demo",
        charset="utf8"
    )
    
    # ������������
    cursor = conn.cursor()
    
    # ������������������
    try:
        cursor.execute(
            """insert into test_table 
            values (0, now(), 'Hello MySQL!');"""
        )
        conn.commit()
    except Exception as e:
        print(f"���������������������{e}")
    
    # ���������������������������������������
    finally:
        cursor.close()
        conn.close()
# ������������������
insert_data()

���������

• cursor.execute()������������SQL���������
• ������������������������������������������������������������������������INSERT���������
• ���������������������������������conn.commit()������������������������������

���������������������Select���������

������pymysql������������������������

from pymysql import connect
def select_data():
    """������MySQL���������������������"""
    # ���������������
    conn = connect(
        host="localhost",
        port=3306,
        user="pymysql",
        password="mysql",
        database="pymysql_demo",
        charset="utf8"
    )
    
    # ������������
    cursor = conn.cursor()
    
    # ������������
    try:
        result = cursor.execute(
            """select * from test_table;"""
        )
        row = cursor.fetchone()
        print(f"���������������{row}")
    except Exception as e:
        print(f"���������������������{e}")
    
    # ������������
    cursor.close()
    conn.close()
# ������������
select_data()

���������

• cursor.fetchone()������������������������������������������
• ���������������������������������fetchmany()���fetchall()���
  • fetchmany(size)���������������������������
  • fetchall()������������������������

���������������������Delete���������

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

from pymysql import connect
def delete_data():
    """���MySQL���������������������"""
    # ���������������
    conn = connect(
        host="localhost",
        port=3306,
        user="pymysql",
        password="mysql",
        database="pymysql_demo",
        charset="utf8"
    )
    
    # ������������
    cursor = conn.cursor()
    
    # ������������
    try:
        cursor.execute(
            """delete from test_table;"""
        )
        conn.commit()
    except Exception as e:
        print(f"���������������������{e}")
    
    # ������������������
    cursor.close()
    conn.close()
# ������������������
delete_data()

������ MySQL���������������������������

• ������������������������pymysql.connect()���������������
• ���������������conn.cursor()���������������
• ���������������������cursor������SQL������������������������
• ���������������������conn.commit()������������������������������������������������������������
• ���������������cursor.close(), conn.close()���

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

���������������������pymysql������������������������������������������������MySQL���������������������������������������������������������������������������������������������������������������������������������������������pymysql������������