使用sqlalchemy进行MySQL的增删改查操作
5星
- 浏览量: 0
- 大小:None
- 文件类型：PDF
简介：
简介：本文介绍如何利用SQLAlchemy这一强大的ORM框架执行MySQL数据库的基本CRUD（创建、读取、更新和删除）操作，帮助开发者简化数据处理流程。
在Python的Web开发中，SQLAlchemy是一个强大的ORM（对象关系映射）库，它允许开发者用Python对象的方式操作数据库，而无需直接编写SQL语句。本篇将详细讲解如何使用SQLAlchemy与MySQL进行增删改查操作。
首先需要安装SQLAlchemy库，可以通过pip命令进行安装：
```bash
pip install sqlalchemy
```
接下来，我们要建立与MySQL数据库的连接。在Python中，使用`create_engine`函数创建数据库引擎，并提供相应的参数来指定用户名、密码、IP地址等信息。
```python
from sqlalchemy import create_engine
engine = create_engine(mysql+pymysql://user:pwd@ip/数据库名?charset=utf8)
```
为了更方便地操作数据库，我们可以使用`sessionmaker`创建一个配置过的`Session`类：
```python
from sqlalchemy.orm import sessionmaker
DBSession = sessionmaker(bind=engine)
```
然后定义ORM模型。这些模型将对应数据库中的表。
```python
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
class ServiceOrder(Base):
__tablename__ = serviceOrderTable
id = Column(Integer, primary_key=True, autoincrement=True)
serviceOrderId = Column(String(32), nullable=False, index=True)
# 其他字段...
class ServiceWorkOrder(Base):
__tablename__ = serviceWorkOrderTable
id = Column(Integer, primary_key=True, autoincrement=True)
serviceWorkOrderId = Column(String(32), nullable=False, index=True)
# 其他字段...
```
现在，我们已经建立了数据库引擎和ORM模型，接下来就可以进行增删改查操作了。
**增加（Insert）**
```python
# 创建Session实例
session = DBSession()
# 创建对象实例
new_order = ServiceOrder(serviceOrderId=test_id, ...)
# 插入数据
session.add(new_order)
# 提交事务
session.commit()
```
**查询（Select）**
```python
# 查询所有服务单
orders = session.query(ServiceOrder).all()
# 根据ID查询
order = session.query(ServiceOrder).filter_by(serviceOrderId=test_id).first()
# 使用exists()判断是否存在某个ID的服务单
if session.query(exists().where(ServiceOrder.serviceOrderId == test_id)).scalar():
print(服务单存在)
else:
print(服务单不存在)
```
**修改（Update）**
```python
# 获取要修改的对象
order = session.query(ServiceOrder).filter_by(serviceOrderId=test_id).first()
# 修改属性
order.serviceDesc = 新服务说明
# 提交修改
session.commit()
```
**删除（Delete）**
```python
# 获取要删除的对象
order = session.query(ServiceOrder).filter_by(serviceOrderId=test_id).first()
# 删除对象
session.delete(order)
# 提交事务
session.commit()
```
以上就是基于SQLAlchemy对MySQL实现增删改查的基本步骤。通过这种方式，我们可以避免直接编写SQL语句，使得数据库操作更加简洁和易读。需要注意的是，在每次操作后都要记得提交事务（`session.commit()`），否则更改不会保存到数据库中。同时，操作完毕后记得关闭Session以释放资源：
```python
session.close()
```
使用SQLAlchemy进行数据库操作不仅简化了代码，还提高了代码的可读性和可维护性，尤其在复杂的业务逻辑中，ORM的优势更为明显。
全部评论 (0)
