当前位置：首页 > news >正文

django使用原生SQL查询示例

news 来源：原创 2024/4/29 0:20:30

django使用原生SQL查询示例

实际开发中，在ORM模型查询API不够用或或者数据量比较大的情况下，我们只能使用原始的SQL语句进行查询。

文章目录

django使用原生SQL查询示例
- - 1.raw()方法
  - - 利用RAW方法执行原生的SQL语句
    - RAW()查询可以查询其他表的数据
    - RAW()方法自动将查询字段映射到模型字段
    - 原生SQL使用参数
  - 2.使用extra方法：
  - 3.直接执行原生SQL
  - 补充:

1.raw()方法

raw()管理器方法用于原始的SQL查询，并返回模型的实例。
需要注意的是：raw()语法查询必须包含主键。
这个方法执行原始的SQL查询，并返回一个django.db.models.query.RawQuerySet 实例。这个RawQuerySet 实例可以像一般的QuerySet那样，通过迭代来提供对象实例。

rawQuerySet为惰性查询，只有在使用时才会真正执行

利用RAW方法执行原生的SQL语句

假设现在我们有一个Book与Publish的Model：

class Book(models.Model):
    id = models.AutoField(primary_key=True)
    title = models.CharField(max_length=33)
    price = models.DecimalField(max_digits=8,decimal_places=2)
    publisher = models.ForeignKey(to='Publish',to_field='id',on_delete=models.CASCADE)
    
    def __str__(self):
        return self.title

class Publish(models.Model):
    id = models.AutoField(primary_key=True)
    name = models.CharField(max_length=22)
    city = models.CharField(max_length=20)

增加一条测试路由:

url(r'^raw/',views.raw),

然后使用raw 方法查询:

for book_obj in Book.objects.raw('select * from book_book where price>100'):
    print(book_obj)

RAW()查询可以查询其他表的数据

#注意这里必须select id字段，否则会报错
ret = Book.objects.raw('select id,city from book_publish')
for i in ret:
    print(i.id,i.city)

结果是Publish表的id与city：注意必须要select id，否则会报错

RAW()方法自动将查询字段映射到模型字段

还可以通过translations参数指定一个把查询的字段名和ORM对象实例的字段名互相对应的字典：

dic = {'city':'C'}
    ret = Book.objects.raw('select * from book_publish',translations=dic)
    for i in ret:
        print(i.id,i.name,i.C)

原生SQL使用参数

注意不要自己使用字符串格式化拼接SQL语句，防止SQL注入！

dic = {'city':'C'}
ret = Book.objects.raw('select * from book_publish where id > %s',translations=dic,params=[22,])
for i in ret:
    print(i.id,i.name,i.C)

2.使用extra方法：

extra:结果集修改器，一种提供额外查询参数的机制

Book.objects.filter(publisher='广东人员出版社').extra(where=['price>50'])
Book.objects.filter(publisher='广东人员出版社',price__gt=50)
Book.objects.extra(select={'count':'select count(*) from book_publish'})

# 提供额外的参数
ret = models.Book.objects.all().extra(where=['id > %s'], params=['1'], order_by=['-id'])

3.直接执行原生SQL

以上方法都是基于django模型，很多情况下我们不需要将查询结果映射成模型(model)，或者我们需要执行DELETE、 INSERT以及UPDATE操作。
在这些情况下，我们可以直接访问数据库，完全避开模型层。
我们可以直接从django提供的接口中获取数据库连接，然后像使用pymysql模块一样操作数据库。
注意不要自己使用字符串格式化拼接SQL语句，防止SQL注入！

简单示例:

from django.db import connection,connections
# 获取游标对象
cursor = connection.cursor()  #cursor = connections['default'].cursor()
# 使用原生SQL进行查询
cursor.execute(' select * from book_publish where id > %s ',[22])
# 获取所有的数据
ret = cursor.fetchall()
print(ret)

补充:

在不使用默认数据库下,链接配置

import pymysql
from 项目名.settings import DATABASES


class Database_operat(object):
    def __init__(self, database=DATABASES, database_name='default'):
        database_information = database[database_name]
        try:
            self.db = pymysql.connect(host=database_information['HOST'], user=database_information['USER'], port=database_information['PORT'],
                                      password=database_information['PASSWORD'], db=database_information['NAME'])
            self.cur = self.db.cursor()
        except pymysql.err.OperationalError as e:
            print(e)
            print("连接数据库失败")
            return