object SchemaUtils
- Source
- SchemaUtils.scala
- Alphabetic
- By Inheritance
- SchemaUtils
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def applyScript(script: String, separator: String, configKey: String)(implicit actorSystem: ClassicActorSystemProvider): Future[Done]
This method can be used to load alternative DDL scripts.
This method can be used to load alternative DDL scripts.
This utility method is intended to be used for testing only. For production, it's recommended to create the table with DDL statements before the system is started.
It will use the database settings found under
configKey
, orpekko-persistence-jdbc.shared-databases
if configured so. See https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#sharing-the-database-connection-pool-between-the-journals for details.- script
the DDL script. The passed
script
can contain more then one SQL statements.- separator
used to separate the different DDL statements.
- configKey
the database configuration key to use. Can be
jdbc-journal
orjdbc-snapshot-store
.
- Annotations
- @ApiMayChange()
- def applyScript(script: String)(implicit actorSystem: ClassicActorSystemProvider): Future[Done]
This method can be used to load alternative DDL scripts.
This method can be used to load alternative DDL scripts.
This utility method is intended to be used for testing only. For production, it's recommended to run any DDL statements before the system is started.
It will use the database settings found under
jdbc-journal
, orpekko-persistence-jdbc.shared-databases
if configured so. See https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#sharing-the-database-connection-pool-between-the-journals for details.- script
the DDL script. The passed script can contain more then one SQL statements separated by a ; (semi-colon).
- Annotations
- @ApiMayChange()
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def createIfNotExists(configKey: String)(implicit actorSystem: ClassicActorSystemProvider): Future[Done]
Creates the schema for both the journal and the snapshot table using the default schema definition.
Creates the schema for both the journal and the snapshot table using the default schema definition.
For information about the different schemas and supported databases consult https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#database-schema
This utility method is intended to be used for testing only. For production, it's recommended to run any DDL statements before the system is started.
This method will automatically detects the configured database using the settings from
configKey
config. If configured withuse-shared-db
, it will use thepekko-persistence-jdbc.shared-databases
definition instead. See https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#sharing-the-database-connection-pool-between-the-journals for details.- configKey
the database journal configuration key to use.
- Annotations
- @ApiMayChange()
- def createIfNotExists()(implicit actorSystem: ClassicActorSystemProvider): Future[Done]
Creates the schema for both the journal and the snapshot table using the default schema definition.
Creates the schema for both the journal and the snapshot table using the default schema definition.
For information about the different schemas and supported databases consult https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#database-schema
This utility method is intended to be used for testing only. For production, it's recommended to run any DDL statements before the system is started.
This method will automatically detects the configured database using the settings from
jdbc-journal
config. If configured withuse-shared-db
, it will use thepekko-persistence-jdbc.shared-databases
definition instead. See https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#sharing-the-database-connection-pool-between-the-journals for details.- Annotations
- @ApiMayChange()
- def dropIfExists(configKey: String)(implicit actorSystem: ClassicActorSystemProvider): Future[Done]
Drops the schema for both the journal and the snapshot table using the default schema definition.
Drops the schema for both the journal and the snapshot table using the default schema definition.
For information about the different schemas and supported databases consult https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#database-schema
This utility method is intended to be used for testing only. For production, it's recommended to run any DDL statements before the system is started.
This method will automatically detects the configured database using the settings from
configKey
config. If configured withuse-shared-db
, it will use thepekko-persistence-jdbc.shared-databases
definition instead. See https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#sharing-the-database-connection-pool-between-the-journals for details.- configKey
the database journal configuration key to use.
- Annotations
- @ApiMayChange()
- def dropIfExists()(implicit actorSystem: ClassicActorSystemProvider): Future[Done]
Drops the schema for both the journal and the snapshot table using the default schema definition.
Drops the schema for both the journal and the snapshot table using the default schema definition.
For information about the different schemas and supported databases consult https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#database-schema
This utility method is intended to be used for testing only. For production, it's recommended to run any DDL statements before the system is started.
This method will automatically detects the configured database using the settings from
jdbc-journal
config. If configured withuse-shared-db
, it will use thepekko-persistence-jdbc.shared-databases
definition instead. See https://pekko.apache.org/docs/pekko-persistence-jdbc/current/index.html#sharing-the-database-connection-pool-between-the-journals for details.- Annotations
- @ApiMayChange()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()