code: public Collector<T> getResults(Connection conn, DataObject object, Collector<T> collector) throws Exception {
          return executeSelect(conn, object, new ResultSetMapper<Collector<T>>(collector));
      }
docs: Executes the query and passes the results to a Collector.