public void begin()

in flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionImpl.java [62:82]

• 19 lines of code
• 5 McCabe index (conditional complexity)

  public void begin() {
    if (!active) {
      throw new JdbcChannelException("Inactive transaction");
    }
    if (count == 0) {
      // Lease a connection now
      try {
        connection = dataSource.getConnection();
      } catch (SQLException ex) {
        throw new JdbcChannelException("Unable to lease connection", ex);
      }
      // Clear any prior warnings on the connection
      try {
        connection.clearWarnings();
      } catch (SQLException ex) {
        LOGGER.error("Error while clearing warnings: " + ex.getErrorCode(), ex);
      }
    }
    count++;
    LOGGER.trace("Tx count-begin: " + count + ", rollback: " + rollback);
  }