Path Lines of Code 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 87 core/src/main/resources/schema/oracle/oracle-drop-schema-legacy.sql 12 core/src/main/resources/schema/oracle/oracle-drop-schema.sql 18 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 57 core/src/main/resources/schema/sqlserver/sqlserver-drop-schema-legacy.sql 2 core/src/main/resources/schema/sqlserver/sqlserver-drop-schema.sql 4 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 202 core/src/main/scala/org/apache/pekko/persistence/jdbc/db/SlickDatabase.scala 60 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 101 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 74 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/DefaultJournalDao.scala 96 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 66 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalTables.scala 82 core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalDao.scala 92 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 50 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 18 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/JdbcReadJournalProvider.scala 11 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 53 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/ReadJournalDao.scala 20 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 130 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/dao/legacy/ReadJournalQueries.scala 50 core/src/main/scala/org/apache/pekko/persistence/jdbc/query/javadsl/JdbcReadJournal.scala 46 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 186 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 83 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 64 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 44 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/DurableStateQueries.scala 93 core/src/main/scala/org/apache/pekko/persistence/jdbc/state/DurableStateTables.scala 45 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 47 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/DurableStateExceptionSupport.scala 17 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 197 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 139 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