基于SQLAlchemy实现操作MySQL并执行原生sql语句

本文整理自网络，侵删。

场景应用

老大我让爬取内部网站获取数据，插入到新建的表中，并每天进行爬取更新数据（后面做了定时任务）。然后根据该表统计每日的新增数量/更新数量进行制图制表，向上级汇报。

思路构建

选用sqlalchemy+mysqlconnector，连接数据库，创建表，对指定表进行CRUD

from sqlalchemy import exists, Column, Integer, String, ForeignKey, DateTime, Text, funcfrom sqlalchemy.ext.declarative import declarative_basefrom sqlalchemy import create_enginefrom sqlalchemy.orm import sessionmakerfrom conf.parseConfig import parseConf# 从配置文件中获取数据库信息host = parseConf.get_conf('MySQLInfo', 'host')port = parseConf.get_conf('MySQLInfo', 'port')dbname = parseConf.get_conf('MySQLInfo', 'dbname')usernm = parseConf.get_conf('MySQLInfo', 'usernm')passwd = parseConf.get_conf('MySQLInfo', 'passwd')# 连接数据库engine_str = "mysql+mysqlconnector://{0}:{1}@{2}:{3}/{4}".format(usernm, passwd, host, port, dbname)# 创建的数据库引擎engine = create_engine(engine_str, encoding='utf-8')#创建session类型DBSession = sessionmaker(bind=engine)# 创建session对象，进行增删改查:session = DBSession()# 实例化官宣模型 - Base 就是 ORM 模型Base = declarative_base()# 创建服务单表 继承Base基类class ServiceOrder(Base):  __tablename__ = 'serviceOrderTable'  serviceOrderId = Column(String(32), primary_key=True, comment='服务单ID')  serviceDesc = Column(String(512), comment='服务说明')  transferTimes = Column(String(32), comment='转派次数')  # 创建更新时间，对数据的更新进行记录  updateTime = Column(DateTime, server_default=func.now(), onupdate=func.now())def init_db():  Base.metadata.create_all(engine)def drop_db():  Base.metadata.drop_all(engine)if __name__ == "__main__":  # 每次执行时 会判断表的存在性 对于数据库中不存在的表进行创建 已存在的表则可以直接进行增删改查  init_db()  ### 首先讲一下使用sqlalchemy执行原生的sql语句###  # 方式一：  res = session.execute('ｓｅｌｅｃｔ * from ServiceOrder') # res是获取的对象  all_res_list = res.fetchall() # all_res_list具体的结果 是列表  print(all_res_list ) # 结果： [('数据提取',), ('非数据提取',)]  # 方式二：  conn = engine.connect()  res = conn.execute('ｓｅｌｅｃｔ * from ServiceOrder')   all_res_list = res.fetchall()  ### 使用创建好的session对象进行增删改查 ###  # 插入单条数据  # 创建新service0rder对象  new_serviceorder = ServiceOrder(serviceOrderId='001', serviceDesc='ack', transferTimes='9')  # 添加到session  session.add(new_serviceorder)  # 提交即保存到数据库  session.commit()  # 插入多条数据  serviceorder_list = [ServiceOrder(serviceOrderId='002', serviceDesc='好的', transferTimes='9'),ServiceOrder(serviceOrderId='003', serviceDesc='起床', transferTimes='9')]  session.add_all(serviceorder_list)  session.commit()  # session.close()  # 查询  # 查询是否存在 结果是布尔值  it_exists = session.query(    exists().where(ServiceOrder.serviceOrderId == '002')  ).scalar()  # 创建Query查询，filter是where条件  # 调用one() first()返回唯一行，如果调用all()则已列表的形式返回所有行:  server_order = session.query(ServiceOrder).filter(ServiceOrder.serviceOrderId == '003').first()  print(server_order.serviceDesc)  serciceorders = session.query(ServiceOrder).filter(ServiceOrder.serviceDesc == '好的').all()  # 改 更新数据  # 数据更新，将值为Mack的serviceDesc修改为Danny  update_obj = session.query(ServiceOrder).filter(ServiceOrder.serviceDesc == 'Mack').ｕｐｄａｔｅ({"serviceDesc": "Danny"})  # 或则  update_objp = session.query(ServiceOrder).filter(ServiceOrder.serviceDesc == 'Mack').first()  update_objp.serviceDesc = 'Danny'  session.commit()  # 删除  update_objk = session.query(ServiceOrder).filter(ServiceOrder.serviceDesc == 'Mack').ｄｅｌｅｔｅ()  # 或则  update_objkp = session.query(ServiceOrder).filter(ServiceOrder.serviceDesc == 'Mack').one()  update_objkp.ｄｅｌｅｔｅ()  session.commit()  session.close()

标签：SQL

相关阅读 >>

sqlserver 注释符 单行注释与多行注释

用sql批量插入数据的存储过程

复习一下sql server的差异备份

mysql运行sql文件时出现问题怎么办

删除索引的sql语句是什么

sql语句批量添加数据的方法是什么

经常使用的jdbc连接数据库方式

sql语言中,删除一个表的命令是什么

sql修改语句是什么

sql插入记录的命令是什么

更多相关阅读请进入《sql》频道 >>

书籍

数据库系统概念 第6版

￥41.1元   机械工业出版社

本书主要讲述了数据模型、基于对象的数据库和XML、数据存储和查询、事务管理、体系结构等方面的内容。