使用SQLAlchemy连接SQLite数据库
时间: 2024-09-30 18:12:42 浏览: 37
Python使用sqlalchemy模块连接数据库操作示例
SQLAlchemy是一个强大的Python ORM (Object-Relational Mapping) 框架,它允许开发者通过Python代码操作SQL数据库,而无需直接编写SQL查询。连接SQLite数据库到SQLAlchemy的过程相对简单,以下是基本步骤:
1. 安装SQLAlchemy:首先需要安装 SQLAlchemy 和 sqlite3 库,可以使用 pip 进行安装:
```
pip install sqlalchemy
```
2. 导入库并创建引擎:在 Python 中,你需要导入 `create_engine` 函数来创建数据库引擎。SQLite 数据库通常只需要一个文件名作为参数:
```python
from sqlalchemy import create_engine
engine = create_engine('sqlite:///example.db')
```
上面的代码将创建一个指向名为 "example.db" 的SQLite数据库的连接。
3. 创建映射模型:根据SQLite表结构,你可以定义 SQLAlchemy 类型的模型来表示数据库中的表。例如,如果有一个用户表:
```python
from sqlalchemy import Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
class User(Base):
__tablename__ = 'users'
id = Column(Integer, primary_key=True)
name = Column(String)
email = Column(String)
```
4. 创建表:使用 `Base.metadata.create_all(engine)` 来根据模型创建或更新数据库表:
```python
Base.metadata.create_all(engine)
```
5. 执行CRUD操作:现在你可以使用 Session 对象(`from sqlalchemy.orm import sessionmaker`)来进行增删改查操作,如获取、插入、更新和删除数据:
```python
Session = sessionmaker(bind=engine)
session = Session()
# 插入数据
new_user = User(name='Alice', email='alice@example.com')
session.add(new_user)
session.commit()
# 查询数据
users = session.query(User).all()
```
阅读全文