public void createSchemaObjects()

in flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java [412:436]

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

  public void createSchemaObjects(boolean createForeignKeys,
      boolean createIndex) {
    runQuery(QUERY_CREATE_SCHEMA_FLUME);
    runQuery(QUERY_CREATE_TABLE_FL_EVENT);

    if (createForeignKeys) {
      runQuery(QUERY_CREATE_TABLE_FL_PLSPILL_FK);
      runQuery(QUERY_CREATE_TABLE_FL_HEADER_FK);
      runQuery(QUERY_CREATE_TABLE_FL_NMSPILL_FK);
      runQuery(QUERY_CREATE_TABLE_FL_VLSPILL_FK);
    } else {
      runQuery(QUERY_CREATE_TABLE_FL_PLSPILL_NOFK);
      runQuery(QUERY_CREATE_TABLE_FL_HEADER_NOFK);
      runQuery(QUERY_CREATE_TABLE_FL_NMSPILL_NOFK);
      runQuery(QUERY_CREATE_TABLE_FL_VLSPILL_NOFK);
    }

    if (createIndex) {
      runQuery(QUERY_CREATE_INDEX_FLE_CHANNEL);
      runQuery(QUERY_CREATE_INDEX_FLH_EVENT);
      runQuery(QUERY_CREATE_INDEX_FLP_EVENT);
      runQuery(QUERY_CREATE_INDEX_FLN_HEADER);
      runQuery(QUERY_CREATE_INDEX_FLV_HEADER);
    }
  }