fix PersistTimestampSpec for h2

akka · Dec 18, 2023 · b2b3d6f · b2b3d6f
1 parent 7f7454e
commit b2b3d6f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTimestampSpec.scala b/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTimestampSpec.scala
@@ -80,7 +80,11 @@ class PersistTimestampSpec
               Row(
                 pid = row.get("persistence_id", classOf[String]),
                 seqNr = row.get[java.lang.Long]("seq_nr", classOf[java.lang.Long]),
-                dbTimestamp = row.get("db_timestamp", classOf[LocalDateTime]).atZone(ZoneId.systemDefault()).toInstant,
+                dbTimestamp = if (settings.dialectName == "sqlserver") {
+                  row.get("db_timestamp", classOf[LocalDateTime]).atZone(ZoneId.systemDefault()).toInstant
+                } else {
+                  row.get("db_timestamp", classOf[Instant])
+                },
                 event)
             })
           .futureValue