block19.scala

def updatePartitionCommand(partitions: List[(String, Long)]) = {
  val enc = (varchar ~ int8).values.list(partitions)
  sql"""INSERT INTO offsets (topic, "offset")
        VALUES $enc
        ON CONFLICT (topic) DO UPDATE
        SET "offset"=EXCLUDED."offset"""".command
}