From 0408c7e2cd9d581775697f7bc30cf1856c2d938a Mon Sep 17 00:00:00 2001
From: QuadStingray <git@quadstingray.dev>
Date: Fri, 26 Apr 2024 23:15:51 +0200
Subject: [PATCH] feat: implemented jdbc driver methods

---
 .../driver/mongodb/jdbc/MongoJdbcDriver.scala | 49 +++++++++----------
 1 file changed, 24 insertions(+), 25 deletions(-)

diff --git a/src/main/scala/dev/mongocamp/driver/mongodb/jdbc/MongoJdbcDriver.scala b/src/main/scala/dev/mongocamp/driver/mongodb/jdbc/MongoJdbcDriver.scala
index 4150c8d..5b48b83 100644
--- a/src/main/scala/dev/mongocamp/driver/mongodb/jdbc/MongoJdbcDriver.scala
+++ b/src/main/scala/dev/mongocamp/driver/mongodb/jdbc/MongoJdbcDriver.scala
@@ -1,46 +1,45 @@
 package dev.mongocamp.driver.mongodb.jdbc
 
-import com.mongodb.MongoCredential.createCredential
 import com.vdurmont.semver4j.Semver
 import dev.mongocamp.driver.mongodb.BuildInfo
-import org.mongodb.scala.MongoClient.DEFAULT_CODEC_REGISTRY
-import org.mongodb.scala.{ConnectionString, MongoClient, MongoClientSettings, MongoCredential}
+import dev.mongocamp.driver.mongodb.database.{ DatabaseProvider, MongoConfig }
+import org.mongodb.scala.{ ConnectionString, ServerAddress }
 
-import java.sql.{Connection, DriverPropertyInfo}
+import java.sql.{ Connection, DriverPropertyInfo }
 import java.util.Properties
 import java.util.logging.Logger
+import scala.jdk.CollectionConverters.CollectionHasAsScala
 
 class MongoJdbcDriver extends java.sql.Driver {
 
   private lazy val semVer = new Semver(BuildInfo.version)
 
-
-  /**
-   * Connect to the database using a URL like :
-   * jdbc:mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]
-   * The URL excepting the jdbc: prefix is passed as it is to the MongoDb native Java driver.
-   */
+  /** Connect to the database using a URL like : jdbc:mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]] The
+    * URL excepting the jdbc: prefix is passed as it is to the MongoDb native Java driver.
+    */
   override def connect(url: String, info: Properties): Connection = {
     if (url == null || !acceptsURL(url)) {
       return null
     }
 
     val connectionUrl = url.replaceFirst("^jdbc:", "")
-    val username = info.getProperty("user")
-    val password = info.getProperty("password")
-
-    val builder = MongoClientSettings
-      .builder()
-      .applyConnectionString(new ConnectionString(connectionUrl))
-      .codecRegistry(DEFAULT_CODEC_REGISTRY)
-
-    if (!username.equalsIgnoreCase("") && !password.equalsIgnoreCase("")) {
-      val credential: MongoCredential = createCredential(username, "admin", password.toCharArray)
-      builder.credential(credential).build()
-    }
-
-    val client: MongoClient = MongoClient(builder.build())
-    new MongoJdbcConnection(client)
+    val username      = Option(info.getProperty("user")).filter(_.trim.nonEmpty)
+    val password      = Option(info.getProperty("password")).filter(_.trim.nonEmpty)
+
+    val string = new ConnectionString(connectionUrl)
+    val provider = DatabaseProvider(
+      MongoConfig(
+        string.getDatabase,
+        MongoConfig.DefaultHost,
+        MongoConfig.DefaultPort,
+        string.getApplicationName,
+        username,
+        password,
+        string.getDatabase,
+        serverAddressList = string.getHosts.asScala.toList.map(h => new ServerAddress(h))
+      )
+    )
+    new MongoJdbcConnection(provider)
   }
 
   override def acceptsURL(url: String): Boolean = {