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

作者:路痴队长 时间:2024-01-18 17:16:05 

场景应用

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

思路构建

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


from sqlalchemy import exists, Column, Integer, String, ForeignKey, DateTime, Text, func
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from 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('select * from ServiceOrder') # res是获取的对象
 all_res_list = res.fetchall() # all_res_list具体的结果 是列表
 print(all_res_list ) # 结果: [('数据提取',), ('非数据提取',)]
 # 方式二:
 conn = engine.connect()
 res = conn.execute('select * 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').update({"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').delete()
 # 或则
 update_objkp = session.query(ServiceOrder).filter(ServiceOrder.serviceDesc == 'Mack').one()
 update_objkp.delete()
 session.commit()
 session.close()

来源:https://www.cnblogs.com/We612/p/12242227.html

标签:SQLAlchemy,MySQL,sql,操作
0
投稿

猜你喜欢

  • Python利用format函数实现对齐打印(左对齐、右对齐与居中对齐)

    2021-07-30 05:16:16
  • python中的断言(assert语句)

    2022-05-21 12:04:56
  • Golang字符串常用函数的使用

    2024-02-11 03:57:35
  • python中用ctypes模拟点击的实例讲解

    2023-10-29 23:18:42
  • MySQL mysqladmin客户端的使用简介

    2024-01-26 00:33:29
  • python http通信接口开发示例

    2022-06-07 05:15:29
  • mysql常用命令行操作语句

    2024-01-12 23:51:20
  • IDEA连接不上MySQL端口号占用的解决

    2024-01-24 14:49:21
  • 深入浅析python的第三方库pandas

    2021-06-05 03:13:03
  • MySql登录时闪退的快速解决办法

    2024-01-24 06:19:28
  • python 多线程中join()的作用

    2022-11-27 12:24:24
  • PHP如何从txt文件中读取数据详解

    2023-11-15 02:37:32
  • 浅谈python str.format与制表符\\t关于中文对齐的细节问题

    2023-05-23 00:39:56
  • python实现nao机器人身体躯干和腿部动作操作

    2021-07-02 07:39:47
  • PHP版微信小店接口开发实例

    2023-11-10 11:56:06
  • python可视化大屏库big_screen示例详解

    2021-10-16 14:32:39
  • 用openCV和Python 实现图片对比,并标识出不同点的方式

    2023-08-31 09:30:55
  • scrapy-redis的安装部署步骤讲解

    2023-03-18 11:53:41
  • MySQL数据库备份以及常用备份工具集合

    2024-01-23 04:25:53
  • z-index在IE中的迷惑

    2007-05-11 16:50:00
  • asp之家 网络编程 m.aspxhome.com