• 执行原始SQL查询

    执行原始SQL查询

    有时候你会发现Django数据库API带给你的也只有这么多,那你可以为你的数据库写一些自定义SQL查询。 你可以通过导入django.db.connection对像来轻松实现,它代表当前数据库连接。 要使用它,需要通过connection.cursor()得到一个游标对像。 然后,使用cursor.execute(sql, [params])来执行SQL语句,使用cursor.fetchone()或者cursor.fetchall()来返回记录集。 例如:

    1. >>> from django.db import connection
    2. >>> cursor = connection.cursor()
    3. >>> cursor.execute("""
    4. ... SELECT DISTINCT first_name
    5. ... FROM people_person
    6. ... WHERE last_name = %s""", ['Lennon'])
    7. >>> row = cursor.fetchone()
    8. >>> print row
    9. ['John']

    connectioncursor几乎实现了标准Python DB-API,你可以访问http://www.python.org/peps/pep-0249.html <http://www.python.org/peps/pep-0249.html>__来获取更多信息。 如果你对Python DB-API不熟悉,请注意在cursor.execute() 的SQL语句中使用“%s” ,而不要在SQL内直接添加参数。 如果你使用这项技术,数据库基础库将会自动添加引号,同时在必要的情况下转意你的参数。

    不要把你的视图代码和django.db.connection语句混杂在一起,把它们放在自定义模型或者自定义manager方法中是个不错的主意。 比如,上面的例子可以被整合成一个自定义manager方法,就像这样:

    1. from django.db import connection, models
    2. class PersonManager(models.Manager):
    3. def first_names(self, last_name):
    4. cursor = connection.cursor()
    5. cursor.execute("""
    6. SELECT DISTINCT first_name
    7. FROM people_person
    8. WHERE last_name = %s""", [last_name])
    9. return [row[0] for row in cursor.fetchone()]
    10. class Person(models.Model):
    11. first_name = models.CharField(max_length=50)
    12. last_name = models.CharField(max_length=50)
    13. objects = PersonManager()

    然后这样使用:

    1. >>> Person.objects.first_names('Lennon')
    2. ['John', 'Cynthia']