欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

基于SQLAlchemy實現(xiàn)操作MySQL并執(zhí)行原生sql語句

 更新時間:2020年06月10日 15:30:43   作者:路癡隊長  
這篇文章主要介紹了基于SQLAlchemy實現(xiàn)操作MySQL并執(zhí)行原生sql語句,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下

場景應(yīng)用

老大我讓爬取內(nèi)部網(wǎng)站獲取數(shù)據(jù),插入到新建的表中,并每天進(jìn)行爬取更新數(shù)據(jù)(后面做了定時任務(wù))。然后根據(jù)該表統(tǒng)計每日的新增數(shù)量/更新數(shù)量進(jìn)行制圖制表,向上級匯報。

思路構(gòu)建

選用sqlalchemy+mysqlconnector,連接數(shù)據(jù)庫,創(chuàng)建表,對指定表進(jìn)行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

# 從配置文件中獲取數(shù)據(jù)庫信息
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')
# 連接數(shù)據(jù)庫
engine_str = "mysql+mysqlconnector://{0}:{1}@{2}:{3}/{4}".format(usernm, passwd, host, port, dbname)
# 創(chuàng)建的數(shù)據(jù)庫引擎
engine = create_engine(engine_str, encoding='utf-8')

#創(chuàng)建session類型
DBSession = sessionmaker(bind=engine)
# 創(chuàng)建session對象,進(jìn)行增刪改查:
session = DBSession()

# 實例化官宣模型 - Base 就是 ORM 模型
Base = declarative_base()


# 創(chuàng)建服務(wù)單表 繼承Base基類
class ServiceOrder(Base):
  __tablename__ = 'serviceOrderTable'
  serviceOrderId = Column(String(32), primary_key=True, comment='服務(wù)單ID')
  serviceDesc = Column(String(512), comment='服務(wù)說明')
  transferTimes = Column(String(32), comment='轉(zhuǎn)派次數(shù)')
  # 創(chuàng)建更新時間,對數(shù)據(jù)的更新進(jìn)行記錄
  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__":
  # 每次執(zhí)行時 會判斷表的存在性 對于數(shù)據(jù)庫中不存在的表進(jìn)行創(chuàng)建 已存在的表則可以直接進(jìn)行增刪改查
  init_db()

  ### 首先講一下使用sqlalchemy執(zhí)行原生的sql語句###
  # 方式一:
  res = session.execute('select * from ServiceOrder') # res是獲取的對象
  all_res_list = res.fetchall() # all_res_list具體的結(jié)果 是列表
  print(all_res_list ) # 結(jié)果: [('數(shù)據(jù)提取',), ('非數(shù)據(jù)提取',)]
  # 方式二:
  conn = engine.connect()
  res = conn.execute('select * from ServiceOrder') 
  all_res_list = res.fetchall()

  ### 使用創(chuàng)建好的session對象進(jìn)行增刪改查 ###
  # 插入單條數(shù)據(jù)
  # 創(chuàng)建新service0rder對象
  new_serviceorder = ServiceOrder(serviceOrderId='001', serviceDesc='ack', transferTimes='9')
  # 添加到session
  session.add(new_serviceorder)
  # 提交即保存到數(shù)據(jù)庫
  session.commit()

  # 插入多條數(shù)據(jù)
  serviceorder_list = [ServiceOrder(serviceOrderId='002', serviceDesc='好的', transferTimes='9'),ServiceOrder(serviceOrderId='003', serviceDesc='起床', transferTimes='9')]
  session.add_all(serviceorder_list)
  session.commit()
  # session.close()

  # 查詢
  # 查詢是否存在 結(jié)果是布爾值
  it_exists = session.query(
    exists().where(ServiceOrder.serviceOrderId == '002')
  ).scalar()
  # 創(chuàng)建Query查詢,filter是where條件
  # 調(diào)用one() first()返回唯一行,如果調(diào)用all()則已列表的形式返回所有行:
  server_order = session.query(ServiceOrder).filter(ServiceOrder.serviceOrderId == '003').first()
  print(server_order.serviceDesc)
  serciceorders = session.query(ServiceOrder).filter(ServiceOrder.serviceDesc == '好的').all()

  # 改 更新數(shù)據(jù)
  # 數(shù)據(jù)更新,將值為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()

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

  • Python中正則表達(dá)式詳解

    Python中正則表達(dá)式詳解

    Python 的 re 模塊(Regular Expression 正則表達(dá)式)提供各種正則表達(dá)式的匹配操作,Python 會將正則表達(dá)式轉(zhuǎn)化為字節(jié)碼,利用 C 語言的匹配引擎進(jìn)行深度優(yōu)先的匹配。
    2017-05-05
  • python素數(shù)篩選法淺析

    python素數(shù)篩選法淺析

    這篇文章主要為大家詳細(xì)介紹了python素數(shù)篩選法的相關(guān)資料,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2018-03-03
  • Python3 shutil(高級文件操作模塊)實例用法總結(jié)

    Python3 shutil(高級文件操作模塊)實例用法總結(jié)

    在本篇文章里小編給大家整理的是一篇關(guān)于Python3 shutil實例用法內(nèi)容,有興趣的朋友們可以學(xué)習(xí)下。
    2020-02-02
  • 利用Python獲取趕集網(wǎng)招聘信息前篇

    利用Python獲取趕集網(wǎng)招聘信息前篇

    這篇文章主要為大家分享了如何利用Python獲取趕集網(wǎng)招聘信息的前一篇內(nèi)容,感興趣的小伙伴們可以參考一下
    2016-04-04
  • Python趣味挑戰(zhàn)之turtle庫繪畫飄落的銀杏樹

    Python趣味挑戰(zhàn)之turtle庫繪畫飄落的銀杏樹

    銀杏還是和恐龍同時代的植物,被稱為活化石,適應(yīng)能力強(qiáng),生長期漫長,壽命可達(dá)千年.因此,銀杏是長壽的代表和象征,接下來用Python的turtle庫來繪畫銀杏樹唯美的一幕,需要的朋友可以參考下
    2021-05-05
  • python pygame模塊編寫飛機(jī)大戰(zhàn)

    python pygame模塊編寫飛機(jī)大戰(zhàn)

    這篇文章主要為大家詳細(xì)介紹了python pygame模塊編寫飛機(jī)大戰(zhàn),文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2018-11-11
  • Python判斷是否json是否包含一個key的方法

    Python判斷是否json是否包含一個key的方法

    今天小編就為大家分享一篇Python判斷是否json是否包含一個key的方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2018-12-12
  • 在TensorFlow中屏蔽warning的方式

    在TensorFlow中屏蔽warning的方式

    今天小編就為大家分享一篇在TensorFlow中屏蔽warning的方式,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-02-02
  • 用python登錄Dr.com思路以及代碼分享

    用python登錄Dr.com思路以及代碼分享

    如今一般的大學(xué)校園或者公寓都是通過客戶端來限制路由器使用,基本上都是Dr.com客戶端,有的是登錄樣式,有的是插件樣式。下面我們來說說python定制自己的客戶端
    2014-06-06
  • Python提取Word中圖片的實現(xiàn)步驟

    Python提取Word中圖片的實現(xiàn)步驟

    本文主要介紹了Python提取Word中圖片的實現(xiàn)步驟,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2022-07-07

最新評論