我想将我的项目从Morphia转换为Spring Data,但是使用Spring Data进行一些基础查询非常慢。
例如:
@Override
public List<PTDefaultBlacklistContact> findByBlacklistId(ObjectId defaultBlacklistId, int limit, int offset, String sortBy) {
Query query = Query.query(Criteria.where("blacklistId").is(defaultBlacklistId));
if (limit != 0)
query.limit(limit);
if (offset != 0)
query.skip(offset);
if (StringUtils.hasLength(sortBy))
query.with(new Sort(sortBy));
log.debug("findByBlacklistId query={}", query);
return mongoOperations.find(query, PTDefaultBlacklistContact.class);
}
大约需要2分钟
和Morphia一起
@Override
public List<PTDefaultBlacklistContact> findByBlacklistId(ObjectId defaultBlacklistId, int limit, int offset, String sortBy) {
Query<PTDefaultBlacklistContact> q = createQuery().disableValidation().filter("blacklistId", defaultBlacklistId).limit(limit)
.offset(offset);
if (StringUtils.hasLength(sortBy)) {
q.order(sortBy);
}
return q.asList();
}
大约需要5秒钟。
我的配置是基本的,因此很奇怪。
我只是在我的application.yml中有这个,并且有spring boot mongodb自动配置。
spring.data.mongodb.uri: mongodb://serv1,serv2,serv3/${mongodb.database}
任何想法 ?
我想知道原因是否可能是生命周期的事件。
谢谢
编辑:
楷模:
PTDefaultBlacklistContact
@Document(collection = "PTDefaultBlacklistContact")
public class PTDefaultBlacklistContact extends PTModel {
private static final long serialVersionUID = 1L;
@Deprecated
@DBRef
protected PTDefaultBlacklist blacklist;
private String identifier;
@Indexed
private ObjectId blacklistId;
private List<PTHistory> history;
public PTDefaultBlacklistContact() {
}
@Override
public int hashCode() {
int prime = 31;
int result = 1;
result = prime * result + ((blacklistId == null) ? 0 : blacklistId.hashCode());
result = prime * result + ((identifier == null) ? 0 : identifier.hashCode());
return result;
}
@Override
public boolean equals(Object obj) {
if (this == obj) {
return true;
}
if (getClass() != obj.getClass()) {
return false;
}
PTDefaultBlacklistContact other = (PTDefaultBlacklistContact) obj;
if (blacklistId == null) {
if (other.blacklistId != null) {
return false;
}
} else if (!blacklistId.equals(other.blacklistId)) {
return false;
}
if (identifier == null) {
if (other.identifier != null) {
return false;
}
} else if (!identifier.equals(other.identifier)) {
return false;
}
return true;
}
@Override
public String toString() {
return "PTDefaultBlacklistContact{" +
"identifier='" + identifier + '\'' +
", blacklistId=" + blacklistId +
'}';
}
public List<PTHistory> getHistory() {
return history;
}
public void setHistory(List<PTHistory> history) {
this.history = history;
}
public String getIdentifier() {
return identifier;
}
public void setIdentifier(String identifier) {
this.identifier = identifier;
}
@Deprecated
public PTDefaultBlacklist getBlacklist() {
return blacklist;
}
@Deprecated
public void setBlacklist(PTDefaultBlacklist blacklist) {
this.blacklist = blacklist;
}
public ObjectId getBlacklistId() {
if (blacklist != null) {
blacklistId = blacklist.getId();
}
return blacklistId;
}
public void setBlacklistId(ObjectId blacklistId) {
this.blacklistId = blacklistId;
}
}
历史
public class PTHistory {
private Long date;
@DBRef
private PTCampaign campaign;
public Long getDate() {
return date;
}
public void setDate(Long date) {
this.date = date;
}
public PTCampaign getCampaign() {
return campaign;
}
public void setCampaign(PTCampaign campaign) {
this.campaign = campaign;
}
}
最佳答案
通过上面的DBRef配置,默认情况下,您将通过Spring Data迅速解决所有问题。这将导致在阅读文档时针对遇到的每个DBRef发出附加查询。
我们通常建议使用@DBRef(lazy = true)
避免这些调用,而仅在访问它们后才读取它们。