if(client != null && !client.isLocked()) {
return false;
}
CodecRegistry codecRegistry = CodecRegistries.fromRegistries(
CodecRegistries.fromCodecs(new UuidCodec(UuidRepresentation.STANDARD)),
MongoClient.getDefaultCodecRegistry()
);
MongoClientOptions options = MongoClientOptions.builder().codecRegistry(codecRegistry)
.build();
MongoCredential credential = MongoCredential.createCredential(Flawbase.getTheConfig().getMongo().getUser(), "sexyMovies", Flawbase.getTheConfig().getMongo().getPw().toCharArray());
ServerAddress db = new ServerAddress(Flawbase.getTheConfig().getMongo().getIp(), Flawbase.getTheConfig().getMongo().getPort());
try {
client = new MongoClient(db, Collections.singletonList(credential), options);
database = client.getDatabase("sexyMovies");
test = database.getCollection("test");
FlawlordUtils.log(Flawbase.getPluginName() + " Mongo established.");
} catch (MongoException e) {
System.out.println(Flawbase.getPluginName() + " Could not connect to mongo!");
e.printStackTrace();
return false;
}
return true;Code hier eingeben...