diff options
Diffstat (limited to 'sandbox/src/main/kotlin/tech/libeufin/sandbox/DB.kt')
-rw-r--r-- | sandbox/src/main/kotlin/tech/libeufin/sandbox/DB.kt | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/sandbox/src/main/kotlin/tech/libeufin/sandbox/DB.kt b/sandbox/src/main/kotlin/tech/libeufin/sandbox/DB.kt index ca83d31a..19d4283d 100644 --- a/sandbox/src/main/kotlin/tech/libeufin/sandbox/DB.kt +++ b/sandbox/src/main/kotlin/tech/libeufin/sandbox/DB.kt @@ -33,6 +33,7 @@ import org.jetbrains.exposed.dao.id.LongIdTable import org.jetbrains.exposed.sql.* import org.jetbrains.exposed.sql.transactions.TransactionManager import org.jetbrains.exposed.sql.transactions.transaction +import tech.libeufin.util.getCurrentUser import tech.libeufin.util.internalServerError import java.sql.Connection import kotlin.reflect.* @@ -665,7 +666,7 @@ class CashoutSubmissionEntity(id: EntityID<Long>) : LongEntity(id) { } fun dbDropTables(dbConnectionString: String) { - Database.connect(dbConnectionString) + Database.connect(dbConnectionString, user = getCurrentUser()) transaction { SchemaUtils.drop( CashoutSubmissionsTable, @@ -690,7 +691,7 @@ fun dbDropTables(dbConnectionString: String) { } fun dbCreateTables(dbConnectionString: String) { - Database.connect(dbConnectionString) + Database.connect(dbConnectionString, user = getCurrentUser()) TransactionManager.manager.defaultIsolationLevel = Connection.TRANSACTION_SERIALIZABLE transaction { SchemaUtils.create( |