【Python】使用SQLAlchemy操作Mysql数据库

from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import sessionmaker
 
# 定义数据库连接字符串（这里需要替换为你的数据库用户名、密码、数据库名）
DATABASE_URI = 'mysql+pymysql://username:password@localhost/database_name'
 
# 创建引擎
engine = create_engine(DATABASE_URI)
 
# 创建会话
Session = sessionmaker(bind=engine)
session = Session()
 
# 定义模型
Base = declarative_base()
 
class User(Base):
    __tablename__ = 'users'
 
    id = Column(Integer, primary_key=True)
    name = Column(String)
 
    def __repr__(self):
        return f'<User(id={self.id}, name={self.name})>'
 
# 创建表格
Base.metadata.create_all(engine)
 
# 示例：插入数据
new_user = User(name='Alice')
session.add(new_user)
session.commit()
 
# 查询数据
users = session.query(User).all()
for user in users:
    print(user)
 
# 关闭会话
session.close()

这段代码展示了如何使用SQLAlchemy连接到MySQL数据库，定义模型，创建表格，以及执行简单的数据插入和查询操作。需要注意的是，你需要根据你的数据库配置替换DATABASE_URI中的username、password和database_name。