四、Spring的数据库访问
1、DAO模式
/**
* 抽取的一个类
* @author zhy
*
*/
public class JdbcDaoSupport { private QueryRunner qr = new QueryRunner(DBCPUtil.getDataSource()); public int update(String sql,Object...params){
try{
return qr.update(sql,params);
}catch(Exception e){
throw new RuntimeException(e);
}
} public <T> T query(String sql,ResultSetHandler<T> rsh,Object...params){
try{
return qr.query(sql,rsh,params);
}catch(Exception e){
throw new RuntimeException(e);
}
}
}
/**
* 前提：不考虑事务问题。因为有AOP的存在，我们可以把事务配置起来
* @author zhy
*
*/
public class AccountDaoImpl extends JdbcDaoSupport implements IAccountDao { public Account findAccountByName(String sourceName) {
return query("select * from account where name = ? ",new BeanHandler<Account>(Account.class),sourceName);
} public void updateAccount(Account sourceAccount) {
update("update account set name=?,money=? where id=? ",sourceAccount.getName(),sourceAccount.getMoney(),sourceAccount.getId()) ;
} }
2、Spring提供的数据库访问的模板工具类
2.1、JDBC环境搭建
2.1.1、拷贝jar包
数据库驱动
spring-jdbc-3.2.0.RELEASE.jar：访问JDBC的一个非常基本jar包
spring-orm-3.2.0.RELEASE.jar：通过ORM框架（Hibernate、MyBatis）支持jar包
spring-tx-3.2.0.RELEASE.jar：事务有关的支持jar包（如果使用的JDBC，数据库自动提交事务的前提下，此包不是必须的）
2.1.2、JdbcTemplate的基本使用
JdbcTemplate：用于直接通过JDBC访问数据用的
HibernateTemplate：用于通过Hibernate框架访问数据库用的
a、初级版本，硬编码问题
public class JdbcTemplateDemo1 {
public static void main(String[] args) throws DataAccessException {
//spring中提供了一个内置的数据源：该数据源没有性能问题，可以使用
DriverManagerDataSource ds = new DriverManagerDataSource();
//给数据源提供必需的参数
ds.setDriverClassName("com.mysql.jdbc.Driver");
ds.setUrl("jdbc:mysql://localhost:3306/ee0413_spring_day36");
ds.setUsername("root");
ds.setPassword("1234");
//创建一个新的springjdbc模板
JdbcTemplate jt = new JdbcTemplate();
//给模板赋值数据源
jt.setDataSource(ds);
jt.execute("insert into account(name,money)values('ddd',1000)");
}
}
b、改进版
<!-- 配置一个JdbcTemplate的bean -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="driverManagerDataSource"></property>
</bean>
public class JdbcTemplateDemo2 {
public static void main(String[] args) throws DataAccessException {
//加载Spring配置文件，创建spring容器
ApplicationContext ac = new ClassPathXmlApplicationContext("bean.xml");
//根据id获取jdbc模板
JdbcTemplate jt = (JdbcTemplate)ac.getBean("jdbcTemplate");
jt.execute("insert into account(name,money)values('eee',1000)");
}
}
c、增删改查操作
public class JdbcTemplateDemo3 {
public static void main(String[] args) throws DataAccessException {
//加载Spring配置文件，创建spring容器
ApplicationContext ac = new ClassPathXmlApplicationContext("bean.xml");
//根据id获取jdbc模板
JdbcTemplate jt = (JdbcTemplate)ac.getBean("jdbcTemplate");
//保存
jt.update("insert into account(name,money)values(?,?)", "fff",300);
//更新
jt.update("update account set money = ? where id = ? ",5000,6);
//删除
jt.update("delete from account where id = ? ",6);
//查询一个
Account account = jt.query("select * from account where id = ?",new MyResultSetExctractor(),1);
List<Account> list = jt.query("select * from account where id = ?",new AccountRowMapper(),1);
Account account = null;
if(list.size() == 1){
account = list.get(0);
}
System.out.println(account);
//查询所有
List<Account> list = jt.query("select * from account", new AccountRowMapper());
System.out.println(list);
//查询返回一行一列的情况：比如count(*)
int totalRecords = jt.queryForObject("select count(*) from account", Integer.class);
System.out.println(totalRecords);
}
}
class AccountRowMapper implements RowMapper<Account>{
/**
* 它是每次遍历都会调用一次此方法
* List<Account> list = new ArrayList<Account>();
* while(rs.next){
* Account account = mapRow(rs);
* list.add(acount);
* }
* return list;
*/
public Account mapRow(ResultSet rs, int rowNum) throws SQLException {
Account account = new Account();
account.setId(rs.getInt("id"));
account.setName(rs.getString("name"));
account.setMoney(rs.getFloat("money"));
return account;
}
}
class MyResultSetExctractor implements ResultSetExtractor<Account>{
public Account extractData(ResultSet rs) throws SQLException, DataAccessException {
Account account = null;
//1.判断是否有结果集
if(rs.next()){
account = new Account();
account.setId(rs.getInt("id"));
account.setName(rs.getString("name"));
account.setMoney(rs.getFloat("money"));
}
return account;
}
}
2.1.3、Spring提供的数据库访问的DAO工具类
JdbcDaoSupport：JdbcTemplate的Dao模式的抽取类
HibernateDaoSupport：HibernateTemplate的Dao模式的抽取类
a、原始版本: DAO中直接使用JdbcTemplate
b、改进版：DAO实现类继承JdbcDaoSupport，注入数据源即可
<!-- 配置一个JdbcTemplate的bean -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="driverManagerDataSource"></property>
</bean> <!-- 配置数据源 -->
<bean id="driverManagerDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
<property name="url" value="jdbc:mysql://localhost:3306/ee0413_spring_day36"></property>
<property name="username" value="root"></property>
<property name="password" value="1234"></property>
</bean>
public class AccountDaoImpl2 extends JdbcDaoSupport implements IAccountDao {
public void saveAccount(Account account) {
getJdbcTemplate().update("insert into account(name,money)values(?,?)",account.getName(),account.getMoney());
}
}
c、关于原始版本和改进版的选择问题：
如果是基于XML的配置，则可以使用改进版，也就是Dao抽取类。
如果是基于注解的配置，我们需要在JdbcTemplate上添加注解，由Spring注入。但是JdbcTemplate对象的定义是在JdbcDaoSupport类中，是spring官方jar包里面的，我们修改不了。所以还要使用原始版本。
2.3、数据源
2.3.1、DBCP数据源 BasicDataSource
a、拷贝DBCP的必要jar包：
commons-dbcp.jar commons-pool.jar
b、配置基本的属性
2.3.2、C3P0数据源 ComboPooledDataSource
a、拷贝C3P0的必要jar包：
c3p0-0.9.1.2.jar
b、配置基本的属性
2.3.3、Spring内置数据源DriverManagerDataSource
<!-- 配置数据源 -->
<bean id="driverManagerDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
<property name="url" value="jdbc:mysql://localhost:3306/ee0413_spring_day36"></property>
<property name="username" value="root"></property>
<property name="password" value="1234"></property>
</bean>
2.3.4、对于原生JDBC配置的支持
把配置信息存到一个.properties文件中。