added database and players collection
parent
ca1e3b996d
commit
07133d57a9
|
@ -4,8 +4,11 @@ import com.mongodb.ConnectionString;
|
|||
import com.mongodb.MongoClientSettings;
|
||||
import com.mongodb.reactivestreams.client.MongoClient;
|
||||
import com.mongodb.reactivestreams.client.MongoClients;
|
||||
import com.mongodb.reactivestreams.client.MongoCollection;
|
||||
import com.mongodb.reactivestreams.client.MongoDatabase;
|
||||
import earth.krakatoa.core.config.MongoConfig;
|
||||
import lombok.Data;
|
||||
import org.bson.Document;
|
||||
|
||||
@Data
|
||||
public class MongoManager {
|
||||
|
@ -17,6 +20,10 @@ public class MongoManager {
|
|||
|
||||
private MongoConfig mongoConfig;
|
||||
|
||||
private MongoDatabase krakatoaDatabase;
|
||||
|
||||
private MongoCollection<Document> playersCollection;
|
||||
|
||||
public MongoManager(MongoConfig mongoConfig) {
|
||||
this.mongoConfig = mongoConfig;
|
||||
}
|
||||
|
@ -32,6 +39,10 @@ public class MongoManager {
|
|||
.applyConnectionString(this.connectionString).build();
|
||||
|
||||
this.mongoClient = MongoClients.create(this.mongoClientSettings);
|
||||
|
||||
this.krakatoaDatabase = this.mongoClient.getDatabase("krakatoa");
|
||||
|
||||
this.playersCollection = this.krakatoaDatabase.getCollection("players");
|
||||
}
|
||||
|
||||
public void shutdown() {
|
||||
|
|
Loading…
Reference in New Issue