Revision 52365
Added by Miriam Baglioni almost 6 years ago
| modules/dnet-data-provision-services/trunk/src/main/java/eu/dnetlib/oai/mongo/MongoPublisherStore.java | ||
|---|---|---|
| 303 | 303 |
public void run() {
|
| 304 | 304 |
Bson filter = Filters.and(Filters.eq(OAIConfigurationReader.DELETED_FIELD, false), |
| 305 | 305 |
Filters.lt(OAIConfigurationReader.LAST_COLLECTION_DATE_FIELD, feedDate)); |
| 306 |
|
|
| 306 | 307 |
if (!StringUtils.isBlank(source)) {
|
| 307 |
filter = Filters.and(filter, Filters.eq(OAIConfigurationReader.SET_FIELD, source));
|
|
| 308 |
filter = Filters.and(filter, Filters.eq(OAIConfigurationReader.SET_FIELD, mongoSetCollection.normalizeSetSpec(source)));
|
|
| 308 | 309 |
} |
| 309 | 310 |
log.debug("Delete flag query: " + filter);
|
| 310 | 311 |
final BasicDBObject update = new BasicDBObject("$set",
|
| ... | ... | |
| 682 | 683 |
this.alwaysNewRecord = alwaysNewRecord; |
| 683 | 684 |
} |
| 684 | 685 |
|
| 686 |
|
|
| 687 |
|
|
| 685 | 688 |
} |
Also available in: Unified diff
normalized set name in filter constraint