Method processBatch

analytics/src/main/java/com/chain/analytics/Importer.java:259–391

(final List<Transaction> transactions)

  // the ORA-00001 exception in Oracle instead of client-side to get around
  // that.
  void processBatch(final List<Transaction> transactions) throws SQLException {
    final String insertTxQ = mTransactionsTbl.getInsertStatement();
    final String insertInputQ = mTransactionInputsTbl.getInsertStatement();
    final String insertOutputQ = mTransactionOutputsTbl.getInsertStatement();

    try (Connection conn = mDataSource.getConnection();
        PreparedStatement psTx = conn.prepareStatement(insertTxQ);
        PreparedStatement psIn = conn.prepareStatement(insertInputQ);
        PreparedStatement psOut = conn.prepareStatement(insertOutputQ);
        PreparedStatement psSpent = conn.prepareStatement(SQL_MARK_SPENT_QUERY)) {

      // Manage our own SQL transactions so we can make this whole
      // blockchain transaction atomic.
      conn.setAutoCommit(false);

      for (Transaction tx : transactions) {
        try {
          ThreadContext.put("tx_id", tx.id);
          logger.debug("Importing transaction {}", tx.id);

          // Insert the transaction itself.
          psTx.setString(1, tx.id);
          psTx.setLong(2, tx.blockHeight);
          psTx.setTimestamp(3, new Timestamp(tx.timestamp.getTime()));
          psTx.setInt(4, tx.position);
          psTx.setString(5, "yes".equals(tx.isLocal) ? TRUE : FALSE);
          psTx.setBlob(6, asJsonBlob(tx.referenceData));
          psTx.setBlob(7, asJsonBlob(tx));
          for (int j = 0; j < mConfig.transactionColumns.size(); j++) {
            Config.CustomColumn col = mConfig.transactionColumns.get(j);
            Object value = col.jsonPath.extract(tx);
            psTx.setObject(8 + j, value, col.type.getType());
          }

          // TODO(jackson): We can't use addBatch in Oracle
          // earlier than 12.1. If customers need support for
          // Oracle < 12.1, we'll need to use the deprecated
          // OraclePreparedStatement.setExecuteBatch method:
          // http://docs.oracle.com/cd/B28359_01/java.111/b31224/oraperf.htm
          psTx.addBatch();

          // Insert each of the inputs.
          boolean spentOutput = false;
          for (int i = 0; i < tx.inputs.size(); i++) {
            final Transaction.Input input = tx.inputs.get(i);

            psIn.setString(1, tx.id);
            psIn.setInt(2, i);
            psIn.setString(3, input.type);
            psIn.setString(4, input.assetId);
            psIn.setString(5, input.assetAlias);
            psIn.setBlob(6, asJsonBlob(input.assetDefinition));
            psIn.setBlob(7, asJsonBlob(input.assetTags));
            psIn.setString(8, "yes".equals(input.assetIsLocal) ? TRUE : FALSE);
            psIn.setLong(9, input.amount);
            psIn.setString(10, input.accountId);
            psIn.setString(11, input.accountAlias);
            psIn.setBlob(12, asJsonBlob(input.accountTags));