Django中SQL查询

简介:

当 Django 中模型提供的查询 API 不能满足要求时,你可能需要使用原始的 sql 查询,这时候就需要用到 Manager.raw() 方法。

Manager 类提供下面的一个方法,可以用于执行 sql:

Manager.raw(raw_query, params=None, translations=None)

使用方法为:

>>> for p in Person.objects.raw('SELECT * FROM myapp_person'):
...     print(p)
John Smith
Jane Jones

raw() 可以通过名称自动将 sql 语句中的字段映射到模型,所以你不必考虑 sql 语句中的字段顺序:

>>> Person.objects.raw('SELECT id, first_name, last_name, birth_date FROM myapp_person')
...
>>> Person.objects.raw('SELECT last_name, birth_date, first_name, id FROM myapp_person')
...

字段映射

如果一个表中有和 person 相同的数据,只是字段名称不一致,你可以使用 sql 语句中 的 as 关键字给字段取别名:

>>> Person.objects.raw('''SELECT first AS first_name,
...                              last AS last_name,
...                              bd AS birth_date,
...                              pk AS id,
...                       FROM some_other_table''')

另外,你还可以添加 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)

延迟获取字段

下面的查询:

>>> people = Person.objects.raw('SELECT id, first_name FROM myapp_person')

sql 语句中只包含两个字段,如果你从 people 中获取不在 sql 语句中的字段的值的时候,其会从数据库再查询一次

>>> for p in Person.objects.raw('SELECT id, first_name FROM myapp_person'):
...     print(p.first_name, # This will be retrieved by the original query
...           p.last_name) # This will be retrieved on demand
...
John Smith
Jane Jones

但是,需要记住的是 sql 语句中一定要包括主键,因为只有主键才能唯一标识数据库中的一条记录。

传递参数

如果你想给 sql 语句传递参数,你可以添加 raw()  params 参数。

>>> lname = 'Doe'
>>> Person.objects.raw('SELECT * FROM myapp_person WHERE last_name = %s', [lname])

记住:上面的 sql 语句一定不要写成下面的方式,因为这样可能会有 sql 注入的问题!

'SELECT * FROM myapp_person WHERE last_name = %s' % lname

运行自定义的 sql

Manager.raw() 只能执行 sql 查询,确不能运行 UPDATEINSERT  DELETE 查询,在这种情况下,你需要使用 django.db.connection 类。

 from django.db import connection

def my_custom_sql(self):
    cursor = connection.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

在 Django 1.6 之后,修改数据之后会自动提交事务,而不用手动调用 transaction.commit_unless_managed() 了。

如果 sql 中你想使用 % 字符 ,则你需要写两次:

cursor.execute("SELECT foo FROM bar WHERE baz = '30%'")
cursor.execute("SELECT foo FROM bar WHERE baz = '30%%' AND id = %s", [self.id])

如果有多个数据库:

from django.db import connections
cursor = connections['my_db_alias'].cursor()
# Your code here...

默认情况下,Python 的 DB API 返回的结果只包括数据不包括每个字段的名称,你可以牺牲一点性能代价,将查询结果转换为字典:

def dictfetchall(cursor):
    "Returns all rows from a cursor as a dict"
    desc = cursor.description
    return [
        dict(zip([col[0] for col in desc], row))
        for row in cursor.fetchall()
    ]

在 Django 1.7 中,可以使用 cursor 作为一个上下文管理器:

with connection.cursor() as c:
    c.execute(...)

其等价于:

c = connection.cursor()
try:
    c.execute(...)
finally:
    c.close()

本文参考:Performing raw SQL queries

目录
相关文章
|
10天前
|
SQL
sql语句加正则 简化查询
sql语句加正则 简化查询
14 0
sql语句加正则 简化查询
|
28天前
|
SQL
sql server链接查询
sql server链接查询
17 1
|
28天前
|
SQL
sql server简单查询
sql server简单查询
14 1
|
1月前
|
SQL 数据库 C#
C# .NET面试系列十一:数据库SQL查询(附建表语句)
#### 第1题 用一条 SQL 语句 查询出每门课都大于80 分的学生姓名 建表语句: ```sql create table tableA ( name varchar(10), kecheng varchar(10), fenshu int(11) ) DEFAULT CHARSET = 'utf8'; ``` 插入数据 ```sql insert into tableA values ('张三', '语文', 81); insert into tableA values ('张三', '数学', 75); insert into tableA values ('李四',
62 2
C# .NET面试系列十一:数据库SQL查询(附建表语句)
|
2月前
|
SQL 缓存 关系型数据库
MySQL技能完整学习列表6、查询优化——3、查询缓存——4、SQL优化技巧
MySQL技能完整学习列表6、查询优化——3、查询缓存——4、SQL优化技巧
63 0
|
2月前
|
SQL 存储 数据库
面试题19: 如何优化SQL查询?
面试题19: 如何优化SQL查询?
面试题19: 如何优化SQL查询?
|
18天前
|
SQL 关系型数据库 MySQL
mysql一条sql查询出多个统计结果
mysql一条sql查询出多个统计结果
13 0
|
28天前
|
SQL
sql高级查询
sql高级查询
12 0
|
1月前
|
SQL 存储 数据可视化
10个高级的 SQL 查询技巧
10个高级的 SQL 查询技巧
|
29天前
|
SQL 数据库
sql server高级查询,看这篇文章就够了
sql server高级查询,看这篇文章就够了
21 0