在Django的模型中执行原始SQL查询的方法
有时候你会发现Django数据库API带给你的也只有这么多,那你可以为你的数据库写一些自定义SQL查询。你可以通过导入django.db.connection对像来轻松实现,它代表当前数据库连接。要使用它,需要通过connection.cursor()得到一个游标对像。然后,使用cursor.execute(sql,[params])来执行SQL语句,使用cursor.fetchone()或者cursor.fetchall()来返回记录集。例如:
>>>fromdjango.dbimportconnection
>>>cursor=connection.cursor()
>>>cursor.execute("""
...SELECTDISTINCTfirst_name
...FROMpeople_person
...WHERElast_name=%s""",['Lennon'])
>>>row=cursor.fetchone()
>>>printrow
['John']
connection和cursor几乎实现了标准PythonDB-API,你可以访问`http://www.python.org/peps/pep-0249.html<http://www.python.org/peps/pep-0249.html>`__来获取更多信息。如果你对PythonDB-API不熟悉,请注意在cursor.execute()的SQL语句中使用``“%s”``,而不要在SQL内直接添加参数。如果你使用这项技术,数据库基础库将会自动添加引号,同时在必要的情况下转意你的参数。
不要把你的视图代码和django.db.connection语句混杂在一起,把它们放在自定义模型或者自定义manager方法中是个不错的主意。比如,上面的例子可以被整合成一个自定义manager方法,就像这样:
fromdjango.dbimportconnection,models
classPersonManager(models.Manager):
deffirst_names(self,last_name):
cursor=connection.cursor()
cursor.execute("""
SELECTDISTINCTfirst_name
FROMpeople_person
WHERElast_name=%s""",[last_name])
return[row[0]forrowincursor.fetchone()]
classPerson(models.Model):
first_name=models.CharField(max_length=50)
last_name=models.CharField(max_length=50)
objects=PersonManager()
然后这样使用:
>>>Person.objects.first_names('Lennon')
['John','Cynthia']