2016-12-31 27 views
0

由於某些原因,我在sqlalchemy中使用了手動連接(Query.join not joinedload)。我已經使用別名,因爲我有多個連接到一個表。現在我想根據關係領域之一對結果進行排序。我如何使用帶有別名的Query.order_by?當我這樣做時,我在查詢中得到了模糊的%(####)而不是字段名稱。通過sqlalchemy中的連接別名進行排序

 if self.order_by: 
     entity = self.cls 
     for field, order in self.order_by: 

      if '.' in field: 

       m = re.match(r'(.+)\.(.+)', field) 

       if m.group(1) not in self.aliases: 

        for item in m.group(1).split('.'): 

         cls = inspect(entity) 
         attr = cls.attrs[item] 
         entity = get_type(attr) 

         if attr.innerjoin: 
          aliased_entity = aliased(entity) 
          self.aliases[m.group(1)] = aliased_entity 
          _query = _query.join(aliased_entity, item).options(contains_eager(item, 
                         alias=aliased_entity)) 
         else: 
          aliased_entity = aliased(entity) 
          self.aliases[m.group(1)] = aliased_entity 
          _query = _query.outerjoin(aliased_entity, item).options(contains_eager(item, 
                           alias=aliased_entity)) 

      if order == "desc": 
       _query = _query.order_by(self.get_order_by_field(field).desc()) 
      else: 
       _query = _query.order_by(self.get_order_by_field(field).asc()) 

然後:

def get_order_by_field(self, field: str) -> Column: 
     if '.' in field: 
      m = re.match(r'(.+)\.(.+)', field) 
      if m.group(1) in self.aliases: 
       return getattr(self.aliases[m.group(1)], m.group(2)) 
      else: 
       return Column(self.column_map[field]) 
     else: 
      return Column(field) 

回答

1

見exsample:

entity = sqlalchemy.aliased(ModelUser) 
session.query(ModelLog.id, ModelLog.date, ModelUser.id.label('current_user_id'), 
       entity.id.label('prev_user_id'))) \ 
     .join(ModelUser, ModelUser.id == ModelLog.id_model_user) \ 
     .join(entity, entity.id == ModelLog.id_prev_model_user) \ 
     .filter(...) \ 
     .order_by(entity.id.asc(), ModelUser.id.desc() 
+0

我必須把代碼的某些部分在這裏。上面的評論。 – Kamyar

相關問題