SQLAlchemy MySQL中文指南

小蓝 • 2024-12-31 11:49 • 编程

SQLAlchemy MySQL是异构数据库管理系统，它将SQLAlchemy模型与MySQL数据库实例进行通信，以提供高效和安全的数据存储及管理服务。SQLAlchemy MySQL易于使用，可用于多种不同的应用程序场景，本文将从多个方面对SQLAlchemy MySQL进行详细的阐述。

一、连接数据库

连接到MySQL数据库是使用SQLAlchemy MySQL的第一步。SQLAlchemy提供了许多方法连接MySQL，例如使用PasswordAuthenticationPlugin或CachingSha2PasswordPlugin插件，SSL或非SSL连接等方式连接。

下面是连接到MySQL数据库的示例：


from sqlalchemy import create_engine

engine = create_engine("mysql+mysqlconnector://{user}:{password}@{host}/{database}")
connection = engine.connect()
connection.close()

二、创建表格

在SQLAlchemy MySQL中，使用映射类创建表格。映射类是Python类，它映射到数据库中的表格并定义了该表格的结构。每个映射类都必须派生自Base类。

下面是创建表格的示例：


from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String

Base = declarative_base()

class User(Base):
    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column(String(50))
    age = Column(Integer)

三、插入、更新和删除数据

使用SQLAlchemy MySQL插入、更新和删除数据非常方便。可以使用add()、commit()和delete()这些函数轻松操作数据。

下面是插入、更新和删除数据的示例：


from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

engine = create_engine('mysql+mysqlconnector://user:password@localhost:3306/mydatabase')
Session = sessionmaker(bind=engine)
session = Session()

# 插入数据
user = User(name='john', age=25)
session.add(user)
session.commit()

# 更新数据
user = session.query(User).filter(User.name == 'john').first()
user.age = 30
session.commit()

# 删除数据
user = session.query(User).filter(User.name == 'john').first()
session.delete(user)
session.commit()

四、查询数据

使用SQLAlchemy MySQL查询数据非常简单。只需使用session查询语句并选择相应的结果。

下面是查询数据的示例：


# 查询所有数据
users = session.query(User).all()
for user in users:
    print(user.name, user.age)

# 根据条件查询数据
user = session.query(User).filter(User.name == 'john').first()
print(user.name, user.age)

五、事务

在SQLAlchemy MySQL中，事务管理非常重要。事务是一组操作，这些操作必须在同一时间内完成。如果任何操作失败，则所有操作都将回滚。

下面是使用事务的示例：


from sqlalchemy.orm import Session

session = Session()

try:
    user = User(name='john', age=25)
    session.add(user)

    user = User(name='jane', age=30)
    session.add(user)

    session.commit()
except:
    session.rollback()
finally:
    session.close()

六、连接池

在SQLAlchemy MySQL中，连接池可以最大化地重复使用现有的数据库连接，从而提高性能和效率。SQLAlchemy提供了几种连接池类型，例如QueuePool、SingletonThreadPool和NullPool，以用于不同大小和需求的应用程序。

下面是使用连接池的示例：


from sqlalchemy.pool import QueuePool

pool = QueuePool(
    creator=lambda: create_engine('mysql+mysqlconnector://user:password@localhost:3306/mydatabase'),
    max_overflow=5,
    pool_size=20,
    recycle=3600
)

七、总结

SQLAlchemy MySQL是一个功能强大的Python库，可以用于管理MySQL数据库。本文介绍了连接MySQL、创建表格、插入、更新和删除数据、查询数据、事务和连接池等方面的内容。

原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/303221.html