Method main

analytics/src/main/java/com/chain/analytics/Application.java:45–109

(String args[])

  private static final Logger logger = LogManager.getLogger();

  public static void main(String args[]) {
    final String chainUrl = System.getenv(ENV_CHAIN_URL);
    final String chainToken = System.getenv(ENV_CHAIN_TOKEN);
    final String databaseUrl = System.getenv(ENV_DATABASE_URL);

    if (chainUrl == null || "".equals(chainUrl)) {
      logger.fatal("missing {} environment variable", ENV_CHAIN_URL);
      System.exit(1);
    }
    if (databaseUrl == null || "".equals(databaseUrl)) {
      logger.fatal("missing {} environment variable", ENV_DATABASE_URL);
      System.exit(1);
    }

    //
    // Setup the importer. The majority of connectivity and
    // configuration errors should be caught here.
    //
    Importer importer = null;
    try {
      Client.Builder clientBuilder =
          new Client.Builder().addURL(chainUrl).setReadTimeout(120, TimeUnit.SECONDS);
      if (chainToken != null && chainToken.length() > 0) {
        clientBuilder.setAccessToken(chainToken);
      }
      final Client client = clientBuilder.build();

      // Use a connection pool.
      ComboPooledDataSource ds = new ComboPooledDataSource();
      ds.setDriverClass("oracle.jdbc.driver.OracleDriver");
      ds.setJdbcUrl(databaseUrl);
      ds.setTestConnectionOnCheckout(true);

      Config config = new Config();
      config.transactionColumns.add(
          new Config.CustomColumn(
              "acc_id",
              new Schema.Varchar2(64),
              new JsonPath(Arrays.asList("reference_data", "account", "id"))));

      importer = Importer.connect(client, ds, DEFAULT_FEED_ALIAS, config);
    } catch (BadURLException ex) {
      logger.fatal("Unable to parse the Chain Core URL provided \"{}\".", chainUrl, ex);
      System.exit(1);
    } catch (PropertyVetoException ex) {
      logger.fatal("Unable to setup JDBC. Is the Oracle driver in the classpath?", ex);
      System.exit(1);
    } catch (HTTPException | ConnectivityException ex) {
      logger.fatal(
          "Unable to connect to Chain Core at the configured URL \"{}\". "
              + "Double check that the URL is correct and reachable.",
          chainUrl,
          ex);
      System.exit(1);
    } catch (ChainException | SQLException ex) {
      logger.fatal("Unable to initialize importer.", ex);
      System.exit(1);
    }