在django的模型中执行原始sql查询的方法

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

>>> from django.db import connection
>>> cursor = connection.cursor()
>>> cursor.execute(“””
… select distinct first_name
… from people_person
… where last_name = %s”””, [‘lennon’])
>>> row = cursor.fetchone()
>>> print row
[‘john’]

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

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

from django.db import connection, models
class personmanager(models.manager):
def first_names(self, last_name):
cursor = connection.cursor()
cursor.execute(“””
select distinct first_name
from people_person
where last_name = %s”””, [last_name])
return [row[0] for row in cursor.fetchone()]
class person(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’]

Posted in 未分类

发表评论