Skip to content

Commit

Permalink
Fixed merge conflict resulting in out of date file version. Replace V…
Browse files Browse the repository at this point in the history
…8 with V10
  • Loading branch information
HoshiKurama committed Sep 6, 2023
1 parent 90e8194 commit b1b607f
Showing 1 changed file with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ class CachedH2(absoluteDataFolderPath: String) : CompletableFutureAsyncDatabase
private val sqlPool: JdbcConnectionPool

init {
val fixedURL = "jdbc:h2:file:$absoluteDataFolderPath/TicketManager-H2-V8.db"
val fixedURL = "jdbc:h2:file:$absoluteDataFolderPath/TicketManager-H2-V10.db"
.replace("C:", "")
.replace("\\", "/")

Expand All @@ -40,28 +40,28 @@ class CachedH2(absoluteDataFolderPath: String) : CompletableFutureAsyncDatabase
val t = ticketMap[ticketID]!!
ticketMap[ticketID] = Ticket(t.id, t.creator, t.priority, t.status, assignment, t.creatorStatusUpdate, t.actions)

return sendQuery { update(queryOf("UPDATE TicketManager_V8_Tickets SET ASSIGNED_TO = ? WHERE ID = ?;", assignment.asString(), ticketID)) }
return sendQuery { update(queryOf("UPDATE TicketManager_V10_Tickets SET ASSIGNED_TO = ? WHERE ID = ?;", assignment.asString(), ticketID)) }
}

override fun setCreatorStatusUpdateAsync(ticketID: Long, status: Boolean): CompletableFuture<Void> {
val t = ticketMap[ticketID]!!
ticketMap[ticketID] = Ticket(t.id, t.creator, t.priority, t.status, t.assignedTo, status, t.actions)

return sendQuery { update(queryOf("UPDATE TicketManager_V8_Tickets SET STATUS_UPDATE_FOR_CREATOR = ? WHERE ID = ?;", status, ticketID)) }
return sendQuery { update(queryOf("UPDATE TicketManager_V10_Tickets SET STATUS_UPDATE_FOR_CREATOR = ? WHERE ID = ?;", status, ticketID)) }
}

override fun setPriorityAsync(ticketID: Long, priority: Ticket.Priority): CompletableFuture<Void> {
val t = ticketMap[ticketID]!!
ticketMap[ticketID] = Ticket(t.id, t.creator, priority, t.status, t.assignedTo, t.creatorStatusUpdate, t.actions)

return sendQuery { update(queryOf("UPDATE TicketManager_V8_Tickets SET PRIORITY = ? WHERE ID = ?;", priority.asByte(), ticketID)) }
return sendQuery { update(queryOf("UPDATE TicketManager_V10_Tickets SET PRIORITY = ? WHERE ID = ?;", priority.asByte(), ticketID)) }
}

override fun setStatusAsync(ticketID: Long, status: Ticket.Status): CompletableFuture<Void> {
val t = ticketMap[ticketID]!!
ticketMap[ticketID] = Ticket(t.id, t.creator, t.priority, status, t.assignedTo, t.creatorStatusUpdate, t.actions)

return sendQuery { update(queryOf("UPDATE TicketManager_V8_Tickets SET STATUS = ? WHERE ID = ?;", status.name, ticketID)) }
return sendQuery { update(queryOf("UPDATE TicketManager_V10_Tickets SET STATUS = ? WHERE ID = ?;", status.name, ticketID)) }
}

override fun insertActionAsync(id: Long, action: Action): CompletableFuture<Void> {
Expand Down Expand Up @@ -94,7 +94,7 @@ class CachedH2(absoluteDataFolderPath: String) : CompletableFutureAsyncDatabase
// Writes ticket
sendQuery {
update(
queryOf("INSERT INTO TicketManager_V8_Tickets (ID, CREATOR, PRIORITY, STATUS, ASSIGNED_TO, STATUS_UPDATE_FOR_CREATOR) VALUES (?,?,?,?,?,?);",
queryOf("INSERT INTO TicketManager_V10_Tickets (ID, CREATOR, PRIORITY, STATUS, ASSIGNED_TO, STATUS_UPDATE_FOR_CREATOR) VALUES (?,?,?,?,?,?);",
newTicket.id,
newTicket.creator.asString(),
newTicket.priority.asByte(),
Expand Down Expand Up @@ -203,7 +203,7 @@ class CachedH2(absoluteDataFolderPath: String) : CompletableFutureAsyncDatabase
location = ticketLoc,
).MassClose()

sendQuery { update(queryOf("UPDATE TicketManager_V8_Tickets SET STATUS = ? WHERE ID IN (${ticketIds.joinToString(", ")});", Ticket.Status.CLOSED.name)) }
sendQuery { update(queryOf("UPDATE TicketManager_V10_Tickets SET STATUS = ? WHERE ID IN (${ticketIds.joinToString(", ")});", Ticket.Status.CLOSED.name)) }
return sendQuery { ticketIds.map { insertActionAsync(it, action) }.flatten() }
}

Expand Down Expand Up @@ -435,7 +435,7 @@ class CachedH2(absoluteDataFolderPath: String) : CompletableFutureAsyncDatabase
// Loads tickets to memory
val basicTicketsCF = CompletableFuture.supplyAsync {
using(sessionOf(sqlPool)) { session ->
session.run(queryOf("SELECT * FROM TicketManager_V8_Tickets;")
session.run(queryOf("SELECT * FROM TicketManager_V10_Tickets;")
.map {it.toTicket() }.asList
)
}
Expand Down

0 comments on commit b1b607f

Please sign in to comment.