Java 类org.springframework.jdbc.core.ColumnMapRowMapper 实例源码

项目:airsonic    文件:DBController.java   
@RequestMapping(method = { RequestMethod.GET, RequestMethod.POST })
protected ModelAndView handleRequestInternal(HttpServletRequest request, HttpServletResponse response) throws Exception {
    Map<String, Object> map = new HashMap<String, Object>();

    String query = request.getParameter("query");
    if (query != null) {
        map.put("query", query);

        try {
            List<?> result = daoHelper.getJdbcTemplate().query(query, new ColumnMapRowMapper());
            map.put("result", result);
        } catch (DataAccessException x) {
            map.put("error", ExceptionUtils.getRootCause(x).getMessage());
        }
    }

    return new ModelAndView("db","model",map);
}
项目:compass    文件:ShardJdbcTemplate.java   
@SuppressWarnings({ "unchecked", "rawtypes" })
@Override
   public List<Map<String, Object>> query(String sql, Object[] args, AggregationDescriptor descriptor) {
    Assert.notNull(sql, "sql must not be null");
    Assert.notNull(descriptor, "AggregationDescriptor must not be null");

       ShardOperationProcessor processor = null;

       if (descriptor.needGroupBy() || descriptor.needAggregation()) {
           processor = this.getAggregationProcessor(descriptor);
       } else {
           processor = this.getNonAggregationProcessor(new ColumnMapRowMapper());
       }

       List<Map<String, Object>> resultList = (List<Map<String, Object>>) this.process(sql, args, processor);
       AggregationUtil.sortIfNecessary(descriptor, resultList);

       return AggregationUtil.limitIfNecessary(descriptor, resultList);
   }
项目:tddl5    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_不设i() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rw, ds1:r, ds2:r, ds3:r"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select 1 from dual"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(2);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds2", "select 1 from dual"));
}
项目:tddl5    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_设单个in() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi5, ds1:ri6, ds2:ri7, ds3:ri8"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(6);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select 1 from dual"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(8);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds3", "select 1 from dual"));
}
项目:tddl5    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_设多个i分流() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi0, ds1:ri0, ds2:ri1, ds3:ri1"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(0);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds0", "select") || MockDataSource.hasTrace("", "ds1", "select"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds2", "select") || MockDataSource.hasTrace("", "ds3", "select"));
}
项目:tddl5    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_1个ds设多个i() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi0, ds1:ri0i1, ds2:ri1, ds3:r, ds4:ri3"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(0);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds0", "select") || MockDataSource.hasTrace("", "ds1", "select"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select") || MockDataSource.hasTrace("", "ds2", "select"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(3);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds3", "select") || MockDataSource.hasTrace("", "ds4", "select"));
}
项目:TDDL    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_不设i() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rw, ds1:r, ds2:r, ds3:r"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select 1 from dual"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(2);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds2", "select 1 from dual"));
}
项目:TDDL    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_设单个in() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi5, ds1:ri6, ds2:ri7, ds3:ri8"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(6);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select 1 from dual"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(8);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds3", "select 1 from dual"));
}
项目:TDDL    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_设多个i分流() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi0, ds1:ri0, ds2:ri1, ds3:ri1"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(0);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds0", "select") || MockDataSource.hasTrace("", "ds1", "select"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds2", "select") || MockDataSource.hasTrace("", "ds3", "select"));
}
项目:TDDL    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_1个ds设多个i() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi0, ds1:ri0i1, ds2:ri1, ds3:r, ds4:ri3"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(0);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds0", "select") || MockDataSource.hasTrace("", "ds1", "select"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select") || MockDataSource.hasTrace("", "ds2", "select"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(3);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds3", "select") || MockDataSource.hasTrace("", "ds4", "select"));
}
项目:tddl    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_不设i() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rw, ds1:r, ds2:r, ds3:r"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select 1 from dual"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(2);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds2", "select 1 from dual"));
}
项目:tddl    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_设单个in() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi5, ds1:ri6, ds2:ri7, ds3:ri8"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(6);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select 1 from dual"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(8);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds3", "select 1 from dual"));
}
项目:tddl    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_设多个i分流() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi0, ds1:ri0, ds2:ri1, ds3:ri1"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(0);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds0", "select") || MockDataSource.hasTrace("", "ds1", "select"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds2", "select") || MockDataSource.hasTrace("", "ds3", "select"));
}
项目:tddl    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_1个ds设多个i() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi0, ds1:ri0i1, ds2:ri1, ds3:r, ds4:ri3"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(0);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds0", "select") || MockDataSource.hasTrace("", "ds1", "select"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select") || MockDataSource.hasTrace("", "ds2", "select"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(3);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds3", "select") || MockDataSource.hasTrace("", "ds4", "select"));
}
项目:spring-greenhouse-clickstart    文件:NFJSLoaderTest.java   
private void assertEventData(String title, String timeZone, String startTime, String endTime, String slug) {
    Map<String, Object> externalEventData = jdbcTemplate.queryForObject("select event, sourceId, source from ExternalEvent where sourceId=? and source='NFJS'", new ColumnMapRowMapper(), SHOW_ID);
    Long eventId = (Long) externalEventData.get("event");
    assertEquals(Long.valueOf(1), eventId);
    assertEquals(Long.valueOf(SHOW_ID), externalEventData.get("sourceId"));
    assertEquals("NFJS", externalEventData.get("source"));

    Map<String, Object> eventData = jdbcTemplate.queryForObject("select id,  title, timeZone, startTime, endTime, slug, description, memberGroup from Event where id=?", new ColumnMapRowMapper(), eventId);
    assertEquals(eventId, eventData.get("id"));
    assertEquals(title, eventData.get("title"));
    assertEquals(timeZone, eventData.get("timeZone"));
    assertEquals(startTime, eventData.get("startTime").toString());
    assertEquals(endTime, eventData.get("endTime").toString());
    assertEquals(slug, eventData.get("slug"));
    assertNull(eventData.get("description"));
    assertEquals(1L, eventData.get("memberGroup"));
}
项目:spring-greenhouse-clickstart    文件:NFJSLoaderTest.java   
private void assertLeaderData(String name, String bio, String personalUrl, String twitterUsername) {
    Map<String, Object> externalLeaderData = jdbcTemplate.queryForObject("select leader, sourceId, source from ExternalLeader where source='NFJS' and sourceId=?", new ColumnMapRowMapper(), 38);
    Long leaderId = (Long) externalLeaderData.get("leader");
    assertEquals(Long.valueOf(15), leaderId);
    assertEquals(38L, externalLeaderData.get("sourceId"));
    assertEquals("NFJS", externalLeaderData.get("source"));

    Map<String, Object> leaderData = jdbcTemplate.queryForObject("select id, name, company, title, location, bio, personalUrl, companyUrl, twitterUsername, member from Leader where id=?", new ColumnMapRowMapper(), leaderId);
    assertEquals(leaderId, leaderData.get("id"));
    assertEquals(name, leaderData.get("name"));
    assertNull(leaderData.get("company"));
    assertNull(leaderData.get("title"));
    assertNull(leaderData.get("location"));
    assertEquals(bio, leaderData.get("bio").toString().trim());
    assertEquals(personalUrl, leaderData.get("personalUrl"));
    assertNull(leaderData.get("companyUrl"));
    assertEquals(twitterUsername, leaderData.get("twitterUsername"));
    assertNull(leaderData.get("member")); // TODO: Might want to figure out how to associate this with GH member table
}
项目:lams    文件:OracleCallMetaDataProvider.java   
@Override
public SqlParameter createDefaultOutParameter(String parameterName, CallParameterMetaData meta) {
    if (meta.getSqlType() == Types.OTHER && REF_CURSOR_NAME.equals(meta.getTypeName())) {
        return new SqlOutParameter(parameterName, getRefCursorSqlType(), new ColumnMapRowMapper());
    }
    else {
        return super.createDefaultOutParameter(parameterName, meta);
    }
}
项目:lams    文件:PostgresCallMetaDataProvider.java   
@Override
public SqlParameter createDefaultOutParameter(String parameterName, CallParameterMetaData meta) {
    if (meta.getSqlType() == Types.OTHER && "refcursor".equals(meta.getTypeName())) {
        return new SqlOutParameter(parameterName, getRefCursorSqlType(), new ColumnMapRowMapper());
    }
    else {
        return super.createDefaultOutParameter(parameterName, meta);
    }
}
项目:pub-service    文件:LowerCaseJdbcTemplate.java   
@Override
protected RowMapper getColumnMapRowMapper() {
    if("2".equals(EopSetting.DBTYPE)){
        return new OracleColumnMapRowMapper();
    }else if("1".equals(EopSetting.DBTYPE)){
        return new MySqlColumnMapRowMapper();
    }else{
        return new ColumnMapRowMapper();
    }
}
项目:spring4-understanding    文件:OracleCallMetaDataProvider.java   
@Override
public SqlParameter createDefaultOutParameter(String parameterName, CallParameterMetaData meta) {
    if (meta.getSqlType() == Types.OTHER && REF_CURSOR_NAME.equals(meta.getTypeName())) {
        return new SqlOutParameter(parameterName, getRefCursorSqlType(), new ColumnMapRowMapper());
    }
    else {
        return super.createDefaultOutParameter(parameterName, meta);
    }
}
项目:spring4-understanding    文件:PostgresCallMetaDataProvider.java   
@Override
public SqlParameter createDefaultOutParameter(String parameterName, CallParameterMetaData meta) {
    if (meta.getSqlType() == Types.OTHER && "refcursor".equals(meta.getTypeName())) {
        return new SqlOutParameter(parameterName, getRefCursorSqlType(), new ColumnMapRowMapper());
    }
    else {
        return super.createDefaultOutParameter(parameterName, meta);
    }
}
项目:spring-boot    文件:JdbcTemplateUtils.java   
/**
 * Map 包装
 */
public static PageBean queryPageByMapMapperNativeSqlString(final JdbcTemplate jdbcTemplate, final SqlUtils.Dialect dbDialect,
                                                           final String queryNativeSql, Object[] queryArgs,
                                                           final String countNativeSql, Object[] countArgs,
                                                           int currentPageNo, int pageSize) {
    return queryPageByNativeSqlString(jdbcTemplate, dbDialect,
            queryNativeSql, queryArgs,
            countNativeSql, countArgs,
            currentPageNo, pageSize, new ColumnMapRowMapper());
}
项目:Nicole    文件:DaoHandler.java   
private RowMapper<Map<String, Object>> getColumnMapRowMapper() {
    if (getKeyType().equalsIgnoreCase(LOWER_KEY)) {
        return new MiniColumnMapRowMapper();
    } else if (getKeyType().equalsIgnoreCase(UPPER_KEY)) {
        return new ColumnMapRowMapper();
    } else {
        return new MiniColumnOriginalMapRowMapper();
    }
}
项目:maker    文件:MiniDaoHandler.java   
/**
 *根据参数设置map的key大小写
 **/
private RowMapper<Map<String,Object>> getColumnMapRowMapper() {
    if(getKeyType().equalsIgnoreCase(LOWER_KEY)){
        return new MiniColumnMapRowMapper();
    }else if(getKeyType().equalsIgnoreCase(UPPER_KEY)){
        return new ColumnMapRowMapper();
    }else{
        return new MiniColumnOriginalMapRowMapper();
    }
}
项目:marklogic-spring-batch    文件:AllTablesItemReader.java   
/**
 * @param tableName
 * @param executionContext
 * @return a JdbcCursorItemReader for the given table name. Override this method to alert the SQL statement that's
 * used for a particular table.
 */
protected JdbcCursorItemReader<Map<String, Object>> buildTableReader(String tableName, ExecutionContext executionContext) {
    JdbcCursorItemReader<Map<String, Object>> reader = new JdbcCursorItemReader<>();
    reader.setDataSource(dataSource);
    reader.setRowMapper(new ColumnMapRowMapper());
    reader.setSql(getSqlQueryForTable(tableName));
    reader.open(executionContext);
    return reader;
}
项目:tddl5    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_设单个i不加数字等同于没设() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi, ds1:ri, ds2:ri, ds3:ri"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select 1 from dual"));
}
项目:TDDL    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_设单个i不加数字等同于没设() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi, ds1:ri, ds2:ri, ds3:ri"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select 1 from dual"));
}
项目:tddl    文件:ThreadLocalDataSourceIndexTest.java   
@Test
public void test_设单个i不加数字等同于没设() {
    JdbcTemplate jt = new JdbcTemplate(createGroupDataSource("ds0:rwi, ds1:ri, ds2:ri, ds3:ri"));

    MockDataSource.clearTrace();
    GroupDataSourceRouteHelper.executeByGroupDataSourceIndex(1);
    jt.query("select 1 from dual", new Object[] {}, new ColumnMapRowMapper());
    MockDataSource.showTrace();
    Assert.assertTrue(MockDataSource.hasTrace("", "ds1", "select 1 from dual"));
}
项目:class-guard    文件:OracleCallMetaDataProvider.java   
@Override
public SqlParameter createDefaultOutParameter(String parameterName, CallParameterMetaData meta) {
    if (meta.getSqlType() == Types.OTHER && REF_CURSOR_NAME.equals(meta.getTypeName())) {
        return new SqlOutParameter(parameterName, getRefCursorSqlType(), new ColumnMapRowMapper());
    }
    else {
        return super.createDefaultOutParameter(parameterName, meta);
    }
}
项目:class-guard    文件:PostgresCallMetaDataProvider.java   
@Override
public SqlParameter createDefaultOutParameter(String parameterName, CallParameterMetaData meta) {
    if (meta.getSqlType() == Types.OTHER && "refcursor".equals(meta.getTypeName())) {
        return new SqlOutParameter(parameterName, getRefCursorSqlType(), new ColumnMapRowMapper());
    }
    else {
        return super.createDefaultOutParameter(parameterName, meta);
    }
}
项目:panelized    文件:SelectCreatorDataProvider.java   
@SuppressWarnings("unchecked")
public Iterator<RowMap> iterator(long first, long count) {

    SelectCreator creator = selectCreator.clone();

    applyFilters(creator);
    applyQuickFilters(creator);

    if (getSort() != null) {
        creator.orderBy(getSort().getProperty(), getSort().isAscending());
    }

    if (getSecondarySort() != null) {
        creator.orderBy(getSecondarySort().getProperty(), getSecondarySort().isAscending());
    }

    creator.orderBy(uniqueColumn);

    log.debug("Executing query: " + creator);

    JdbcTemplate t = new JdbcTemplate(getDataSource());

    @SuppressWarnings("rawtypes")
    RowMapper rowMapper = new ColumnMapRowMapper() {
        @Override
        protected Map<String, Object> createColumnMap(int columnCount) {
            return new RowMap();
        }
        @Override
        public Map<String, Object> mapRow(ResultSet rs, int rowNum) throws SQLException {
            Map<String, Object> row = super.mapRow(rs, rowNum);
            processRow((RowMap) row);
            return row;
        }
    };
    return t.query(creator.page(DIALECT, (int) count, (int) first), (RowMapper<RowMap>) rowMapper).iterator();

}
项目:spring-greenhouse-clickstart    文件:NFJSLoaderTest.java   
private void assertVenueData(String name, String postalAddress, double latitude, double longitude, String locationHint, long createdBy) {
    Map<String, Object> eventVenueData = jdbcTemplate.queryForObject("select event, venue from EventVenue where event=?", new ColumnMapRowMapper(), 1);
    assertEquals(Long.valueOf(1), eventVenueData.get("event"));
    Long venueId = (Long) eventVenueData.get("venue");
    assertEquals(Long.valueOf(1), venueId);

    Map<String, Object> venueData = jdbcTemplate.queryForObject("select id, name, postalAddress, latitude, longitude, locationHint, createdBy from Venue where id=?", new ColumnMapRowMapper(), venueId);
    assertEquals(Long.valueOf(1), venueData.get("id"));
    assertEquals(name, venueData.get("name"));
    assertEquals(postalAddress, venueData.get("postalAddress"));
    assertEquals(latitude, venueData.get("latitude"));
    assertEquals(longitude, venueData.get("longitude"));
    assertEquals(locationHint, venueData.get("locationHint"));
    assertEquals(createdBy, venueData.get("createdBy"));
}
项目:spring-greenhouse-clickstart    文件:NFJSLoaderTest.java   
private void assertEventTimeSlotData(long id, long eventId, String label, String startTime, String endTime) {
    Map<String, Object> externalEventTimeSlotData = jdbcTemplate.queryForObject("select timeSlot, sourceId, source from ExternalEventTimeSlot where timeSlot=?", new ColumnMapRowMapper(), id);
    assertEquals(id, externalEventTimeSlotData.get("timeSlot"));
    assertEquals(6311L, externalEventTimeSlotData.get("sourceId"));
    assertEquals("NFJS", externalEventTimeSlotData.get("source"));

    Map<String, Object> eventTimeSlotData = jdbcTemplate.queryForObject("select id, event, label, startTime, endTime from EventTimeSlot where id=?", new ColumnMapRowMapper(), 16);
    assertEquals(id, eventTimeSlotData.get("id"));
    assertEquals(eventId, eventTimeSlotData.get("event"));
    assertEquals(label, eventTimeSlotData.get("label"));
    assertEquals(startTime, eventTimeSlotData.get("startTime").toString());
    assertEquals(endTime, eventTimeSlotData.get("endTime").toString());
}
项目:quickmon    文件:JdbcSampler.java   
@Override
public List<Map<String, Object>> sample() {
    JdbcTemplate temp = new JdbcTemplate();
    List<Map<String, Object>> result = temp.query(sql, new ColumnMapRowMapper());
    return result;
}
项目:lams    文件:NamedParameterJdbcTemplate.java   
@Override
public Map<String, Object> queryForMap(String sql, SqlParameterSource paramSource) throws DataAccessException {
    return queryForObject(sql, paramSource, new ColumnMapRowMapper());
}
项目:lams    文件:NamedParameterJdbcTemplate.java   
@Override
public Map<String, Object> queryForMap(String sql, Map<String, ?> paramMap) throws DataAccessException {
    return queryForObject(sql, paramMap, new ColumnMapRowMapper());
}
项目:lams    文件:NamedParameterJdbcTemplate.java   
@Override
public List<Map<String, Object>> queryForList(String sql, SqlParameterSource paramSource)
        throws DataAccessException {

    return query(sql, paramSource, new ColumnMapRowMapper());
}
项目:spring4-understanding    文件:NamedParameterJdbcTemplate.java   
@Override
public Map<String, Object> queryForMap(String sql, SqlParameterSource paramSource) throws DataAccessException {
    return queryForObject(sql, paramSource, new ColumnMapRowMapper());
}
项目:spring4-understanding    文件:NamedParameterJdbcTemplate.java   
@Override
public Map<String, Object> queryForMap(String sql, Map<String, ?> paramMap) throws DataAccessException {
    return queryForObject(sql, paramMap, new ColumnMapRowMapper());
}
项目:spring4-understanding    文件:NamedParameterJdbcTemplate.java   
@Override
public List<Map<String, Object>> queryForList(String sql, SqlParameterSource paramSource)
        throws DataAccessException {

    return query(sql, paramSource, new ColumnMapRowMapper());
}