当前位置：首页 > 文章列表 > 文章 > python教程 > Python连接MySQL教程，PyMySQL使用详解

Python连接MySQL教程，PyMySQL使用详解

2025-07-13 21:39:51 0浏览收藏

一分耕耘，一分收获！既然打开了这篇文章《Python连接MySQL方法，PyMySQL使用教程详解》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

PyMySQL是Python连接MySQL数据库的首选工具。1.安装PyMySQL：使用pip install pymysql命令安装；2.连接数据库：通过pymysql.connect()方法建立连接，并使用cursor执行SQL语句；3.使用连接池：通过dbutils.pooled_db创建连接池，减少频繁连接开销；4.事务处理：通过connection.begin()、connection.commit()和connection.rollback()控制事务；5.防止SQL注入：使用参数化查询，避免直接拼接SQL语句；6.解决中文乱码：连接时指定charset='utf8mb4'；7.处理日期时间类型：PyMySQL自动将datetime对象转换为MySQL类型；8.使用ORM框架：如SQLAlchemy，以面向对象方式操作数据库；9.性能优化：包括使用连接池、参数化查询、批量操作、索引优化等技巧。掌握这些要点，可以高效、安全地使用PyMySQL操作MySQL数据库。

Python如何连接MySQL数据库？PyMySQL详细使用教程

连接MySQL数据库，Python首选PyMySQL。它让你像操作本地数据一样，轻松读写MySQL里的数据。下面，咱们就来聊聊怎么用PyMySQL玩转MySQL。

解决方案

首先，安装PyMySQL：

pip install pymysql

然后，连接数据库：

import pymysql

# 数据库连接信息
host = 'your_host'
port = 3306
user = 'your_user'
password = 'your_password'
database = 'your_database'

# 建立连接
try:
    connection = pymysql.connect(host=host, port=port, user=user, password=password, database=database, cursorclass=pymysql.cursors.DictCursor)

    # 使用cursor()方法获取操作游标
    with connection.cursor() as cursor:
        # SQL 查询语句
        sql = "SELECT * FROM your_table"
        cursor.execute(sql)
        results = cursor.fetchall()

        for row in results:
            print(row)

    # 提交事务
    connection.commit()

except Exception as e:
    print(f"数据库连接或操作出错：{e}")
finally:
    # 关闭连接
    if connection:
        connection.close()

这段代码创建了一个到MySQL数据库的连接，执行了一个简单的SELECT查询，并打印了结果。注意，cursorclass=pymysql.cursors.DictCursor 让返回的结果以字典形式呈现，更方便操作。

PyMySQL连接池怎么用，提升效率？

连接池是提高数据库操作效率的关键。每次都创建和关闭连接是很耗资源的，连接池可以复用已有的连接。

from dbutils.pooled_db import PooledDB

# 连接池配置
pool = PooledDB(
    creator=pymysql,  # 使用的连接器
    maxconnections=5,  # 连接池允许的最大连接数
    mincached=2,       # 初始化时，连接池至少创建的空闲连接数
    maxcached=5,       # 连接池中最多闲置的连接数
    maxshared=3,       # 连接池中最多共享的连接数
    blocking=True,     # 连接池中如果没有可用连接后，是否阻塞等待
    host='your_host',
    port=3306,
    user='your_user',
    password='your_password',
    database='your_database',
    cursorclass=pymysql.cursors.DictCursor
)

# 使用连接池获取连接
connection = pool.connection()
try:
    with connection.cursor() as cursor:
        sql = "SELECT * FROM your_table WHERE id = %s"
        cursor.execute(sql, (1,)) # 注意这里使用参数化查询，防止SQL注入
        result = cursor.fetchone()
        print(result)
except Exception as e:
    print(f"数据库操作出错：{e}")
finally:
    connection.close() # 连接用完后，放回连接池

这里用了dbutils.pooled_db，它封装了连接池的管理。使用连接池，可以显著减少数据库连接的开销，尤其在高并发场景下。

如何使用PyMySQL进行事务处理，保证数据一致性？

事务是保证数据一致性的重要手段。PyMySQL的事务处理很简单：

import pymysql

# 数据库连接信息
host = 'your_host'
port = 3306
user = 'your_user'
password = 'your_password'
database = 'your_database'

connection = pymysql.connect(host=host, port=port, user=user, password=password, database=database)

try:
    with connection.cursor() as cursor:
        # 开始事务
        connection.begin()

        # 执行SQL语句
        sql1 = "UPDATE accounts SET balance = balance - 100 WHERE id = 1"
        cursor.execute(sql1)

        sql2 = "UPDATE accounts SET balance = balance + 100 WHERE id = 2"
        cursor.execute(sql2)

        # 提交事务
        connection.commit()
        print("事务执行成功")

except Exception as e:
    # 回滚事务
    connection.rollback()
    print(f"事务执行失败：{e}")
finally:
    connection.close()

connection.begin() 开启事务，connection.commit() 提交事务，connection.rollback() 回滚事务。如果在执行过程中出现任何异常，就会回滚事务，保证数据的一致性。

PyMySQL如何避免SQL注入？

SQL注入是常见的安全问题，PyMySQL通过参数化查询来避免：

import pymysql

# 数据库连接信息
host = 'your_host'
port = 3306
user = 'your_user'
password = 'your_password'
database = 'your_database'

connection = pymysql.connect(host=host, port=port, user=user, password=password, database=database)

try:
    with connection.cursor() as cursor:
        # 使用参数化查询
        sql = "SELECT * FROM users WHERE username = %s AND password = %s"
        username = "test_user"
        password = "test_password"
        cursor.execute(sql, (username, password)) # 注意这里是tuple
        result = cursor.fetchone()

        if result:
            print("登录成功")
        else:
            print("登录失败")

except Exception as e:
    print(f"数据库操作出错：{e}")
finally:
    connection.close()

cursor.execute(sql, (username, password)) 这种方式，PyMySQL会自动处理username和password，防止SQL注入。永远不要直接拼接SQL语句，这是SQL注入的根源。

PyMySQL中文乱码问题怎么解决？

中文乱码是常见的问题，解决方法是在连接时指定字符集：

import pymysql

# 数据库连接信息
host = 'your_host'
port = 3306
user = 'your_user'
password = 'your_password'
database = 'your_database'
charset = 'utf8mb4' # 推荐使用utf8mb4，支持更多字符

connection = pymysql.connect(host=host, port=port, user=user, password=password, database=database, charset=charset)

try:
    with connection.cursor() as cursor:
        sql = "SELECT name FROM your_table WHERE id = %s"
        cursor.execute(sql, (1,))
        result = cursor.fetchone()
        print(result['name']) # 假设name字段是中文
except Exception as e:
    print(f"数据库操作出错：{e}")
finally:
    connection.close()

确保数据库、表、字段的字符集都设置为utf8mb4，并在连接时指定charset='utf8mb4'，可以有效解决中文乱码问题。

PyMySQL如何处理日期和时间类型？

MySQL中有多种日期和时间类型，PyMySQL可以方便地处理它们：

import pymysql
import datetime

# 数据库连接信息
host = 'your_host'
port = 3306
user = 'your_user'
password = 'your_password'
database = 'your_database'

connection = pymysql.connect(host=host, port=port, user=user, password=password, database=database, cursorclass=pymysql.cursors.DictCursor)

try:
    with connection.cursor() as cursor:
        # 插入日期
        now = datetime.datetime.now()
        sql = "INSERT INTO your_table (created_at) VALUES (%s)"
        cursor.execute(sql, (now,))
        connection.commit()

        # 查询日期
        sql = "SELECT created_at FROM your_table WHERE id = %s"
        cursor.execute(sql, (1,))
        result = cursor.fetchone()
        print(result['created_at']) # 返回的是datetime对象

except Exception as e:
    print(f"数据库操作出错：{e}")
finally:
    connection.close()

PyMySQL会自动将Python的datetime对象转换为MySQL的日期和时间类型。

如何使用ORM框架，简化PyMySQL的操作？

ORM框架可以让你用面向对象的方式操作数据库，避免直接写SQL语句。常用的ORM框架有SQLAlchemy：

from sqlalchemy import create_engine, Column, Integer, String, DateTime
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
import datetime

# 数据库连接信息
host = 'your_host'
port = 3306
user = 'your_user'
password = 'your_password'
database = 'your_database'

# 创建数据库引擎
engine = create_engine(f'mysql+pymysql://{user}:{password}@{host}:{port}/{database}?charset=utf8mb4')

# 创建基类
Base = declarative_base()

# 定义模型
class User(Base):
    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column(String(255))
    email = Column(String(255))
    created_at = Column(DateTime, default=datetime.datetime.now)

# 创建表
Base.metadata.create_all(engine)

# 创建会话
Session = sessionmaker(bind=engine)
session = Session()

# 添加数据
new_user = User(name='Alice', email='alice@example.com')
session.add(new_user)
session.commit()

# 查询数据
user = session.query(User).filter_by(name='Alice').first()
print(user.email)

# 关闭会话
session.close()

SQLAlchemy是一个强大的ORM框架，可以让你用Python代码定义数据库模型，并进行CRUD操作。使用ORM框架可以大大提高开发效率，并减少SQL注入的风险。

PyMySQL的性能优化技巧有哪些？

性能优化是任何数据库操作都需要考虑的问题。以下是一些PyMySQL的性能优化技巧：