From 6589d56b8454bdaf98d5db79cacf39b0c2941a54 Mon Sep 17 00:00:00 2001 From: mamutmk5 <3045922+mamutmk5@users.noreply.github.com> Date: Fri, 12 Jul 2024 15:21:53 +0200 Subject: [PATCH] BC-7240 - test dto class --- src/main/java/de/svs/doido/mongo/Admin.java | 11 ++--- .../java/de/svs/doido/mongo/db/MongoApp.java | 14 ++++++ .../de/svs/doido/mongo/dto/MogoServer.java | 45 +++++++++++++++++++ 3 files changed, 62 insertions(+), 8 deletions(-) create mode 100644 src/main/java/de/svs/doido/mongo/db/MongoApp.java create mode 100644 src/main/java/de/svs/doido/mongo/dto/MogoServer.java diff --git a/src/main/java/de/svs/doido/mongo/Admin.java b/src/main/java/de/svs/doido/mongo/Admin.java index 607622d..a8abbe5 100644 --- a/src/main/java/de/svs/doido/mongo/Admin.java +++ b/src/main/java/de/svs/doido/mongo/Admin.java @@ -16,6 +16,8 @@ import com.mongodb.client.MongoDatabase; import java.util.List; +import svs.doido.mongo.dto.MongoServer; + @Path("/admin") public class Admin { @@ -30,14 +32,7 @@ public Admin(KubernetesClient kubernetesClient) { @Path("/{clientname}") public void testConnect(String clientname) { String uri = "mongodb://mongodb-2.mongo-svc:27017/replicaSet=rs0&directConnection=false"; - ServerApi serverApi = ServerApi.builder() - .version(ServerApiVersion.V1) - .build(); - MongoClientSettings settings = MongoClientSettings.builder() - .applyConnectionString(new ConnectionString(uri)) - .serverApi(serverApi) - .build(); - try (MongoClient mongoClient = MongoClients.create(settings)) { + try (MongoClient mongoClient = new MongoServer(clientname, uri).getMongoClient()) { MongoDatabase database = mongoClient.getDatabase(clientname); try { // Send a ping to confirm a successful connection diff --git a/src/main/java/de/svs/doido/mongo/db/MongoApp.java b/src/main/java/de/svs/doido/mongo/db/MongoApp.java new file mode 100644 index 0000000..67ff4d2 --- /dev/null +++ b/src/main/java/de/svs/doido/mongo/db/MongoApp.java @@ -0,0 +1,14 @@ +package svs.doido.mongo.db; + +import svs.doido.mongo.dto.Configmap; +import io.fabric8.kubernetes.api.model.ConfigMap; +import io.fabric8.kubernetes.api.model.ObjectMeta; +import io.fabric8.kubernetes.client.KubernetesClient; +import jakarta.inject.Inject; +import jakarta.enterprise.context.ApplicationScoped; + + +@ApplicationScoped +public class MongoApp { + +} \ No newline at end of file diff --git a/src/main/java/de/svs/doido/mongo/dto/MogoServer.java b/src/main/java/de/svs/doido/mongo/dto/MogoServer.java new file mode 100644 index 0000000..44d22c2 --- /dev/null +++ b/src/main/java/de/svs/doido/mongo/dto/MogoServer.java @@ -0,0 +1,45 @@ +package svs.doido.mongo.dto; + +import lombok.Getter; +import lombok.ToString; +import lombok.EqualsAndHashCode; +import com.mongodb.*; +import com.mongodb.client.MongoClient; +import com.mongodb.client.MongoClients; +import com.mongodb.client.MongoDatabase; + + +@ToString +@EqualsAndHashCode +public class MongoServer { + @Getter + private String name; + + @Getter + private MongoClient mongoClient; + + @Getter + private ConnectionString connectionString; + + public void MongoServer(String name, String connectionString) { + if (name == null ) { + throw new NullPointerException(); + } + if (connectionString == null) { + throw new NullPointerException(); + } + else { + this.connectionString = new ConnectionString(connectionString); + } + ServerApi serverApi = ServerApi.builder() + .version(ServerApiVersion.V1) + .build(); + MongoClientSettings settings = MongoClientSettings.builder() + .applyConnectionString(this.connectionString) + .applicationName(name) + .serverApi(serverApi) + .build(); + mongoClient = MongoClients.create(settings); + } + +} \ No newline at end of file