SQLAlchemy是Python中流行的开源ORM工具，能以面向对象方式操作数据库，且提供统一接口连接和操作多种数据库，以下是在PostgreSQL、SQLite上开发及扩展到其他数据库的方法。 ### 在PostgreSQL上开发 使用SQLAlchemy连接PostgreSQL，需要安装`psycopg2`驱动，然后通过创建引擎连接数据库。 ```python from sqlalchemy import create_engine, Column, Integer, String from sqlalchemy.orm import sessionmaker from sqlalchemy.ext.declarative import declarative_base # 创建引擎 engine = create_engine('postgresql://user:password@host:port/database_name') # 创建会话 Session = sessionmaker(bind=engine) session = Session() # 创建基类 Base = declarative_base() # 定义模型 class User(Base): __tablename__ = 'users' id = Column(Integer, primary_key=True) name = Column(String) # 创建表 Base.metadata.create_all(engine) # 插入数据 new_user = User(name='John') session.add(new_user) session.commit() # 查询数据 users = session.query(User).all() for user in users: print(user.name) ``` ### 在SQLite上开发 SQLite是轻量级数据库，SQLAlchemy连接它无需额外驱动。 ```python from sqlalchemy import create_engine, Column, Integer, String from sqlalchemy.orm import sessionmaker from sqlalchemy.ext.declarative import declarative_base # 创建引擎 engine = create_engine('sqlite:///test.db') # 创建会话 Session = sessionmaker(bind=engine) session = Session() # 创建基类 Base = declarative_base() # 定义模型 class Book(Base): __tablename__ = 'books' id = Column(Integer, primary_key=True) title = Column(String) # 创建表 Base.metadata.create_all(engine) # 插入数据 new_book = Book(title='Python Basics') session.add(new_book) session.commit() # 查询数据 books = session.query(Book).all() for book in books: print(book.title) ``` ### 扩展到其他数据库 SQLAlchemy提供统一接口，只需修改引擎的连接字符串就能扩展到其他数据库。 - **MySQL**：需安装`mysql-connector-python`或`pymysql`驱动。 ```python engine = create_engine('mysql+pymysql://user:password@host:port/database_name') ``` - **Oracle**：需安装`cx_Oracle`驱动。 ```python engine = create_engine('oracle+cx_oracle://user:password@host:port/service_name') ``` SQLAlchemy以统一方式操作不同数据库，开发者可专注业务逻辑，降低数据库耦合性，提高代码可移植性[^1][^2]。