flecomte/postgres-json
1
1
Fork 0
Code Issues 10 Pull Requests 2 Actions Packages Projects Releases 2 Wiki Activity

feature: add log into migrations

Browse Source
This commit is contained in:
Fabrice Lecomte
2019-08-03 20:26:50 +02:00
parent 15c347e3fd
commit a20682b406
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/kotlin/fr/postgresjson/migration/Migrations.kt
View File

@@ -7,6 +7,8 @@ import fr.postgresjson.definition.Function.FunctionNotFound
import fr.postgresjson.entity.Entity import fr.postgresjson.entity.Entity
import fr.postgresjson.migration.Migration.Action import fr.postgresjson.migration.Migration.Action
import fr.postgresjson.migration.Migration.Status import fr.postgresjson.migration.Migration.Status
import fr.postgresjson.utils.LoggerDelegate
import org.slf4j.Logger
import java.io.File import java.io.File
import java.io.FileNotFoundException import java.io.FileNotFoundException
import java.util.* import java.util.*
@@ -37,6 +39,7 @@ data class Migrations private constructor(
private val queries: MutableMap<String, Query> = mutableMapOf(), private val queries: MutableMap<String, Query> = mutableMapOf(),
private val functions: MutableMap<String, Function> = mutableMapOf() private val functions: MutableMap<String, Function> = mutableMapOf()
) { ) {
private val logger: Logger? by LoggerDelegate()
constructor(directory: File, connection: Connection): this(listOf(directory), connection) constructor(directory: File, connection: Connection): this(listOf(directory), connection)
constructor(directories: List<File>, connection: Connection): this(connection) { constructor(directories: List<File>, connection: Connection): this(connection) {
@@ -228,6 +231,7 @@ data class Migrations private constructor(
fun run(): Map<Pair<String, Direction>, Status> { fun run(): Map<Pair<String, Direction>, Status> {
val list: MutableMap<Pair<String, Direction>, Status> = mutableMapOf() val list: MutableMap<Pair<String, Direction>, Status> = mutableMapOf()
logger?.info("Migration Begin")
connection.apply { connection.apply {
sendQuery("BEGIN") sendQuery("BEGIN")
lock() lock()
@@ -239,6 +243,7 @@ data class Migrations private constructor(
} }
sendQuery("COMMIT") sendQuery("COMMIT")
} }
logger?.info("Migration done")
return list.toMap() return list.toMap()
} }
@@ -249,6 +254,7 @@ data class Migrations private constructor(
fun forceAllDown(): Map<Pair<String, Direction>, Status> { fun forceAllDown(): Map<Pair<String, Direction>, Status> {
val list: MutableMap<Pair<String, Direction>, Status> = mutableMapOf() val list: MutableMap<Pair<String, Direction>, Status> = mutableMapOf()
logger?.info("Migration DOWN begin")
connection.apply { connection.apply {
sendQuery("BEGIN") sendQuery("BEGIN")
lock() lock()
@@ -257,6 +263,7 @@ data class Migrations private constructor(
} }
sendQuery("COMMIT") sendQuery("COMMIT")
} }
logger?.info("Migration DOWN done")
return list.toMap() return list.toMap()
} }