电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

django執行原始查詢sql,并返回Dict字典例子

瀏覽:11日期:2024-10-14 10:39:16

很多時候執行sql語句,數據比django的model來的快,但并不想關心返回的字段,例如你可以執行:select * from product這種sql,這里個方法將會返回與數據庫列名相同的鍵值對 ,格式是這樣子的:

result = [{“id”:1,”name”:”product1”},{“id”:2,”name”:”product2”}]

當然你還可以

import json json.dumps(result )

返回一串json數據,是不是很完美。。。

# coding:utf-8from django.db import connection, transaction’’’執行django原始sql語句 并返回一個數組對象’’’def executeQuery(sql): cursor = connection.cursor() # 獲得一個游標(cursor)對象 cursor.execute(sql) rawData = cursor.fetchall() print rawData col_names = [desc[0] for desc in cursor.description] print col_names result = [] for row in rawData: objDict = {} # 把每一行的數據遍歷出來放到Dict中 for index, value in enumerate(row): print index, col_names[index], value objDict[col_names[index]] = value result.append(objDict) return result

補充知識:重寫django的mysql驅動實現原生sql語句查詢返回字典類型數據

在使用django的時候,有些需求需要特別高的查詢效率,所以需要使用原生的sql語句查詢,但是查詢結果一般是一個元組嵌套元組。為了處理方便,需要從數據庫查詢后直接返回字典類型的數據。

這里使用的方法是繼承django.db.backends.mysql驅動

首先在django項目下創建一個mysql文件夾,然后在這個文件夾下創建base.py。

base.py

from django.db.backends.mysql import basefrom django.db.backends.mysql import featuresfrom django.utils.functional import cached_property class DatabaseFeatures(features.DatabaseFeatures): @cached_property def is_sql_auto_is_null_enabled(self): with self.connection.cursor() as cursor: cursor.execute(’SELECT @@SQL_AUTO_IS_NULL’) result = cursor.fetchone() return result and result[’@@SQL_AUTO_IS_NULL’] == 1 class DatabaseWrapper(base.DatabaseWrapper): features_class = DatabaseFeatures def create_cursor(self, name=None): cursor = self.connection.cursor(self.Database.cursors.DictCursor) return base.CursorWrapper(cursor) @cached_property def mysql_server_info(self): with self.temporary_connection() as cursor: cursor.execute(’SELECT VERSION()’) return cursor.fetchone()[’VERSION()’]

最后在django項目的settings.py文件里修改數據庫配置的數據庫引擎

DATABASES = { ’default’: { ’ENGINE’: ’Test.mysql’, # 指定數據庫驅動為剛剛創建的mysql文件夾 ’NAME’: ’test’, # 指定的數據庫名 ’USER’: ’root’, # 數據庫登錄的用戶名 ’PASSWORD’: ’123456’, # 登錄數據庫的密碼 ’HOST’: ’127.0.0.1’, ’PORT’: ’3306’, # 數據庫服務器端口,mysql默認為3306 ’DATABASE_OPTIONS’: { ’connect_timeout’: 60, ’init_command’: 'SET sql_mode=’STRICT_TRANS_TABLES’', ’charset’: ’utf8mb4’, }, }}

測試

from django.db import connections def f(): search_sql = 'SELECT propertyphotoid,propertyid,alykey FROM lansi_architecture_data.propertyphoto limit 0,5' cursor = connections[’default’].cursor() try: cursor.execute(search_sql) rows = cursor.fetchall() except Exception as e: print(e) rows = 1 print(rows)

輸出結果

[{’propertyphotoid’: 27, ’propertyid’: 0, ’alykey’: ’123456’}, {’propertyphotoid’: 28, ’propertyid’: 10837, ’alykey’: ’Property/6113/207504A1-AC65-4E3B-BE86-538B3807D364’}, {’propertyphotoid’: 29, ’propertyid’: 6113, ’alykey’: ’Property/6113/357A4EAE-750A-4F59-AF01-271B4225CFBD’}, {’propertyphotoid’: 31, ’propertyid’: 6113, ’alykey’: ’Property/6113/6DF1A2C1-F54C-4462-8363-619806A2F085’}, {’propertyphotoid’: 36, ’propertyid’: 6113, ’alykey’: ’Property/6113/572CB245-ABC0-4FD6-8353-729EBD5E5D46’}]

源碼解析:

django.db.utils.ConnectionHandler的__getitem__方法

django執行原始查詢sql,并返回Dict字典例子

獲取連接對象的游標是由DatabaseWrapper類的create_cursor返回的。所以只需要重寫create_cursor方法,就可以更改游標返回的數據類型了。

django.db.backends.mysql.base.DatabaseWrapper類中的create_cursor方法如下:

def create_cursor(self, name=None): cursor = self.connection.cursor() return CursorWrapper(cursor)

到這里,理論上已經完成了重寫目標,但是在測試的時候出錯了,在django.db.backends.mysql.features.DatabaseFeatures里的is_sql_auto_is_null_enabled方法報出KeyError的錯誤。

@cached_property def is_sql_auto_is_null_enabled(self): with self.connection.cursor() as cursor: cursor.execute(’SELECT @@SQL_AUTO_IS_NULL’) result = cursor.fetchone() return result and result[0] == 1

原因是is_sql_auto_is_null_enabled方法使用了重寫后的游標,cursor.execute(’SELECT @@SQL_AUTO_IS_NULL’)返回的結果不是元組,而是一個字典。所以result[0]會報出KeyError的錯誤。重寫is_sql_auto_is_null_enabled方法把result[0]改成result[’@@SQL_AUTO_IS_NULL’]就可以了.

最后還需要把DatabaseWrapper類里的features_class賦值為重寫后的DatabaseFeatures類。

以上這篇django執行原始查詢sql,并返回Dict字典例子就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持好吧啦網。

標簽: Django
主站蜘蛛池模板: 骨龄仪_骨龄检测仪_儿童骨龄测试仪_品牌生产厂家【品源医疗】 | 经济师考试_2025中级经济师报名时间_报名入口_考试时间_华课网校经济师培训网站 | 早报网 | 定制液氮罐_小型气相液氮罐_自增压液氮罐_班德液氮罐厂家 | 天津力值检测-天津管道检测-天津天诚工程检测技术有限公司 | 广东泵阀展|阀门展-广东国际泵管阀展览会 | 洁净实验室工程-成都手术室净化-无尘车间装修-四川华锐净化公司-洁净室专业厂家 | 标准件-非标紧固件-不锈钢螺栓-非标不锈钢螺丝-非标螺母厂家-三角牙锁紧自攻-南京宝宇标准件有限公司 | 热处理温控箱,热处理控制箱厂家-吴江市兴达电热设备厂 | 交通信号灯生产厂家_红绿灯厂家_电子警察监控杆_标志杆厂家-沃霖电子科技 | 不锈钢水管-不锈钢燃气管-卫生级不锈钢管件-不锈钢食品级水管-广东双兴新材料集团有限公司 | 印刷人才网 印刷、包装、造纸,中国80%的印刷企业人才招聘选印刷人才网! | 客服外包专业服务商_客服外包中心_网萌科技 | 钢托盘,钢制托盘,立库钢托盘,金属托盘制造商_南京飞天金属制品实业有限公司 | 佛山商标注册_商标注册代理|专利注册申请_商标注册公司_鸿邦知识产权 | 全国国际化学校_国际高中招生_一站式升学择校服务-国际学校网 | 尊享蟹太太美味,大闸蟹礼卡|礼券|礼盒在线预订-蟹太太官网 | 棕刚玉_白刚玉_铝酸钙-锐石新材料 | 南昌旅行社_南昌国际旅行社_南昌国旅在线 | 标准件-非标紧固件-不锈钢螺栓-非标不锈钢螺丝-非标螺母厂家-三角牙锁紧自攻-南京宝宇标准件有限公司 | 大型工业风扇_工业大风扇_大吊扇_厂房车间降温-合昌大风扇 | 手板-手板模型-手板厂-手板加工-生产厂家,[东莞创域模型] | 电子海图系统-电梯检验系统-智慧供热系统开发-商品房预售资金监管系统 | 低粘度纤维素|混凝土灌浆料|有机硅憎水粉|聚羧酸减水剂-南京斯泰宝 | 【ph计】|在线ph计|工业ph计|ph计厂家|ph计价格|酸度计生产厂家_武汉吉尔德科技有限公司 | 质构仪_鱼糜弹性仪-上海腾拔仪器科技有限公司| 集装箱标准养护室-集装箱移动式养护室-广州璟业试验仪器有限公司 | 数控专用机床,专用机床,自动线,组合机床,动力头,自动化加工生产线,江苏海鑫机床有限公司 | 昆明网络公司|云南网络公司|昆明网站建设公司|昆明网页设计|云南网站制作|新媒体运营公司|APP开发|小程序研发|尽在昆明奥远科技有限公司 | 上海冠顶工业设备有限公司-隧道炉,烘箱,UV固化机,涂装设备,高温炉,工业机器人生产厂家 | 大巴租车平台承接包车,通勤班车,巴士租赁业务 - 鸿鸣巴士 | 振动台-振动试验台-振动冲击台-广东剑乔试验设备有限公司 | 辐射色度计-字符亮度测试-反射式膜厚仪-苏州瑞格谱光电科技有限公司 | 防爆正压柜厂家_防爆配电箱_防爆控制箱_防爆空调_-盛通防爆 | 氢氧化钾厂家直销批发-济南金昊化工有限公司 | 螺旋丝杆升降机-SWL蜗轮-滚珠丝杆升降机厂家-山东明泰传动机械有限公司 | 包塑软管|金属软管|包塑金属软管-闵彬管业 | 济南侦探调查-济南调查取证-山东私家侦探-山东白豹调查咨询公司 密集架|电动密集架|移动密集架|黑龙江档案密集架-大量现货厂家销售 | 济南律师,济南法律咨询,山东法律顾问-山东沃德律师事务所 | 西门子伺服电机维修,西门子电源模块维修,西门子驱动模块维修-上海渠利 | 昊宇水工|河北昊宇水工机械工程有限公司|