Path Lines of Code build.sbt 89 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/AllPersistenceIdsTest.scala 14 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByPersistenceIdTest.scala 20 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByTagTest.scala 20 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/CurrentPersistenceIdsTest.scala 20 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/EventAdapterTest.scala 12 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/EventsByPersistenceIdTest.scala 18 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/EventsByTagTest.scala 14 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/HardDeleteQueryTest.scala 12 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/JdbcJournalPerfSpec.scala 38 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/JdbcJournalSpec.scala 15 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/JdbcSnapshotStoreSpec.scala 13 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/JournalDaoStreamMessagesMemoryTest.scala 20 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/JournalSequenceActorTest.scala 20 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/PostgresDurableStateStorePluginSpec.scala 6 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/PostgresScalaJdbcDurableStateChangesByTagTest.scala 11 core/src/it/scala/org/apache/pekko/persistence/jdbc/integration/StoreOnlySerializableMessagesTest.scala 14 core/src/main/resources/schema/h2/h2-create-schema-legacy.sql 30 core/src/main/resources/schema/h2/h2-create-schema.sql 51 core/src/main/resources/schema/h2/h2-drop-schema-legacy.sql 3 core/src/main/resources/schema/h2/h2-drop-schema.sql 5 core/src/main/resources/schema/mysql/mysql-create-schema-legacy.sql 17 core/src/main/resources/schema/mysql/mysql-create-schema.sql 35 core/src/main/resources/schema/mysql/mysql-drop-schema-legacy.sql 2 core/src/main/resources/schema/mysql/mysql-drop-schema.sql 3 core/src/main/resources/schema/oracle/oracle-create-schema-legacy.sql 39 core/src/main/resources/schema/oracle/oracle-create-schema.sql 52 core/src/main/resources/schema/oracle/oracle-drop-schema-legacy.sql 14 core/src/main/resources/schema/oracle/oracle-drop-schema.sql 14 core/src/main/resources/schema/postgres/postgres-create-schema-legacy.sql 30 core/src/main/resources/schema/postgres/postgres-create-schema.sql 51 core/src/main/resources/schema/postgres/postgres-drop-schema-legacy.sql 3 core/src/main/resources/schema/postgres/postgres-drop-schema.sql 4 core/src/main/resources/schema/sqlserver/sqlserver-create-schema-legacy.sql 22 core/src/main/resources/schema/sqlserver/sqlserver-create-schema.sql 38 core/src/main/resources/schema/sqlserver/sqlserver-drop-schema-legacy.sql 2 core/src/main/resources/schema/sqlserver/sqlserver-drop-schema.sql 3 core/src/main/scala/org/apache/pekko/persistence/jdbc/JournalRow.scala 8 core/src/main/scala/org/apache/pekko/persistence/jdbc/MissingElements.scala 23 core/src/main/scala/org/apache/pekko/persistence/jdbc/PekkoSerialization.scala 47 core/src/main/scala/org/apache/pekko/persistence/jdbc/config/PekkoPersistenceConfig.scala 200 core/src/main/scala/org/apache/pekko/persistence/jdbc/db/SlickDatabase.scala 57 core/src/main/scala/org/apache/pekko/persistence/jdbc/db/SlickExtension.scala 55 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/JdbcAsyncWriteJournal.scala 104 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/BaseDao.scala 39 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/BaseJournalDaoWithReadMessages.scala 58 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/DefaultJournalDao.scala 97 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/FlowControl.scala 7 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/H2Compat.scala 16 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalDao.scala 10 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalDaoWithReadMessages.scala 21 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalDaoWithUpdates.scala 6 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalQueries.scala 74 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalTables.scala 76 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalDao.scala 93 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalSerializer.scala 28 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/JournalQueries.scala 59 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/JournalTables.scala 25 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/package.scala 15 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/JdbcReadJournalProvider.scala 10 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActor.scala 107 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/DefaultReadJournalDao.scala 51 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/ReadJournalDao.scala 19 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/ReadJournalQueries.scala 55 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/legacy/ByteArrayReadJournalDao.scala 127 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/legacy/ReadJournalQueries.scala 49 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/javadsl/JdbcReadJournal.scala 37 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/package.scala 14 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala 187 core/src/main/scala/org/apache/pekko/persistence/jdbc/serialization/PersistentReprSerializer.scala 32 core/src/main/scala/org/apache/pekko/persistence/jdbc/serialization/SnapshotSerializer.scala 7 core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/JdbcSnapshotStore.scala 86 core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/DefaultSnapshotDao.scala 105 core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/SnapshotDao.scala 21 core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/SnapshotQueries.scala 47 core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/SnapshotTables.scala 61 core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/ByteArraySnapshotDao.scala 82 core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/ByteArraySnapshotSerializer.scala 24 core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/SnapshotQueries.scala 47 core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/SnapshotTables.scala 41 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/DurableStateQueries.scala 102 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/DurableStateTables.scala 42 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/JdbcDurableStateStoreProvider.scala 32 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/OffsetOps.scala 14 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/SequenceNextValUpdater.scala 32 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/javadsl/JdbcDurableStateStore.scala 42 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala 171 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateStore.scala 185 core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaType.scala 8 core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/internal/SchemaUtilsImpl.scala 121 core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/javadsl/SchemaUtils.scala 34 core/src/main/scala/org/apache/pekko/persistence/jdbc/testkit/scaladsl/SchemaUtils.scala 30 core/src/main/scala/org/apache/pekko/persistence/jdbc/util/BlockingOps.scala 11 core/src/main/scala/org/apache/pekko/persistence/jdbc/util/ByteArrayOps.scala 9 core/src/main/scala/org/apache/pekko/persistence/jdbc/util/ConfigOps.scala 16 core/src/main/scala/org/apache/pekko/persistence/jdbc/util/InputStreamOps.scala 18 core/src/main/scala/org/apache/pekko/persistence/jdbc/util/PluginVersionChecker.scala 13 core/src/main/scala/org/apache/pekko/persistence/jdbc/util/StringOps.scala 7 core/src/main/scala/org/apache/pekko/persistence/jdbc/util/TrySeq.scala 14 migrator/src/it/scala/org/apache/pekko/persistence/jdbc/migrator/integration/JournalMigratorTest.scala 8 migrator/src/it/scala/org/apache/pekko/persistence/jdbc/migrator/integration/SnapshotMigratorTest.scala 8 migrator/src/main/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigrator.scala 102 migrator/src/main/scala/org/apache/pekko/persistence/jdbc/migrator/SnapshotMigrator.scala 64 project/AutomaticModuleName.scala 7 project/CopyrightHeader.scala 80 project/Dependencies.scala 30 project/ProjectAutoPlugin.scala 88 project/plugins.sbt 19