void init()

in src/main/java/org/apache/fineract/cn/cassandra/core/CassandraJourney.java [79:95]

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

  void init() {
    final KeyspaceMetadata keyspaceMetadata =
        session.getCluster().getMetadata().getKeyspace(session.getLoggedKeyspace());
    final TableMetadata schemaTable = keyspaceMetadata.getTable(ParseUtils.quote(this.schemaTableName));
    if (schemaTable == null) {
      try {
        session.execute(SchemaBuilder
            .createTable(this.schemaTableName)
            .addPartitionKey("version", DataType.text())
            .addColumn("hash_value", DataType.cint())
            .buildInternal()
        );
      } catch (final Throwable th) {
        this.logger.warn("Schema table for '{}' already exists.", this.applicationName.getServiceName());
      }
    }
  }