Java源码示例：org.springframework.jdbc.core.SingleColumnRowMapper
示例1
public int getLastTestId() {
try {
Integer ret = runQuery("select MAX(test_id) from report",
new SingleColumnRowMapper<>(Integer.class));
if (ret == null) {
return -1;
}
return ret.intValue();
}
catch (DataNotFoundException e) {
logger.warn("The query runner returned data not found. Returning -1 as the next test ID");
return -1;
}
}
示例2
public int getLastTestNumber(int testId) {
try {
Integer ret = runQuery("select MAX(test_number) from report where test_id = ?",
new SingleColumnRowMapper<>(Integer.class),
testId);
if (ret == null) {
return -1;
}
return ret.intValue();
}
catch (DataNotFoundException e) {
logger.warn("The query runner returned data not found. Returning -1 as the next test number");
return -1;
}
}
示例3
@Override
@Nullable
public <T> T queryForObject(String sql, SqlParameterSource paramSource, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramSource, new SingleColumnRowMapper<>(requiredType));
}
示例4
@Override
@Nullable
public <T> T queryForObject(String sql, Map<String, ?> paramMap, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramMap, new SingleColumnRowMapper<>(requiredType));
}
示例5
@Override
@Nullable
public <T> T queryForObject(String sql, SqlParameterSource paramSource, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramSource, new SingleColumnRowMapper<>(requiredType));
}
示例6
@Override
@Nullable
public <T> T queryForObject(String sql, Map<String, ?> paramMap, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramMap, new SingleColumnRowMapper<>(requiredType));
}
示例7
/**
* !!! Only supports MySQL
*/
@SuppressWarnings("unchecked")
public static List<String> findSchemas(JdbcTemplate jdbcTemplate, final String schemaPattern) {
try {
if (StringUtils.isEmpty(schemaPattern)) {
return jdbcTemplate.query("show databases", new SingleColumnRowMapper(String.class));
}
return jdbcTemplate.query("show databases like ?",
new Object[]{schemaPattern},
new SingleColumnRowMapper(String.class));
} catch (Exception e) {
logger.error(e.getMessage(), e);
return new ArrayList<String>();
}
}
示例8
private <K> List<K> queryForPlainValueList(Class<K> clzz, String sql, Criteria.ResultMappedCriteria resultMappedCriteria, Dialect dialect, JdbcTemplate jdbcTemplate) {
List<Object> valueList = resultMappedCriteria.getValueList();
if (valueList == null || valueList.isEmpty()) {
return this.jdbcTemplate.query(sql, new SingleColumnRowMapper<>(clzz));
}else {
Object[] arr = dialect.toArr(valueList);
return this.jdbcTemplate.query(sql, arr,
new SingleColumnRowMapper<>(clzz));
}
}
示例9
@Bean
public JdbcCursorItemReader<Long> addressPrinterReader(final DataSource dataSource) throws Exception {
final JdbcCursorItemReader<Long> reader = new JdbcCursorItemReader<>();
reader.setSql(SELECT_ADDRESS_QUERY);
reader.setRowMapper(new SingleColumnRowMapper<>());
reader.setDataSource(dataSource);
reader.setMaxRows(100);
reader.afterPropertiesSet();
return reader;
}
示例10
@Bean
public JdbcCursorItemReader<Long> addressBatchTaskDeletionReader(final DataSource dataSource) throws Exception {
final JdbcCursorItemReader<Long> reader = new JdbcCursorItemReader<>();
reader.setSql(SELECT_BATCH_TASK_ADDRESS_TO_DELETE_QUERY);
reader.setRowMapper(new SingleColumnRowMapper<>());
reader.setDataSource(dataSource);
reader.setMaxRows(50);
reader.afterPropertiesSet();
return reader;
}
示例11
@Override
public <T> List<T> queryForList(String sql, SqlParameterSource paramSource, Class<T> elementType)
throws DataAccessException {
return query(sql, paramSource, new SingleColumnRowMapper<>(elementType));
}
示例12
private <T> T selectRecipients(@VelocityCheck int companyID, Class<T> type, String sqlStatement, Object... sqlParameters) throws SQLException {
return selectRecipients(companyID, new SingleColumnRowMapper<>(type), sqlStatement, sqlParameters);
}
示例13
@Override
public <T> List<T> queryForList(String sql, SqlParameterSource paramSource, Class<T> elementType)
throws DataAccessException {
return query(sql, paramSource, new SingleColumnRowMapper<>(elementType));
}
示例14
@Override
public <T> T queryForObject(String sql, SqlParameterSource paramSource, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramSource, new SingleColumnRowMapper<T>(requiredType));
}
示例15
@Override
public <T> T queryForObject(String sql, Map<String, ?> paramMap, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramMap, new SingleColumnRowMapper<T>(requiredType));
}
示例16
@Override
public <T> List<T> queryForList(String sql, SqlParameterSource paramSource, Class<T> elementType)
throws DataAccessException {
return query(sql, paramSource, new SingleColumnRowMapper<T>(elementType));
}
示例17
@Override
public <T> T queryForObject(String sql, SqlParameterSource paramSource, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramSource, new SingleColumnRowMapper<T>(requiredType));
}
示例18
@Override
public <T> T queryForObject(String sql, Map<String, ?> paramMap, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramMap, new SingleColumnRowMapper<T>(requiredType));
}
示例19
@Override
public <T> List<T> queryForList(String sql, SqlParameterSource paramSource, Class<T> elementType)
throws DataAccessException {
return query(sql, paramSource, new SingleColumnRowMapper<T>(elementType));
}
示例20
@Override
public <T> T queryForObject(String sql, SqlParameterSource paramSource, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramSource, new SingleColumnRowMapper<T>(requiredType));
}
示例21
@Override
public <T> T queryForObject(String sql, Map<String, ?> paramMap, Class<T> requiredType)
throws DataAccessException {
return queryForObject(sql, paramMap, new SingleColumnRowMapper<T>(requiredType));
}
示例22
@Override
public <T> List<T> queryForList(String sql, SqlParameterSource paramSource, Class<T> elementType)
throws DataAccessException {
return query(sql, paramSource, new SingleColumnRowMapper<T>(elementType));
}
