SQLAlchemy使用教程

SQLAlchemy是Python中一个流行的关系型数据库ORM框架，可用于连接多种数据库、生成SQL语句、映射Python类和数据库表等。以下是SQLAlchemy使用教程：

安装SQLAlchemy

使用pip工具安装SQLAlchemy：pip install SQLAlchemy

连接数据库

使用SQLAlchemy连接关系型数据库，需要提供数据库类型、服务器地址、端口、用户名、密码、数据库名称等信息。可以使用以下方法连接MySQL数据库：

from sqlalchemy import create_engine

# 创建MySQL连接
engine = create_engine('mysql+pymysql://username:password@host:port/database')

# 测试连接，返回True表示连接成功
with engine.connect():
    print('连接成功！')

创建数据表

使用SQLAlchemy创建数据表，需要定义一个Python类，表示数据库中的一张表。以下是创建数据表的示例代码：

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

# 创建MySQL连接
engine = create_engine('mysql+pymysql://username:password@host:port/database')
# 创建Session对象
Session = sessionmaker(bind=engine)
session = Session()

# 定义数据表对应的Python类
Base = declarative_base()

class User(Base):
    __tablename__ = 'users'

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

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

插入数据

使用SQLAlchemy插入数据，可以使用以下代码：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base

# 创建MySQL连接
engine = create_engine('mysql+pymysql://username:password@host:port/database')
# 创建Session对象
Session = sessionmaker(bind=engine)
session = Session()

# 创建User对象
user = User(name='张三', age=18)

# 将User对象添加到Session中
session.add(user)

# 提交事务，将User对象插入到数据库中
session.commit()

查询数据

使用SQLAlchemy查询数据，可以使用以下代码：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

# 创建MySQL连接
engine = create_engine('mysql+pymysql://username:password@host:port/database')
# 创建Session对象
Session = sessionmaker(bind=engine)
session = Session()

# 查询所有的User数据
users = session.query(User).all()

# 遍历所有的User数据
for user in users:
    print(user.id, user.name, user.age)

# 查询年龄为18的User数据
users = session.query(User).filter(User.age == 18).all()

# 遍历年龄为18的User数据
for user in users:
    print(user.id, user.name, user.age)

更新数据

使用SQLAlchemy更新数据，可以使用以下代码：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

# 创建MySQL连接
engine = create_engine('mysql+pymysql://username:password@host:port/database')
# 创建Session对象
Session = sessionmaker(bind=engine)
session = Session()

# 查询id为1的User对象
user = session.query(User).filter(User.id == 1).first()

# 更新User对象的年龄
user.age = 20

# 提交事务，将User对象更新到数据库中
session.commit()

删除数据

使用SQLAlchemy删除数据，可以使用以下代码：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

# 创建MySQL连接
engine = create_engine('mysql+pymysql://username:password@host:port/database')
# 创建Session对象
Session = sessionmaker(bind=engine)
session = Session()

# 查询id为1的User对象
user = session.query(User).filter(User.id == 1).first()

# 将User对象从Session中删除
session.delete(user)

# 提交事务，将User对象从数据库中删除
session.commit()

这是SQLAlchemy的一些基础用法，掌握了这些基础用法之后，可以使用SQLAlchemy连接多种数据库、操作数据库。