package edu.nju.dao; import edu.nju.entities.Answer; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.MongoOperations; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Query; import org.springframework.stereotype.Repository; import java.util.List; @Repository public class AnswerDao { @Autowired private MongoOperations mongoOperations; public List findAnswersByItemWorker(String item_id,String worker_id){ Query query = new Query(); query.addCriteria(Criteria.where("item_id").is(item_id).and("worker_id").is(worker_id)); return mongoOperations.find(query, Answer.class); } //存在则更新,不存在则插入 public String save(Answer answer){ mongoOperations.save(answer); return answer.getId(); } }