这篇文章将为大家详细讲解有关基于sqlalchemy对mysql实现增删改查操作的方法,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
需求场景:
老大让我利用爬虫爬取的数据写到或更新到mysql数据库中,百度了两种方法
1 是使用pymysql连接mysql,通过操作原生的sql语句进行增删改查数据;
2 是使用sqlalchemy连接mysql,通过ORM模型建表并操作数据库,不需要写原生的sql语句,相对简单些;
以下就是本次使用sqlalchemy的经验之谈。
实现流程:连接数据库》通过模型类创建表》建立会话》执行创建表语句》通过会话进行增删改查
from sqlalchemy import exists, Column, Integer, String, ForeignKey, exists
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
# 创建的数据库引擎
engine = create_engine("mysql+pymysql://user:pwd@ip/数据库名?charset=utf8")
#创建session类型
DBSession = sessionmaker(bind=engine)
# 实例化官宣模型 - Base 就是 ORM 模型
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')
serviceDesc = Column(String(268), comment='服务说明')
oneLevelName = Column(String(32), comment='C类别')
twoLevelName = Column(String(32), comment='T子类')
threeLevelName = Column(String(32), comment='I项目')
fourLevelName = Column(String(32), comment='S子项')
transferTimes = Column(String(32), comment='转派次数')
overDueStatus = Column(String(32), comment='过期状态')
serviceTimeLimit = Column(String(32), comment='服务时限')
serTimeLimitTypeName = Column(String(16), comment='时限类型')
# 一对多:
# serviceWorkOrder = relationship("ServiceWorkOrder", backref="serviceorder")
# 多对一:多个服务工单可以属于服务单
class ServiceWorkOrder(Base):
__tablename__ = 'serviceWorkOrderTable'
id = Column(Integer, primary_key=True, autoincrement=True)
serviceWorkOrderId = Column(String(32), nullable=False, index=True, comment='服务工单ID')
workOrderName = Column(String(268), comment='工单名称')
fromId = Column(String(32), comment='服务单ID')
createUserSectionName = Column(String(32), comment='创建人室')
createUserName = Column(String(32), comment='创建人')
handlerName = Column(String(32), comment='处理人')
statusName = Column(String(32), comment='工单状态')
createTime = Column(String(32), comment='创建时间')
# “多”的一方的book表是通过外键关联到user表的:
# serviceOrder_id = Column(Integer, ForeignKey('serviceOrderTable.id'))
# 创建数据库 如果数据库已存在 则不会创建 会根据库名直接连接已有的库
def init_db():
Base.metadata.create_all(engine)
def drop_db():
Base.metadata.drop_all(engine)
def insert_update():
# all_needed_data_lists 是需要插入数据库的数据 格式[{key: value, ... }, { }, { }...]
for item in all_needed_data_lists:
ServiceOrderRow = ServiceOrder(serviceOrderId=item['serviceOrderId'],
serviceDesc=item['serviceDesc'],
oneLevelName=item['oneLevelName'],
twoLevelName=item['twoLevelName'],
threeLevelName=item['threeLevelName'],
fourLevelName=item['fourLevelName'],
transferTimes=item['transferTimes'],
overDueStatus=item['overDueStatus'],
serviceTimeLimit=item['serviceTimeLimit'],
serTimeLimitTypeName=item['serTimeLimitTypeName'],
)
try:
# 利用exists判断目标对象是否存在,返回True或Faults
it_exists = session.query(
exists().where(ServiceOrder.serviceOrderId == item['serviceOrderId'] )
).scalar()
except Exception as e:
self.log.error(e)
break
try:
# 如果不存在,进行新增;存在的话就更新现存的数据
if not it_exists:
session.add(ServiceOrderRow)
else:
session.query(ServiceOrder).filter(ServiceOrder.serviceOrderId == item['serviceOrderId'])\
.update(item)
except Exception as e:
self.log.error(e)
break
try:
session.commit()
self.log.info('数据更新成功!')
except:
session.rollback()
self.log.info('数据更新失败!')
if __name__ == "__main__":
# 创建数据库 如果数据库已存在 则不会创建 会根据库名直接连接已有的库
init_db()
# 创建session对象,进行增删改查:
session = DBSession()
# 利用session 增 改数据 记得提交
insert_update()
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
软考中级精品资料免费领
- 历年真题答案解析
- 备考技巧名师总结
- 高频考点精准押题
- 资料下载
- 历年真题
193.9 KB下载数265
191.63 KB下载数245
143.91 KB下载数1148
183.71 KB下载数642
644.84 KB下载数2756
相关文章
发现更多好内容猜你喜欢
AI推送时光机基于sqlalchemy对mysql实现增删改查操作的方法
数据库2024-04-02
基于sqlalchemy对mysql实现增删改查操作
数据库2022-05-17
node.js对于数据库MySQL基本操作实例总结【增删改查】
数据库2023-05-18
nodejs操作mysql实现增删改查的实例
数据库2022-06-04
Java用jdbc连接实现对MySQL增删改查操作
数据库2023-09-06
nodejs如何操作mysql实现增删改查
数据库2024-04-02
Java实现单链表增删改查的操作方法
数据库2023-06-14
Python对XML文件实现增删改查操作
数据库2022-11-13
python对数据库mysql的操作(增删改查)
数据库2015-11-13
mysql索引如何实现增删改查的操作
数据库2024-04-02
怎么使用Nodejs连接Mysql实现基本的增删改查操作
数据库2023-06-15
详解Nodejs基于mongoose模块的增删改查的操作
数据库2022-06-04
SpringData JPA增删改查操作方法实例分析
数据库2023-07-02
【MySQL系列】表内容的基本操作(增删查改)
数据库2023-08-20
Java使用jdbc连接实现对MySQL增删改查操作的全过程
数据库2023-03-06
PHP+MySQL怎么实现数据库的增删改查操作
数据库2023-05-14
PHP+MySQL如何实现数据库的增删改查操作
数据库2023-07-05
Nodejs如何连接mysql并实现增、删、改、查操作
数据库2024-04-02
如何实现java链表中的基本操作(增、删、查、改)
数据库2020-02-26
咦!没有更多了?去看看其它编程学习网 内容吧