franciskim

var Promise = require('bluebird');
var MongoDB = Promise.promisifyAll(require("mongodb"));
var MongoClient = Promise.promisifyAll(MongoDB.MongoClient);
var cheerio = require('cheerio');
var http = require('http');

var urls = [
    'http://www.magentocommerce.com/certification/directory/index/?q=&country_id=AU&region_id=&region=vic&certificate_type=',
    'http://www.magentocommerce.com/certification/directory/index/?q=&country_id=AU&region_id=&region=victoria&certificate_type='
];

codebje

public <T> T streamQuery(String sql, Function<Stream<SqlRowSet>, ? extends T> streamer, Object... args) {
  return jdbcTemplate.query(sql, resultSet -> {
    final SqlRowSet rowSet = new ResultSetWrappingSqlRowSet(resultSet);
    final boolean parallel = false;

    // The ResultSet API has a slight impedance mismatch with Iterators, so this conditional
    // simply returns an empty iterator if there are no results
    if (!rowSet.next()) {
      return streamer.apply(StreamSupport.stream(Spliterators.emptySpliterator(), parallel));
    }