iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Database inserts ++

Browse Source
This commit is contained in:
Brage Skjønborg 2026-01-21 18:32:42 +01:00
parent af3f7bbc1a
commit 36eb28ad6b
3 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/EventStore.kt
View File

@ -19,8 +19,8 @@ object EventStore: EventStore {
.map {
PersistedEvent(
id = it[EventsTable.id].value.toLong(),
referenceId = it[EventsTable.referenceId],
eventId = it[EventsTable.eventId],
referenceId = UUID.fromString(it[EventsTable.referenceId]),
eventId = UUID.fromString(it[EventsTable.eventId]),
event = "", // You might want to store the event type as well
data = it[EventsTable.data],
persistedAt = it[EventsTable.persistedAt]
@ -33,12 +33,12 @@ object EventStore: EventStore {
override fun getPersistedEventsFor(referenceId: UUID): List<PersistedEvent> {
val result = withTransaction {
EventsTable.selectAll()
.where { EventsTable.referenceId eq referenceId}
.where { EventsTable.referenceId eq referenceId.toString()}
.map {
PersistedEvent(
id = it[EventsTable.id].value.toLong(),
referenceId = it[EventsTable.referenceId],
eventId = it[EventsTable.eventId],
referenceId = UUID.fromString(it[EventsTable.referenceId]),
eventId = UUID.fromString(it[EventsTable.eventId]),
event = "", // You might want to store the event type as well
data = it[EventsTable.data],
persistedAt = it[EventsTable.persistedAt]
@ -55,8 +55,8 @@ object EventStore: EventStore {
}
withTransaction {
EventsTable.insert {
it[EventsTable.referenceId] = event.referenceId
it[EventsTable.eventId] = event.eventId
it[EventsTable.referenceId] = event.referenceId.toString()
it[EventsTable.eventId] = event.eventId.toString()
it[EventsTable.event] = eventName
it[EventsTable.data] = asData
it[EventsTable.persistedAt] = LocalDateTime.now()

5
shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/tables/EventsTable.kt
View File

@ -5,11 +5,10 @@ import org.jetbrains.exposed.sql.Column
import org.jetbrains.exposed.sql.javatime.CurrentDateTime
import org.jetbrains.exposed.sql.javatime.datetime
import java.time.LocalDateTime
import java.util.*
object EventsTable: IntIdTable(name = "EVENTS") {
val referenceId: Column<UUID> = uuid("REFERENCE_ID")
val eventId: Column<UUID> = uuid("EVENT_ID")
val referenceId: Column<String> = varchar("REFERENCE_ID", 36)
val eventId: Column<String> = varchar("EVENT_ID", 36)
val event: Column<String> = varchar("EVENT",100)
val data: Column<String> = text("DATA")
val persistedAt: Column<LocalDateTime> = datetime("PERSISTED_AT").defaultExpression(CurrentDateTime)

5
shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/tables/TasksTable.kt
View File

@ -6,11 +6,10 @@ import org.jetbrains.exposed.sql.Column
import org.jetbrains.exposed.sql.javatime.CurrentDateTime
import org.jetbrains.exposed.sql.javatime.datetime
import java.time.LocalDateTime
import java.util.*
object TasksTable: IntIdTable(name = "TASKS") {
val referenceId: Column<UUID> = uuid("REFERENCE_ID")
val taskId: Column<UUID> = uuid("TASK_ID")
val referenceId: Column<String> = varchar("REFERENCE_ID", 36)
val taskId: Column<String> = varchar("TASK_ID", 36)
val task: Column<String> = varchar("TASK",100)
val status: Column<TaskStatus> = enumerationByName("STATUS", 50, TaskStatus::class).default(TaskStatus.Pending)
val data: Column<String> = text("DATA")