Path	Lines of Code
core/src/main/scala/org/apache/pekko/persistence/r2dbc/ConnectionFactoryProvider.scala	141
core/src/main/scala/org/apache/pekko/persistence/r2dbc/R2dbcSettings.scala	91
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	394
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/ContinuousQuery.scala	142
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/MonoToFuture.scala	35
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/PubSub.scala	56
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/R2dbcExecutor.scala	248
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/Sql.scala	59
core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/JournalDao.scala	251
core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/R2dbcJournal.scala	192
core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/mysql/MySQLJournalDao.scala	32
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/R2dbcReadJournalProvider.scala	13
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/javadsl/R2dbcReadJournal.scala	74
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/QueryDao.scala	309
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/R2dbcReadJournal.scala	339
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/mysql/MySQLQueryDao.scala	60
core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/R2dbcSnapshotStore.scala	79
core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/SnapshotDao.scala	214
core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/mysql/MySQLSnapshotDao.scala	27
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/R2dbcDurableStateStoreProvider.scala	15
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/javadsl/R2dbcDurableStateStore.scala	64
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/DurableStateDao.scala	384
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/DurableStateExceptionSupport.scala	17
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/R2dbcDurableStateStore.scala	149
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/mysql/MySQLDurableStateDao.scala	59