Merge pull request #25 from razorpay/sslmode_post

add sslmode for postgress DE-6429
razorpay · Aug 7, 2024 · b4f1c26 · b4f1c26
2 parents 6f1b8a3 + a9e1a85
commit b4f1c26
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/sql-delta-import/src/main/scala/com/razorpay/spark/jdbc/JDBCImport.scala b/sql-delta-import/src/main/scala/com/razorpay/spark/jdbc/JDBCImport.scala
@@ -141,8 +141,11 @@ class JDBCImport(
     val schema = importConfig.schema
 
     val connectionUrl = s"jdbc:$dbType://$host:$port/$database"
-
-    connectionUrl
+    if (dbType == Constants.POSTGRESQL) {
+      s"$connectionUrl?sslmode=disable"
+    } else {
+      connectionUrl
+    }
   }
 
   private lazy val sourceDataframe = readJDBCSourceInParallel()