2014-07-25 39 views
5

如何将这个mysql查询导入到django ORM中?Django具有多个连接字段的ORM查询

SELECT search_products.model, search_products.year, search_products.size, search_avg_price.estimated_price 
FROM search_products 
left JOIN search_avg_price 
ON search_products.model=search_avg_price.model and search_products.size=search_avg_price.size and search_products.year=search_avg_price.year 

我已经尝试

latest_products = Products.objects.all().prefetch_related("avg_price") 

,但是这是由Django的翻译为

SELECT `search_products`.`id`, `search_products`.`size`, `search_products`.`year`, , `search_products`.`model`, `search_products`.`avg_price_id` 
FROM `search_products` 

latest_products = Products.objects.all().select_related("avg_price") 

这是由Django的翻译为:

SELECT `search_products`.`id`, `search_products`.`size`, `search_products`.`year`, , `search_products`.`model`, `search_products`.`avg_price_id`, `search_avg_price`.`id`, `search_avg_price`.`model`, `search_avg_price`.`size`, `search_avg_price`.`year`, `search_avg_price`.`estimated_price` 
FROM `search_products` 
INNER JOIN `search_avg_price` ON (`search_products`.`avg_price_id` = `search_avg_price`.`id`) 

,如果我在数据库中运行我得到正确的结果上面的SQL ...

编辑:模型和视图

class Avg_price(models.Model): 
model = models.CharField(max_length=50, blank=True) 
size= models.IntegerField(blank=True, null=True) 
year= models.IntegerField(blank=True, null=True) 
estimated_price= models.IntegerField(blank=True, null=True) 

class Products(models.Model): 
product_id =models.IntegerField(blank=True, null=True) 
link_id = models.CharField(max_length=200, blank=True) 
location = models.CharField(max_length=200, blank=True) 
model = models.CharField(max_length=50, blank=True) 
size= models.IntegerField(blank=True, null=True) 
price= models.IntegerField(blank=True, null=True) 
year= models.IntegerField(blank=True, null=True) 
type=models.ForeignKey(Type) 
avg_price = models.ForeignKey(Avg_price) 

def __unicode__(self): # Python 3: def __str__(self): 
    return self.location 

模板

{% if latest_products %} 
    {% for product in latest_products %} 
    <ul> 
    <li id="col_one"> 
     <h5>{{product.avg_price.estimated_price}}</h5> 
     <h5>{{product.model}}</h5> 
+0

你不为此需要'select_related'或'prefetch_related',假设使用外键或多对多关系,您希望使用过滤器与另一个模型绑定。你能发布你的模型代码吗? – Tom

回答

1

尝试查询像这样:

qs = Product.objects.filter(
    avg_price__model__isnull=True).filter(
    avg_price__size__isnull=True).filter(
    avg_price__year__isnull=True).values_list(
    'model', 'year', 'size', 'avg_price__estimated_price') 

测试:

print(qs.query) 

说明:

从您的产品型号,您正在访问每次ForeignKeyavg_price和其他所需的当您返回的时间是NULL这种模式相对场该查询基于LEFT JOIN。这里有跨越的关系看UPS的文档:

https://docs.djangoproject.com/en/dev/topics/db/queries/#lookups-that-span-relationships

然后values_list使你可以指定哪些值返回。下面是关于values_list文档:

https://docs.djangoproject.com/en/dev/ref/models/querysets/#django.db.models.query.QuerySet.values_list

+0

我试过并得到错误:“FieldError:无法将关键字'avg_price.estimated_price'解析为字段”。看来django无法看到其他表格......并且我需要显示表格产品的所有结果,并在每次出现时添加表格avg_price的结果(年份,模型和大小)......感谢帮助 – user2950162

+0

用'avg_price__estimated_price'而不是'avg_price.estimated_price'怎么样? –

+0

结果查询是从一个我想建立不同的... SELECT'search_productsmodel','search_products'.'year','search_products'.'size','search_avg_price'.'estimated_price' FROM'search_products' INNER JOIN'search_avg_price' ON('search_products'.'avg_price_id' ='search_avg_price'.'id') WHERE('search_avg_price'.'model' IS NULL AND'search_avg_price'.'size' IS NULL AND'search_avg_price'.'年份是空的) – user2950162

1

你可以通过表列表方法额外的()并把条件从您的SQL查询的ON到其中部分额外的()

Product.objects.extra(
    tables=['search_avg_price'], 
    where=[ 
     '"search_products"."model"="search_avg_price"."model"', 
     '"search_products"."size"="search_avg_price"."size"', 
     '"search_products"."year"="search_avg_price"."year"' 
    ] 
) 

阅读更多关于额外的: https://docs.djangoproject.com/en/1.6/ref/models/querysets/#extra