zenon/distributed-systems-technologies
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add MongoDB indexing (1.4.1)

Browse Source
This commit is contained in:
Tobias Eidelpes 2021-04-06 18:34:39 +02:00
parent 4bad3fc48f
commit 8b4308cf1e
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ass1-doc/src/main/java/dst/ass1/doc/impl/DocumentRepository.java
View File

@ -3,6 +3,7 @@ package dst.ass1.doc.impl;
import com.mongodb.MongoClient; import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase; import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Indexes;
import dst.ass1.doc.IDocumentRepository; import dst.ass1.doc.IDocumentRepository;
import dst.ass1.jpa.model.ILocation; import dst.ass1.jpa.model.ILocation;
import org.bson.Document; import org.bson.Document;
@ -19,6 +20,9 @@ public class DocumentRepository implements IDocumentRepository {
MongoDatabase mongoDatabase = mongoClient.getDatabase(MONGO_DB_NAME); MongoDatabase mongoDatabase = mongoClient.getDatabase(MONGO_DB_NAME);
MongoCollection<Document> mongoCollection = mongoDatabase.getCollection(COLL_LOCATION_DATA); MongoCollection<Document> mongoCollection = mongoDatabase.getCollection(COLL_LOCATION_DATA);
mongoCollection.createIndex(Indexes.ascending(M_LOCATION_NAME));
mongoCollection.createIndex(Indexes.geo2dsphere(M_LOCATION_GEO));
Document document = new Document(locationProperties) Document document = new Document(locationProperties)
.append(I_LOCATION, location.getLocationId()) .append(I_LOCATION, location.getLocationId())
.append(M_LOCATION_NAME, location.getName()); .append(M_LOCATION_NAME, location.getName());