Java实战之03Spring-04Spring的数据库访问

四、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文件中。