def createKeyspaceAndTable()

in cassandra/src/main/scala/org/apache/pekko/projection/cassandra/internal/CassandraOffsetStore.scala [126:150]

• 25 lines of code
• 2 McCabe index (conditional complexity)

  def createKeyspaceAndTable(): Future[Done] = {
    for {
      _ <- session.executeDDL(
        s"CREATE KEYSPACE IF NOT EXISTS $keyspace WITH REPLICATION = { 'class' : 'SimpleStrategy','replication_factor':1 }")
      _ <- session.executeDDL(s"""
        |CREATE TABLE IF NOT EXISTS $keyspace.$table (
        |  projection_name text,
        |  partition int,
        |  projection_key text,
        |  offset text,
        |  manifest text,
        |  last_updated timestamp,
        |  PRIMARY KEY ((projection_name, partition), projection_key))
        """.stripMargin.trim)
      _ <- session.executeDDL(s"""
        |CREATE TABLE IF NOT EXISTS $keyspace.$managementTable (
        |  projection_name text,
        |  partition int,
        |  projection_key text,
        |  paused boolean,
        |  last_updated timestamp,
        |  PRIMARY KEY ((projection_name, partition), projection_key))
        """.stripMargin.trim)
    } yield Done
  }