Spring Jdbc

使用jdbcTemplate查询数据的时候可以使用queryForXXX等方法。下面我们就一一解析一下：
1、jdbcTemplate.queryForInt()和jdbcTemplate.queryForLong()
--使用queryForInt返回user表中的记录数量，queryForInt搭配这样的sql可以在分页的时候计算总记录数
jdbcTemplate.queryForInt("select count(*) from user");

这个queryForInt已经废弃

2、jdbcTemplate.queryForObject()
--本质上和queryForInt相同，只是可以返回不同的对象,例如返回一个String对象
String name = (String) jdbcTemplate.queryForObject(  --3个参数，1、sql 2、要传递的参数数组 3、返回来的对象class
"SELECT name FROM USER WHERE id = ?",
new Object[] {id},
java.lang.String.class);

3、jdbcTemplate.queryForList(???)
--返回一个装有map的list,每一个map是一条记录,map里面的key是字段名
List rows = jdbcTemplate.queryForList("SELECT * FROM user");  --得到装有map的list
for(int i=0;i<rows.size();i++){                   --遍历
Map userMap=rows.get(i);
System.out.println(userMap.get("id"));
System.out.println(userMap.get("name"));
System.out.println(userMap.get("age"));
}

4、jdbcTemplate.queryForMap(SQL)
--这个查询只能是查询一条记录的查询,返回一个map,key的值是column的值
Map map = jdbcTemplate.queryForMap("select count(*) as keyval from user");
map.get("keyval")

5、jdbcTemplate.queryForRowSet(???)
--返回一个RowSet   然后调用.getString或者getInt等去取值

6、jdbc1.query(sql, new RowCallbackHandler()
--返回一个ResultSet对象， processRow有自动循环的机制，它会自动执行processRow中的语句直到
--rs的size执行完了为止。我们可以在这其中用list完成对象的转移，只不过list要用final来修饰
jdbc1.query(sql, new RowCallbackHandler() { //editing
public void processRow(ResultSet rs) throws SQLException {
VideoSearch vs = new VideoSearch();
vs.setRECORDINGFILENAME(rs.getString("RECORDINGFILENAME"));
vs.setCALLID(rs.getString("CALLID"));
list.add(vs);

}
}

说明：
JDBCTemplate的使用方法:
在ApplicationContext.xml中定义一个jdbcTemplate的节点，使用POJO注入,获得注入后可以执行操作
不需要继承什么基类

<bean id="jdbcTemplate"
class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"/>
</bean>

SqlRowSet rs = jdbcTemplate.queryForRowSet(sql, params);
jdbcTemplate有很多的ORM化回调操作将返回结果转为对象列表，
但很多时候还是需要返回ResultSet，Spring有提供一个类似ResultSet的，实现JDBC3.0 RowSet接口的Spring SqlRowSet
注意

queryForObject(String sql, Class<T> requiredType)

Integer.class

requiredType。

queryForInt()

private boolean isUserExists(String username) {

String sql = "SELECT count(*) FROM USERS WHERE username = ?";
boolean result = false;

//The method queryForInt(String, Object...) from the type JdbcTemplate is deprecated
int count = getJdbcTemplate().queryForInt(sql, new Object[] { username });

if (count > 0) {
result = true;
}

return result;
}

Solution

queryForInt()

queryForLong()

queryForObject(String, Class)

private boolean isUserExists(String username) {

String sql = "SELECT count(*) FROM USERS WHERE username = ?";
boolean result = false;

int count = getJdbcTemplate().queryForObject(
sql, new Object[] { username }, Integer.class);

if (count > 0) {
result = true;
}

return result;
}

/**
* 使用反射的基本行映射器
* @param name
* @return
*/
public static User test1(String name){
JdbcTemplate jdbc = new JdbcTemplate(Temple.getDataSource());
String sql = "select id,name,money,birthday from user where id=?";
Object[] args = new Object[] {name};
Object use = jdbc.queryForObject(sql, args,new BeanPropertyRowMapper(User.class));
return (User)use;
}

/**
* 查询返回多个结果
* @param id
* @return
*/
public static List<User> test2(int id){
JdbcTemplate jdbc = new JdbcTemplate(Temple.getDataSource());
String sql = "select id,name,money,birthday from user where id<?";
Object[] args = new Object[] {id};
@SuppressWarnings("unchecked")
List<User> use = jdbc.query(sql, args,new BeanPropertyRowMapper(User.class));
return use;
}

package org.springframework.jdbc.core;

public class JdbcTemplate extends JdbcAccessor implements JdbcOperations {

//...
@Deprecated
public long queryForLong(String sql, Object... args) throws DataAccessException {
Number number = queryForObject(sql, args, Long.class);
return (number != null ? number.longValue() : 0);
}

@Deprecated
public int queryForInt(String sql, Object... args) throws DataAccessException {
Number number = queryForObject(sql, args, Integer.class);
return (number != null ? number.intValue() : 0);
}

NamedParameterJdbcTemplate

/*
* 可以为参数取名字:ln,:email,:deptid
* 优点：如果有多个参数，不用去纠结于参数的位置顺序，直接对应参数名，便于维护
* 缺点：较为麻烦
*/
@Test
public void testNamedParameterJdbcTemplate(){
//之前不适用具名参数的用法：
//String sql="insert employee(last_name,email,dept_id) values(?,?,?)";
//我们给予参数赋值必须依赖于?的顺序

// 使用具名参数的用法：
String sql="insert employee(last_name,email,dept_id) values(:ln,:email,:deptid)";
Map<String,Object> paramMap=new HashMap<String, Object>();
paramMap.put("ln", "超级无敌银河最强临时工");
paramMap.put("email", "super@qq.com");
paramMap.put("deptid", 4);
namedParameterJdbcTemplate.update(sql,paramMap);
}

/*
* 使用具名参数时，可以使用int org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate.update(String sql, SqlParameterSource paramSource) throws DataAccessException
方法进行更新操作：
1. SQL语句中的具名参数与类的属性名一致
2. 使用接口SqlParameterSource的BeanPropertySqlParameterSource实现类作为参数

*/
@Test
public void testNamedParameterJdbcTemplate2(){
//之前不适用具名参数的用法：
//String sql="insert employee(last_name,email,dept_id) values(?,?,?)";
//我们给予参数赋值必须依赖于?的顺序

// 使用具名参数的用法：
String sql="insert employee(last_name,email,dept_id) values(:lastName,:email,:deptId)";
EmployeeBean2 e=new EmployeeBean2();
e.setLastName("haha");
e.setEmail("haha@qq.com");
e.setDeptId(4);
SqlParameterSource sqlParameterSource=new BeanPropertySqlParameterSource(e);
namedParameterJdbcTemplate.update(sql,sqlParameterSource);
}

使用JDBCTemplate 进行基本的批量操作

public class JdbcActorDao implements ActorDao {
private JdbcTemplate jdbcTemplate;

public void setDataSource(DataSource dataSource) {
this.jdbcTemplate = new JdbcTemplate(dataSource);
}

public int[] batchUpdate(final List<Actor> actors) {
int[] updateCounts = jdbcTemplate.batchUpdate("update t_actor set first_name = ?, " +
"last_name = ? where id = ?",
new BatchPreparedStatementSetter() {
public void setValues(PreparedStatement ps, int i) throws SQLException {
ps.setString(1, actors.get(i).getFirstName());
ps.setString(2, actors.get(i).getLastName());
ps.setLong(3, actors.get(i).getId().longValue());
}

public int getBatchSize() {
return actors.size();
}
});
return updateCounts;
}

// ... additional methods
}

SqlParameterSourceUtils.createBatch

public class JdbcActorDao implements ActorDao {
private NamedParameterTemplate namedParameterJdbcTemplate;

public void setDataSource(DataSource dataSource) {
this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
}

public int[] batchUpdate(final List<Actor> actors) {
SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(actors.toArray());
int[] updateCounts = namedParameterJdbcTemplate.batchUpdate(
"update t_actor set first_name = :firstName, last_name = :lastName where id = :id",
batch);
return updateCounts;
}

// ... additional methods
}

public class JdbcActorDao implements ActorDao {

private JdbcTemplate jdbcTemplate;

public void setDataSource(DataSource dataSource) {
this.jdbcTemplate = new JdbcTemplate(dataSource);
}

public int[] batchUpdate(final List<Actor> actors) {
List<Object[]> batch = new ArrayList<Object[]>();
for (Actor actor : actors) {
Object[] values = new Object[] {
actor.getFirstName(),
actor.getLastName(),
actor.getId()};
batch.add(values);
}
int[] updateCounts = jdbcTemplate.batchUpdate(
"update t_actor set first_name = ?, last_name = ? where id = ?",
batch);
return updateCounts;
}

// ... additional methods

}

---------------------

 SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(actors.toArray());
int[] updateCounts = simpleJdbcTemplate.batchUpdate(
"update t_actor set first_name = :firstName, last_name = :lastName where id = :id",
batch);