基于sqlalchemy对mysql实现增删改查操作

在Python的Web开发中，SQLAlchemy是一个强大的ORM（对象关系映射）库，它允许开发者用Python对象的方式操作数据库，而无需直接编写SQL语句。本篇将详细讲解如何使用SQLAlchemy与MySQL进行增删改查操作。 我们需要安装SQLAlchemy库，可以通过pip命令进行安装： ```bash pip install sqlalchemy ``` 接下来，我们要建立与MySQL数据库的连接。在Python中，使用`create_engine`函数创建数据库引擎，这里以pymysql为例，提供数据库URL，包括用户名、密码、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模型，这些模型将对应数据库中的表。例如，创建一个`ServiceOrder`和`ServiceWorkOrder`表： ```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, comment='服务单ID') # 其他字段... class ServiceWorkOrder(Base): __tablename__ = 'serviceWorkOrderTable' id = Column(Integer, primary_key=True, autoincrement=True) serviceWorkOrderId = Column(String(32), nullable=False, index=True, comment='服务工单ID') # 其他字段... ``` 现在，我们已经建立了数据库引擎和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的优势更为明显。