基于SQLAlchemy實(shí)現(xiàn)操作MySQL并執(zhí)行原生sql語(yǔ)句
場(chǎng)景應(yīng)用
老大我讓爬取內(nèi)部網(wǎng)站獲取數(shù)據(jù),插入到新建的表中,并每天進(jìn)行爬取更新數(shù)據(jù)(后面做了定時(shí)任務(wù))。然后根據(jù)該表統(tǒng)計(jì)每日的新增數(shù)量/更新數(shù)量進(jìn)行制圖制表,向上級(jí)匯報(bào)。
思路構(gòu)建
選用sqlalchemy+mysqlconnector,連接數(shù)據(jù)庫(kù),創(chuàng)建表,對(duì)指定表進(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ù)庫(kù)信息 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ù)庫(kù) engine_str = "mysql+mysqlconnector://{0}:{1}@{2}:{3}/{4}".format(usernm, passwd, host, port, dbname) # 創(chuàng)建的數(shù)據(jù)庫(kù)引擎 engine = create_engine(engine_str, encoding='utf-8') #創(chuàng)建session類型 DBSession = sessionmaker(bind=engine) # 創(chuàng)建session對(duì)象,進(jìn)行增刪改查: session = DBSession() # 實(shí)例化官宣模型 - 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ù)說(shuō)明') transferTimes = Column(String(32), comment='轉(zhuǎn)派次數(shù)') # 創(chuàng)建更新時(shí)間,對(duì)數(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í) 會(huì)判斷表的存在性 對(duì)于數(shù)據(jù)庫(kù)中不存在的表進(jìn)行創(chuàng)建 已存在的表則可以直接進(jìn)行增刪改查 init_db() ### 首先講一下使用sqlalchemy執(zhí)行原生的sql語(yǔ)句### # 方式一: res = session.execute('select * from ServiceOrder') # res是獲取的對(duì)象 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對(duì)象進(jìn)行增刪改查 ### # 插入單條數(shù)據(jù) # 創(chuàng)建新service0rder對(duì)象 new_serviceorder = ServiceOrder(serviceOrderId='001', serviceDesc='ack', transferTimes='9') # 添加到session session.add(new_serviceorder) # 提交即保存到數(shù)據(jù)庫(kù) 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()
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Python3 shutil(高級(jí)文件操作模塊)實(shí)例用法總結(jié)
在本篇文章里小編給大家整理的是一篇關(guān)于Python3 shutil實(shí)例用法內(nèi)容,有興趣的朋友們可以學(xué)習(xí)下。2020-02-02Python趣味挑戰(zhàn)之turtle庫(kù)繪畫飄落的銀杏樹(shù)
銀杏還是和恐龍同時(shí)代的植物,被稱為活化石,適應(yīng)能力強(qiáng),生長(zhǎng)期漫長(zhǎng),壽命可達(dá)千年.因此,銀杏是長(zhǎng)壽的代表和象征,接下來(lái)用Python的turtle庫(kù)來(lái)繪畫銀杏樹(shù)唯美的一幕,需要的朋友可以參考下2021-05-05python pygame模塊編寫飛機(jī)大戰(zhàn)
這篇文章主要為大家詳細(xì)介紹了python pygame模塊編寫飛機(jī)大戰(zhàn),文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-11-11Python判斷是否json是否包含一個(gè)key的方法
今天小編就為大家分享一篇Python判斷是否json是否包含一個(gè)key的方法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-12-12Python提取Word中圖片的實(shí)現(xiàn)步驟
本文主要介紹了Python提取Word中圖片的實(shí)現(xiàn)步驟,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-07-07