Merge pull request #1 from KnifeMaster007/remove_jooq_dependency

Removed jooq dependency

Author: ayedo

build.gradle

@@ -11,7 +11,6 @@ repositories {
 
 dependencies {
     implementation 'org.jetbrains.kotlin:kotlin-stdlib-jdk8'
-    implementation 'org.jooq:jooq:3.12.3'
     implementation 'org.junit.jupiter:junit-jupiter-api:5.5.2'
 }
 

src/main/kotlin/DatabaseCopier.kt

@@ -1,34 +1,44 @@
-import org.jooq.DSLContext
-import org.jooq.impl.DSL
+import java.sql.Connection
+import java.sql.DriverManager
 
 class DatabaseCopier(
     private val host: String,
     private val port: Int,
     private val user: String,
     private val password: String
 ) {
+    private fun <R> withConnection(url: String, user: String, password: String, block: (Connection) -> R) {
+        DriverManager.getConnection(url, user, password).use {
+            block(it)
+        }
+    }
+
+    private fun Connection.execute(query: String) {
+        this.createStatement().use {
+            it.execute(query)
+        }
+    }
 
     fun copy(from: String, to: String) {
 
         synchronized(this) {
 
             val url = jdbcUrl(host, port, from)
 
-            DSL.using(url, user, password).use({ db: DSLContext ->
-
+            withConnection(url, user, password) { db ->
                 withExclusiveConnectionTo(db, to, from) {
                     db.execute("drop database if exists $to;")
                     db.execute("create database $to template $from;")
                 }
-
-            })
+            }
         }
     }
 
+
     private fun jdbcUrl(host: String, port: Int, database: String) =
         "jdbc:postgresql://$host:$port/$database?ApplicationName=database-copier"
 
-    private fun withExclusiveConnectionTo(db: DSLContext, vararg databaseNames: String, fn: () -> Unit) {
+    private fun withExclusiveConnectionTo(db: Connection, vararg databaseNames: String, fn: () -> Unit) {
 
         val whereDatNames = databaseNames.asSequence().map({ "datname = '$it'" }).joinToString(" or ")