Spring使用JdbcTemplate操作数据库---使用RowCallbackHander读数据篇
首先,假设如下SQL表中有数据username=test1,passwd=test1,address=test1
CREATE TABLE `login` (
`username` varchar(10) default NULL,
`passwd` varchar(10) default NULL,
`address` varchar(10) default NULL
) ENGINE=InnoDB DEFAULT CHARSET=gb2312;
配置文件:
文章图片
xml version="1.0" encoding="UTF-8"
?>
文章图片
文章图片
<
beans
>
文章图片
<
bean
id
="dataSource"
class
="org.apache.commons.dbcp.BasicDataSource"
>
文章图片
<
property
name
="driverClassName"
>
文章图片
<
value
>
com.mysql.jdbc.Driver
value
>
文章图片
property
>
文章图片
<
property
name
="url"
>
文章图片
<
value
>
jdbc:mysql://localhost:3306/javaee
value
>
文章图片
property
>
文章图片
<
property
name
="username"
>
文章图片
<
value
>
root
value
>
文章图片
property
>
文章图片
<
property
name
="password"
>
文章图片
<
value
>
1234
value
>
文章图片
property
>
文章图片
bean
>
文章图片
<
bean
id
="jdbcTemplate"
class
="org.springframework.jdbc.core.JdbcTemplate"
>
文章图片
<
property
name
="dataSource"
>
文章图片
<
ref
local
="dataSource"
/>
文章图片
property
>
文章图片
bean
>
文章图片
文章图片
<
bean
id
="personDAO"
class
="SpringJDBCSupport.ReadData.PersonDAO"
>
文章图片
<
property
name
="jdbcTemplate"
>
文章图片
<
ref
local
="jdbcTemplate"
/>
文章图片
property
>
文章图片
bean
>
文章图片
beans
>
文章图片
文章图片
JavaBean:
文章图片
package
SpringJDBCSupport.ReadData;
文章图片
import
com.mysql.jdbc.Driver;
文章图片
文章图片
public class
Person
...
{
文章图片
private String name;
文章图片
private String password;
文章图片
private String address;
文章图片
文章图片
public Person()...{
文章图片
文章图片
}
文章图片
文章图片
public Person(String name,String password,String address)...{
文章图片
this.name=name;
文章图片
this.password=password;
文章图片
this.address=address;
文章图片
}
文章图片
文章图片
public String getAddress() ...{
文章图片
return address;
文章图片
}
文章图片
文章图片
public void setAddress(String address) ...{
文章图片
this.address = address;
文章图片
}
文章图片
文章图片
public String getName() ...{
文章图片
return name;
文章图片
}
文章图片
文章图片
public void setName(String name) ...{
文章图片
this.name = name;
文章图片
}
文章图片
文章图片
public String getPassword() ...{
文章图片
return password;
文章图片
}
文章图片
文章图片
public void setPassword(String password) ...{
文章图片
this.password = password;
文章图片
}
文章图片
文章图片
public String toString()...{
文章图片
return this.getName()+"-"+this.getPassword()+"-"+this.getAddress();
文章图片
}
文章图片
}
文章图片
DAO:
其中getPersonByRowCallbackHandler方法根据username获得person对象
文章图片
package
SpringJDBCSupport.ReadData;
文章图片
文章图片
import
java.sql.PreparedStatement;
文章图片
import
java.sql.ResultSet;
文章图片
import
java.sql.SQLException;
文章图片
import
java.sql.Types;
文章图片
import
java.util.List;
文章图片
文章图片
import
org.springframework.jdbc.core.BatchPreparedStatementSetter;
文章图片
import
org.springframework.jdbc.core.JdbcTemplate;
文章图片
import
org.springframework.jdbc.core.RowCallbackHandler;
文章图片
文章图片
文章图片
public class
PersonDAO
...
{
文章图片
private JdbcTemplate jdbcTemplate;
文章图片
文章图片
文章图片
public JdbcTemplate getJdbcTemplate() ...{
文章图片
return jdbcTemplate;
文章图片
}
文章图片
文章图片
文章图片
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) ...{
文章图片
this.jdbcTemplate = jdbcTemplate;
文章图片
}
文章图片
文章图片
文章图片
public int insertPersonUseUpdate(Person person)...{
文章图片
String sql="insert into login values(?,?,?)";
文章图片
文章图片
Object[] params=new Object[]...{
文章图片
person.getName(),
文章图片
person.getPassword(),
文章图片
person.getAddress()
文章图片
};
文章图片
return this.getJdbcTemplate().update(sql,params);
文章图片
}
文章图片
文章图片
public int insertPersonUseExecute(Person person)...{
文章图片
String sql="insert into login values(?,?,?)";
文章图片
文章图片
Object[] params=new Object[]...{
文章图片
person.getName(),
文章图片
person.getPassword(),
文章图片
person.getAddress()
文章图片
};
文章图片
文章图片
int[] types=new int[]...{
文章图片
Types.VARCHAR,
文章图片
Types.VARCHAR,
文章图片
Types.VARCHAR
文章图片
};
文章图片
return this.getJdbcTemplate().update(sql,params,types);
文章图片
}
文章图片
文章图片
public int[] updatePersonUseBatchUpdate( final List persons)...{
文章图片
String sql="insert into login values(?,?,?)";
文章图片
BatchPreparedStatementSetter setter=null;
文章图片
文章图片
setter=new BatchPreparedStatementSetter()...{
文章图片
文章图片
public int getBatchSize()...{
文章图片
return persons.size();
文章图片
}
文章图片
文章图片
public void setValues(PreparedStatement ps,int index) throws SQLException...{
文章图片
Person person=(Person)persons.get(index);
文章图片
ps.setString(1,person.getName());
文章图片
ps.setString(2,person.getPassword());
文章图片
ps.setString(3,person.getAddress());
文章图片
}
文章图片
};
文章图片
return this.getJdbcTemplate().batchUpdate(sql,setter);
文章图片
}
文章图片
文章图片
文章图片
public Person getPersonByRowCallbackHandler(String username)...{
文章图片
文章图片
String sql="select * from login where username=?";
文章图片
final Person person=new Person();
文章图片
文章图片
final Object params[]=new Object[]...{username};
文章图片
文章图片
this.getJdbcTemplate().query(sql,params,new RowCallbackHandler()...{
文章图片
文章图片
public void processRow(ResultSet rs)throws SQLException...{
文章图片
person.setName(rs.getString("username"));
文章图片
person.setPassword(rs.getString("passwd"));
文章图片
person.setAddress(rs.getString("address"));
文章图片
}
文章图片
});
文章图片
return person;
文章图片
}
文章图片
文章图片
}
文章图片
测试代码:
文章图片
package
SpringJDBCSupport.ReadData;
文章图片
文章图片
import
java.io.File;
文章图片
import
java.util.ArrayList;
文章图片
import
java.util.List;
文章图片
文章图片
import
org.springframework.beans.factory.BeanFactory;
文章图片
import
org.springframework.beans.factory.xml.XmlBeanFactory;
文章图片
import
org.springframework.core.io.FileSystemResource;
文章图片
文章图片
文章图片
public class
TestJDBCTemplate
...
{
文章图片
文章图片
public static String filePath="";
文章图片
public static BeanFactory factory=null;
文章图片
文章图片
public static void main(String[] args) ...{
文章图片
filePath=System.getProperty("user.dir")+File.separator+"SpringJDBCSupport"+File.separator+"ReadData"+File.separator+"hello.xml";
文章图片
factory=new XmlBeanFactory(new FileSystemResource(filePath));
文章图片
PersonDAO personDAO=(PersonDAO)factory.getBean("personDAO");
文章图片
文章图片
/**//*
文章图片
* 准备数据
文章图片
*/
文章图片
Person p1=new Person("test1","test1","test1");
文章图片
Person p2=new Person("test2","test2","test2");
文章图片
Person p3=new Person("test3","test3","test3");
文章图片
Person p4=new Person("test4","test4","test4");
文章图片
Person p5=new Person("test5","test5","test5");
文章图片
List persons=new ArrayList();
文章图片
persons.add(p3);
文章图片
persons.add(p4);
文章图片
persons.add(p5);
文章图片
//使用jdbcTemplate.update方式
文章图片
//personDAO.insertPersonUseUpdate(p1);
文章图片
//使用jdbcTemplate.execute方式
文章图片
//personDAO.insertPersonUseExecute(p2);
文章图片
////使用jdbcTemplate批处理方式
文章图片
//personDAO.updatePersonUseBatchUpdate(persons);
文章图片
文章图片
//使用RowCallbackHandler执行一次查询,并打印person信息
文章图片
System.out.println(personDAO.getPersonByRowCallbackHandler("test1"));
文章图片
}
文章图片
文章图片
文章图片
文章图片
}
文章图片
运行结果:
【Spring使用JdbcTemplate操作数据库---使用RowCallbackHander读数据篇】test1-test1-test1
推荐阅读
- 由浅入深理解AOP
- 【译】20个更有效地使用谷歌搜索的技巧
- Activiti(一)SpringBoot2集成Activiti6
- mybatisplus如何在xml的连表查询中使用queryWrapper
- MybatisPlus|MybatisPlus LambdaQueryWrapper使用int默认值的坑及解决
- MybatisPlus使用queryWrapper如何实现复杂查询
- SpringBoot调用公共模块的自定义注解失效的解决
- 解决SpringBoot引用别的模块无法注入的问题
- iOS中的Block
- Linux下面如何查看tomcat已经使用多少线程