Packages

object SchemaUtils

Source
SchemaUtils.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SchemaUtils
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. 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, or pekko-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 or jdbc-snapshot-store.

    Annotations
    @ApiMayChange()
  5. 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, or pekko-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()
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. 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 with use-shared-db, it will use the pekko-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()
  9. 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 with use-shared-db, it will use the pekko-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()
  10. 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 with use-shared-db, it will use the pekko-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()
  11. 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 with use-shared-db, it will use the pekko-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()
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  15. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped