SQLAlchemy的基本用法有哪些？

<think>好的，用户想了解SQLAlchemy的基本用法。首先，我需要回忆一下SQLAlchemy的核心概念和常用功能。根据用户提供的引用内容，特别是引用[1]、[2]、[3]、[4]，里面提到了Sqlalchemy的Query对象、数据类型、relationship、原生SQL使用，以及安装连接和ORM与Core API的区别。 用户可能刚接触SQLAlchemy，需要从基础开始讲解。首先应该介绍SQLAlchemy的两个主要组件：ORM和Core。然后按照步骤说明如何安装、连接数据库，接着是定义模型类，进行基本的CRUD操作。可能还需要提到使用原生SQL的方法，因为引用[1]和[4]提到了这点。 需要注意的是，用户提供的引用中有提到SQLAlchemy 2.0的变化，所以需要确保信息是最新的，特别是关于创建引擎和会话的部分。例如，在SQLAlchemy 2.0中，sessionmaker可能被async_sessionmaker取代，但用户可能还是使用同步方式，所以需要确认正确的方法。 另外，用户的问题是关于基本用法，所以不需要深入高级功能，但可以简要提及性能优化或常见问题，比如连接池配置或者事务处理。同时，根据引用[3]，安装和连接是基础步骤，必须详细说明。 可能还需要区分ORM和Core API的使用场景，因为引用[2]和[3]提到了两者。但用户可能更关注ORM部分，因为这是更常见的用法。不过，根据引用[1]，用户可能也需要知道如何使用原生SQL，所以应该包括这部分内容。 接下来，结构需要清晰，分步骤讲解：安装、连接、定义模型、创建会话、CRUD操作、事务处理，最后是原生SQL的使用。每个步骤给出示例代码，并确保代码符合SQLAlchemy 2.0的语法，比如使用`create_engine`的参数是否正确，是否使用了新的声明式基类方式（如`DeclarativeBase`）。 还需要检查引用中的信息是否一致，例如引用[4]提到使用`create_engine`时的URL格式，而引用[3]可能提到安装步骤，需要整合这些内容。同时，确保示例代码中的导入语句正确，比如从`sqlalchemy.orm`导入`Session`而不是`scoped_session`，除非需要更复杂的会话管理。 最后，生成相关问题时要覆盖用户可能进一步想知道的内容，比如性能优化、异步支持、模型关系处理等，参考引用中的内容，比如relationship的使用（引用[1]）和Core API（引用[2]）的区别。</think>### SQLAlchemy 基本用法教程 #### 一、核心组件与工作原理 SQLAlchemy 提供两个主要组件： 1. **ORM（对象关系映射）**：通过类与数据库表映射，实现面向对象操作 2. **Core（SQL表达式语言）**：直接使用SQL表达式进行数据库操作 推荐优先学习ORM模式，适合大多数应用场景[^3]。 #### 二、基础使用步骤 **1. 安装与连接数据库** ```python # 安装（支持Python3.8+） pip install sqlalchemy pymysql # 创建数据库引擎（以MySQL为例） from sqlalchemy import create_engine engine = create_engine('mysql+pymysql://用户名:密码@IP:3306/数据库名?charset=utf8mb4', echo=True) # echo=True显示生成SQL ``` **2. 定义数据模型** ```python from sqlalchemy.orm import DeclarativeBase from sqlalchemy import Column, Integer, String class Base(DeclarativeBase): pass class User(Base): __tablename__ = 'users' id = Column(Integer, primary_key=True) name = Column(String(30)) age = Column(Integer) # 创建表结构 Base.metadata.create_all(engine) ``` **3. 创建会话工厂** ```python from sqlalchemy.orm import sessionmaker Session = sessionmaker(bind=engine) ``` **4. 基本CRUD操作** ```python # 新增数据 with Session() as session: new_user = User(name='张三', age=25) session.add(new_user) session.commit() # 查询数据 with Session() as session: users = session.query(User).filter(User.age > 20).all() for u in users: print(f"{u.id}: {u.name}") # 更新数据 with Session() as session: user = session.query(User).filter_by(name='张三').first() user.age = 26 session.commit() # 删除数据 with Session() as session: user = session.query(User).filter_by(name='张三').first() session.delete(user) session.commit() ``` #### 三、高级功能 1. **使用原生SQL** ```python with engine.connect() as conn: result = conn.execute(text("SELECT * FROM users WHERE age > :age"), {"age": 20}) for row in result: print(row) ``` 2. **关系映射** ```python class Order(Base): __tablename__ = 'orders' id = Column(Integer, primary_key=True) user_id = Column(Integer, ForeignKey('users.id')) amount = Column(Integer) user = relationship("User", back_populates="orders") User.orders = relationship("Order", back_populates="user") ``` #### 四、事务管理 ```python with Session() as session: try: # 操作1 session.add(User(name='李四', age=30)) # 操作2 session.execute(text("UPDATE users SET age=age+1")) session.commit() except: session.rollback() raise ``` #### 五、最佳实践建议 1. 使用上下文管理器管理会话生命周期 2. 批量操作时使用`session.bulk_save_objects()`提升性能 3. 生产环境配置连接池参数： ```python engine = create_engine(url, pool_size=5, max_overflow=10, pool_timeout=30) ```