使用SQLAlchemy操作數(shù)據(jù)庫(kù)表過程解析
需求場(chǎng)景:
使用sqlalchmy從現(xiàn)有的表中獲取數(shù)據(jù)(不是自己建表)。百度了一下,網(wǎng)上都是使用sqlalchemy自己先創(chuàng)建表,然后導(dǎo)入數(shù)據(jù)表的模型類進(jìn)行增刪改查;現(xiàn)在不是自己建表,該如何操作呢?
操作方案
通過sqlalchmey執(zhí)行原生的sql語句,增刪改查的原生語句攜帶表名,就不需要導(dǎo)入數(shù)據(jù)表的模型類了。
使用的包:
SQLAlchemy (1.3.10) + mysql-connector-python (8.0.19)
提供以下干貨:
- 演示了向原生sql語句傳遞變量的用法 即動(dòng)態(tài)執(zhí)行sql語句 更加靈活
- 通過執(zhí)行原生的sql語句實(shí)現(xiàn)操作已有的表
- 演示了sql語句根據(jù)多字段排序的方法等
DEMO
# -*- coding:utf-8 -*- from sqlalchemy import create_engine,MetaData,Table,exists from sqlalchemy.orm import sessionmaker, scoped_session from util.Log import Log from conf.parseConfig import parseConf # 從配置文件中獲取mysql的配置信息 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) class OpsMysql(object): def __init__(self, log=Log(__file__).getlog()): self.log = log self.session = None try: self.engine = create_engine( engine_str, max_overflow=0, # 超過連接池大小外最多創(chuàng)建的連接 pool_size=5, # 連接池大小 pool_timeout=30, # 池中沒有線程最多等待的時(shí)間,否則報(bào)錯(cuò) pool_recycle=-1, # 多久之后對(duì)線程池中的線程進(jìn)行一次連接的回收(重置) # echo=True, # 顯示相應(yīng)執(zhí)行的 sql 指令 encoding='utf-8' ) SessionFactory = sessionmaker(bind=self.engine) self.session = scoped_session(SessionFactory) except Exception as e: self.log.error(str(e)) self.log.error("Connect {0}@{1}:{2} failed!".format(dbname, host, port)) def get_session(self): return self.session def getEngine(self): return self.engine def init_db(self, base): base.metadata.create_all(self.engine) def drop_db(self, base): base.metadata.drop_all(self.engine) if __name__ == "__main__": log = Log(__file__).getlog() tt = OpsMysql(log) session = tt.get_session() if session: # 通過執(zhí)行原生的sql語句實(shí)現(xiàn)操作已有的表 # 此處演示了向原生sql語句傳遞變量的用法 即動(dòng)態(tài)執(zhí)行sql語句 更加靈活 mail_id = 1 res = session.execute('select * from tbl_mail_addr where mail_id='" + mail_id + "' and mail_tp="c"') res01 = res.fetchall() # 結(jié)果是列表 print(res01[0]) # (1, 'c', 1, 'XX@u163.com') mail_id = '1' mail_type = 'c' # 查詢id為1,類型是c的郵箱信息,并按mail_tp降序,addr_no升序排列,限制查詢數(shù)量100 sql = "select * from tbl_mail_addr where tbl_mail_addr.oper_flag='1' and tbl_mail_addr.mail_id='" + mail_id + "' and tbl_mail_addr.mail_tp='" + mail_type + "' order by tbl_mail_addr.mail_tp, tbl_mail_addr.addr_no ASC limit 100" result = session.execute(sql) value_list = result.fetchall() print(value_list) # [(1, 'c', 1, 'XX@163.com'), (1, 'c', 2, 'XX@qq.com), (1, 'c', 3, 'XX@qq.com')] session.close()
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- 基于sqlalchemy對(duì)mysql實(shí)現(xiàn)增刪改查操作
- Python sqlalchemy時(shí)間戳及密碼管理實(shí)現(xiàn)代碼詳解
- Python Sqlalchemy如何實(shí)現(xiàn)select for update
- Python SQLAlchemy庫(kù)的使用方法
- Python流行ORM框架sqlalchemy的簡(jiǎn)單使用
- python實(shí)現(xiàn)sqlalchemy的使用概述
- Python?ORM框架之SQLAlchemy?的基礎(chǔ)用法
- python中SQLAlchemy使用前端頁(yè)面實(shí)現(xiàn)插入數(shù)據(jù)
相關(guān)文章
Python基于正則表達(dá)式實(shí)現(xiàn)文件內(nèi)容替換的方法
這篇文章主要介紹了Python基于正則表達(dá)式實(shí)現(xiàn)文件內(nèi)容替換的方法,涉及Python文件、目錄及字符串正則替換等相關(guān)操作技巧,需要的朋友可以參考下2017-08-08Pycharm及python安裝詳細(xì)步驟及PyCharm配置整理(推薦)
這篇文章主要介紹了Pycharm及python安裝詳細(xì)步驟以及PyCharm配置整理,本文通過圖文并茂的形式給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-04-04python 簡(jiǎn)單備份文件腳本v1.0的實(shí)例
下面小編就為大家?guī)硪黄猵ython 簡(jiǎn)單備份文件腳本v1.0的實(shí)例。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧,希望對(duì)大家有所幫助2017-11-11利用Python搶回在螞蟻森林逝去的能量(實(shí)現(xiàn)代碼)
螞蟻森林是一項(xiàng)旨在帶動(dòng)公眾低碳減排的公益項(xiàng)目,每個(gè)人的低碳行為在螞蟻森林里可計(jì)為"綠色能量",很多小伙伴都玩過,今天小編給大家分享一篇教程關(guān)于Python搶回在螞蟻森林逝去的能量,感興趣的朋友跟隨小編一起看看吧2022-03-03python實(shí)現(xiàn)簡(jiǎn)單遺傳算法
這篇文章主要為大家詳細(xì)介紹了python實(shí)現(xiàn)簡(jiǎn)單的遺傳算法,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-03-03Python Request類源碼實(shí)現(xiàn)方法及原理解析
這篇文章主要介紹了Python Request類源碼實(shí)現(xiàn)方法及原理解析,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-08-08詳解K-means算法在Python中的實(shí)現(xiàn)
這篇文章主要介紹了詳解K-means算法在Python中的實(shí)現(xiàn),具有一定借鑒價(jià)值,需要的朋友可以了解下。2017-12-12Python pandas dataframe之重命名相同列名
這篇文章主要介紹了Python pandas dataframe之重命名相同列名方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-09-09Pygame與OpenCV聯(lián)合播放視頻并保證音畫同步
Pygame的Movie模塊已經(jīng)廢棄多年,本文主要介紹了Pygame與OpenCV聯(lián)合播放視頻并保證音畫同步,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-12-12