表接結構如下
class MachineFixDoc(Base): """ 設備報修單,代理或用戶向公司申請報修 """ __tablename__ = 'machine_fix_doc' id = Column(String(26), unique=True, primary_key=True, default=SystemIDGenerator.repair_id) belong_to = Column(Enum(MachineFixBelongEnum), nullable=False) # 報修的設備歸屬於用戶還是代理 user_id = Column(String(36)) # 用戶id agent_id = Column(String(36), nullable=False) # 代理id machine_ids = Column(ARRAY(String(18)), nullable=False) # 設備id列表 operator = Column(String(36)) # 報修單由誰創建的目前存的是app.models.interface.UserInterface.username stage = Column(Enum(MachineFixDocStageEnum), default=MachineFixDocStageEnum.ongoing) # 處理中、或 已完成 remark = Column(Text) # 備注
machine_ids是一個array類型
現在要查詢MachineFixDoc.machine_ids中包含列表['520000011903111748', '721990005000']任意一個的所有MachineFixDoc
sql如下
select * from machine_fix_doc where machine_ids && array['520000011903111748', ' 721990005000']::varchar[];
sqlalchemy如下
from sqlalchemy import text all_machine_ids = ['520000011903111748', ' 721990005000'] docs = db.session.query(MachineFixDoc.machine_ids).filter(text('machine_ids && array%s::varchar[]' % str(all_machine_ids))).all()