Django执行原生SQL查询的两种实现方式
本文介绍Django中执行原生SQL查询的两种核心方式：使用Manager.raw()方法返回模型实例，以及绕过模型层直接操作数据库连接。详细讲解了字段映射、参数化查询、索引访问及指定数据库连接等关键用法，帮助开发者灵活处理复杂SQL需求。
执行原生 SQL 查询
在 Django 框架中，开发者可以通过两种主要途径来执行原生 SQL 语句：
- 第一种是利用 Manager.raw() 方法执行原生查询，该方法会返回对应的模型实例。
- 第二种是完全跳过模型层，直接执行自定义的 SQL 语句。
1、执行原生查询
通过管理器提供的 raw() 方法，可以执行原生 SQL 查询并获取模型实例：
Manager.raw(raw_query, params=None, translations=None)
该方法接收一个原生 SQL 字符串作为参数，执行该语句后返回一个 django.db.models.query.RawQuerySet 对象。这个 RawQuerySet 对象的行为与普通 QuerySet 类似，支持迭代以获取具体的对象实例。
1.1 普通查询
class Person(models.Model):
first_name = models.CharField(...)
last_name = models.CharField(...)
birth_date = models.DateField(...)
你可以按照如下示例执行自定义 SQL：
for p in Person.objects.raw('SELECT * FROM app_person'): # django默认的表名是app名加类名
print(p)
# 没有查询到就报错
1.2 将查询字段映射为模型字段
raw() 方法会自动将查询语句中的字段名映射到模型中对应的字段名。需要注意的是，查询语句中字段的排列顺序并不重要。换句话说，以下两种查询写法在功能上是一致的：
Person.objects.raw('SELECT id, first_name, last_name, birth_date FROM app_person')
Person.objects.raw('SELECT last_name, birth_date, first_name, id FROM app_person')
这种匹配是基于字段名称进行的。因此，你可以利用 SQL 的 AS 子句将查询结果中的字段映射到模型字段上。例如，如果数据表中包含 Person 相关数据，你可以方便地将其映射到 Person 实例中：
>>> Person.objects.raw('''SELECT first AS first_name,
... last AS last_name,
... bd AS birth_date,
... pk AS id,
... FROM app_person''')
只要字段名称匹配，模型实例就能被正确创建。
此外，你还可以使用 raw() 方法的 translations 参数来显式指定查询字段到模型字段的映射关系。这是一个字典，用于将查询语句中的字段名映射至模型字段名。例如，上述查询也可以这样编写：
>>> name_map = {'first': 'first_name', 'last': 'last_name', 'bd': 'birth_date', 'pk': 'id'}
>>> Person.objects.raw('SELECT * FROM some_other_table', translations=name_map)
1.3 索引查询
raw() 支持索引操作，因此，如果你只需要获取第一个结果，可以这样写：
>>> first_person = Person.objects.raw('SELECT * FROM app_person')[0]
1.4 将参数传给 raw()
如果需要执行参数化的查询，可以使用 raw() 的 params 参数：
>>> lname = 'Doe'
>>> Person.objects.raw('SELECT * FROM myapp_person WHERE last_name = %s', [lname])
params 是一个参数字典。你可以使用列表来替换查询字符串中的 %s 占位符，或者使用字典来替换 %(key)s 占位符（其中 key 由字典的键替换）。无论使用哪种数据库引擎，这些占位符都会被 params 参数的值所替换。 注意：必须以列表形式传入参数，格式必须严格遵循此规范，不能写成字符串。
2、直接执行自定义 SQL
绕过模型层。
对象 django.db.connection 代表默认的数据库连接。要使用此数据库连接，首先调用 connection.cursor() 获取一个指针对象。然后，调用 cursor.execute(sql, [params]) 来执行 SQL 语句，并通过 cursor.fetchone() 或 cursor.fetchall() 获取结果数据。
from django.db import connection
def my_sql(self):
with connection.cursor() as cursor:
cursor.execute("UPDATE bar SET foo = 1 WHERE baz = %s", [self.baz])
cursor.execute("SELECT foo FROM bar WHERE baz = %s", [self.baz])
row = cursor.fetchone()
return row
为了避免 SQL 注入风险，绝对不能在 SQL 字符串中使用引号包裹 %s 占位符。 注意，若要在查询中包含文本的百分号，需要在传入参数时使用两个百分号：
cursor.execute("SELECT foo FROM bar WHERE baz = '30%%' AND id = %s", [self.id])
2.1 指定连接数据库
使用 django.db.connections 获取指定数据库的连接（及指针）。django.db.connections 是一个类字典对象，允许你通过连接别名获取指定的数据库连接：
from django.db import connections
with connections['my_db_alias'].cursor() as cursor:
本文介绍了 Django 执行原生 SQL 查询的实现方法，更多相关内容请搜索本站历史文章或继续浏览后续文章，希望大家以后多多支持本站！
免责声明：本文内容仅供参考，不代表本站观点。转载或引用请注明出处。
