public void validateInput()

in java/src/main/java/com/google/cloud/dataproc/templates/jdbc/JDBCToSpanner.java [111:134]

• 21 lines of code
• 7 McCabe index (conditional complexity)

  public void validateInput() {
    jdbcProperties.put(JDBCOptions.JDBC_URL(), config.getJdbcURL());
    jdbcProperties.put(JDBCOptions.JDBC_DRIVER_CLASS(), config.getJdbcDriverClassName());
    jdbcProperties.put(JDBCOptions.JDBC_TABLE_NAME(), config.getSQL());

    if (StringUtils.isNotBlank(config.getJdbcSQLPartitionColumn())
        && StringUtils.isNotBlank(config.getJdbcSQLLowerBound())
        && StringUtils.isNotBlank(config.getJdbcSQLUpperBound())
        && StringUtils.isNotBlank(config.getJdbcSQLNumPartitions())) {
      jdbcProperties.put(JDBCOptions.JDBC_PARTITION_COLUMN(), config.getJdbcSQLPartitionColumn());
      jdbcProperties.put(JDBCOptions.JDBC_UPPER_BOUND(), config.getJdbcSQLUpperBound());
      jdbcProperties.put(JDBCOptions.JDBC_LOWER_BOUND(), config.getJdbcSQLLowerBound());
      jdbcProperties.put(JDBCOptions.JDBC_NUM_PARTITIONS(), config.getJdbcSQLNumPartitions());
    }

    if (StringUtils.isNotBlank(config.getJdbcFetchSize())) {
      jdbcProperties.put(JDBCOptions.JDBC_BATCH_FETCH_SIZE(), config.getJdbcFetchSize());
    }

    if (StringUtils.isNotBlank(config.getJdbcSessionInitStatement())) {
      jdbcProperties.put(
          JDBCOptions.JDBC_SESSION_INIT_STATEMENT(), config.getJdbcSessionInitStatement());
    }
  }