src/main/java/com/s24/search/solr/analysis/jdbc/SimpleJdbcReader.java
@Override
   public Reader getReader() {
      if (dataSource == null) {
         if (ignore) {
            return new StringReader("");
         }
         throw new IllegalArgumentException("Missing data source.");
      }

      QueryRunner runner = new QueryRunner(dataSource);
      try {
         logger.info("Querying for data using {}", sql);
         List<String> content = runner.query(sql, SINGLE_LINE_RESULT_SET_HANDLER);
         logger.info("Loaded {} lines", content.size());

         // return joined
         return new StringReader(Joiner.on('\n').join(content));
      } catch (SQLException e) {
         throw new IllegalArgumentException("Failed to load data from the database", e);
      }
   }
@Override
   public Reader getReader() {
      if (dataSource == null) {
         if (ignore) {
            return new StringReader("");
         }
         throw new IllegalArgumentException("Missing data source.");
      }

      QueryRunner runner = new QueryRunner(dataSource);
      try {
         logger.info("Querying for data using {}", sql);
         List<String> content = runner.query(sql, SINGLE_LINE_RESULT_SET_HANDLER);
         logger.info("Loaded {} lines", content.size());

         // return joined
         return new StringReader(Joiner.on('\n').join(content));
      } catch (SQLException e) {
         throw new IllegalArgumentException("Failed to load data from the database", e);
      }
   }
@ Override public Reader getReader ( ) { if ( dataSource == null ) { if ( ignore ) { return new StringReader ( "" ) ; } throw new IllegalArgumentException ( "Missing data source." ) ; } QueryRunner runner = new QueryRunner ( dataSource ) ; try { logger . info ( "Querying for data using {}" , sql ) ; List < String > content = runner . query ( sql , SINGLE_LINE_RESULT_SET_HANDLER ) ; logger . info ( "Loaded {} lines" , content . size ( ) ) ; // return joined return new StringReader ( Joiner . on ( ' ' ) . join ( content ) ) ; } catch ( SQLException e ) { throw new IllegalArgumentException ( "Failed to load data from the database" , e ) ; } }
{@inheritDoc}
{