#654 Fix db_version not created when postgresql autocommit=false.

Author: yruslan

pramen/core/src/main/scala/za/co/absa/pramen/core/rdb/PramenDb.scala

@@ -27,6 +27,7 @@ import za.co.absa.pramen.core.reader.JdbcUrlSelector
 import za.co.absa.pramen.core.reader.model.JdbcConfig
 
 import java.sql.Connection
+import scala.util.Try
 import scala.util.control.NonFatal
 
 class PramenDb(val jdbcConfig: JdbcConfig,
@@ -43,6 +44,11 @@ class PramenDb(val jdbcConfig: JdbcConfig,
   def db: Database = slickDb
 
   def setupDatabase(): Unit = {
+    // Explicitly set auto-commit to true, overriding any user JDBC settings or PostgreSQL defaults
+    Try(jdbcConnection.setAutoCommit(true)).recover {
+      case NonFatal(e) => log.warn(s"Unable to set autoCommit=true fdr the bookkeeping database tha uses the driver: ${jdbcConfig.driver}.")
+    }
+
     val dbVersion = rdb.getVersion()
     if (dbVersion < MODEL_VERSION) {
       initDatabase(dbVersion)

pramen/core/src/main/scala/za/co/absa/pramen/core/rdb/RdbJdbc.scala

@@ -16,17 +16,19 @@
 
 package za.co.absa.pramen.core.rdb
 
-import java.sql.Connection
-
+import org.slf4j.LoggerFactory
 import za.co.absa.pramen.core.rdb.RdbJdbc.dbVersionTableName
 
+import java.sql.{Connection, SQLException}
 import scala.util.control.NonFatal
 
 object RdbJdbc {
   val dbVersionTableName = "db_version"
 }
 
 class RdbJdbc(connection: Connection) extends Rdb{
+  private val log = LoggerFactory.getLogger(this.getClass)
+
   override def getVersion(): Int = {
     getDbVersion()
   }
@@ -37,18 +39,24 @@ class RdbJdbc(connection: Connection) extends Rdb{
       executeDDL(s"INSERT INTO $dbVersionTableName (version) VALUES (0)")
     }
 
-    executeDDL(s"UPDATE db_version SET version = $version")
+    executeDDL(s"UPDATE $dbVersionTableName SET version = $version")
   }
 
   override def doesTableExists(tableName: String): Boolean = {
     val meta = connection.getMetaData
-    val res = meta.getTables(null, null, tableName, Array[String]("TABLE"))
-    if (res.next) {
-      res.close()
-      true
-    } else {
-      res.close()
-      false
+    try {
+      val res = meta.getTables(null, null, tableName, Array[String]("TABLE"))
+      if (res.next) {
+        res.close()
+        true
+      } else {
+        res.close()
+        false
+      }
+    } catch {
+      case ex: SQLException =>
+        log.warn(s"Error while checking existence of $tableName.", ex)
+        false
     }
   }