def this()

in jdbc/src/main/scala/org/apache/pekko/projection/jdbc/internal/Dialect.scala [187:237]

• 32 lines of code
• 3 McCabe index (conditional complexity)

  def this(tableName: String, managementTableName: String, lowerCase: Boolean) =
    this(None, tableName, managementTableName, lowerCase)

  def transform(stmt: String): String =
    if (lowerCase) toRootLowerCase(stmt)
    else stmt

  private val table = transform(schema.map(s => s""""$s"."$tableName"""").getOrElse(s""""$tableName""""))

  private val managementTable = transform(
    schema.map(s => s""""$s"."$managementTableName"""").getOrElse(s""""$managementTableName""""))

  override val createTableStatements: immutable.Seq[String] =
    DialectDefaults.createTableStatement(table).map(s => transform(s))

  override val dropTableStatement: String = transform(DialectDefaults.dropTableStatement(table))

  override val readOffsetQuery: String = transform(DialectDefaults.readOffsetQuery(table))

  override val clearOffsetStatement: String = transform(DialectDefaults.clearOffsetStatement(table))

  override def insertStatement(): String = transform(DialectDefaults.insertStatement(table))

  override def updateStatement(): String = transform(DialectDefaults.updateStatement(table))

  override val createManagementTableStatements: immutable.Seq[String] =
    DialectDefaults.createManagementTableStatement(managementTable).map(s => transform(s))

  override val dropManagementTableStatement: String = transform(
    DialectDefaults.dropManagementTableStatement(managementTable))

  override val readManagementStateQuery: String = transform(DialectDefaults.readManagementStateQuery(managementTable))

  override def insertManagementStatement(): String =
    transform(DialectDefaults.insertManagementStatement(managementTable))

  override def updateManagementStatement(): String =
    transform(DialectDefaults.updateManagementStatement(managementTable))

}

/**
 * INTERNAL API
 */
@InternalApi
private[projection] case class PostgresDialect(
    schema: Option[String],
    tableName: String,
    managementTableName: String,
    lowerCase: Boolean)
    extends Dialect {