HL-1205 Postgres support

src/main/kotlin/com/atlassian/performance/tools/infrastructure/api/database/PostgresDatabase.kt

@@ -0,0 +1,49 @@
+package com.atlassian.performance.tools.infrastructure.api.database
+
+import com.atlassian.performance.tools.infrastructure.DockerImage
+import com.atlassian.performance.tools.infrastructure.api.dataset.DatasetPackage
+import com.atlassian.performance.tools.ssh.api.SshConnection
+import org.apache.logging.log4j.LogManager
+import org.apache.logging.log4j.Logger
+import java.net.URI
+import java.time.Duration
+
+class PostgresDatabase(
+    private val source: DatasetPackage,
+    private val maxConnections: Int,
+    private val dataBaseVersion: String
+) : Database {
+    private val logger: Logger = LogManager.getLogger(this::class.java)
+
+    private val image: DockerImage = DockerImage(
+        name = "postgres:$dataBaseVersion",
+        pullTimeout = Duration.ofMinutes(5)
+    )
+
+    constructor(
+        source: DatasetPackage,
+        dataBaseVersion: String = "9.6"
+    ) : this(
+        source = source,
+        maxConnections = 200,
+        dataBaseVersion = dataBaseVersion
+    )
+
+    override fun setup(ssh: SshConnection): String {
+        val pgData = source.download(ssh)
+        val containerName = image.run(
+            ssh = ssh,
+            parameters = "-p 3306:5432 -v `realpath $pgData`:/var/lib/postgresql/data",
+            arguments = "-c 'listen_addresses='*'' -c 'max_connections=$maxConnections'"
+        )
+        Thread.sleep(Duration.ofSeconds(15).toMillis())
+        return pgData
+    }
+
+    override fun start(jira: URI, ssh: SshConnection) {
+        // TODO Check logs for the following entry
+        // LOG:  database system is ready to accept connections
+        Thread.sleep(Duration.ofSeconds(15).toMillis())
+    }
+
+}

src/main/kotlin/com/atlassian/performance/tools/infrastructure/api/dataset/FileArchiver.kt

@@ -18,7 +18,11 @@ class FileArchiver {
     ) {
         ubuntu.install(connection, listOf("lbzip2"))
         time("unzip") {
-            connection.execute("tar -I lbzip2 -xf $archive", timeout)
+            val cmd = if (archive.contains("SCALED_ISSUES_UNIMODAL_PG"))
+                "tar -xzvf $archive"
+            else
+                "tar -I lbzip2 -xf $archive"
+            connection.execute(cmd, timeout)
         }
     }