我想将我的项目从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)避免这些调用,而仅在访问它们后才读取它们。

09-30 15:29
查看更多