9.SpringJDBC模板类

Posted 2020-09-16

1. Spring框架中提供了很多持久层的模板类来简化编程，使用模板类编写程序会变的简单
2. 提供了JDBC模板，Spring框架提供的
    * JdbcTemplate类
3. Spring框架可以整合Hibernate框架，也提供了模板类
    * HibernateTemplate类
快速入门

1. 步骤一：创建数据库的表结构

create database spring_day03;
    use spring_day03;
    create table t_account(
        id int primary key auto_increment,
        name varchar(20),
        money double
);

2.引入开发的JAR包
    * 先引入IOC基本的6个jar包（4个核心+2个日志）
    * 再引入Spring-aop的jar包（1个AOP）
    * 最后引入JDBC模板需要的jar包
        * mysql数据库的驱动包
        * Spring-jdbc.jar
        * Spring-tx.jar

3. 在配置文件中配置连接池和模板类，并扫描包

<!-- spring自带连接池 -->
     <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql:///spring_day03"/>
        <property name="username" value="root"/>
        <property name="password" value="toor"/>
    </bean>

    <!-- 模板类 -->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <!-- 扫包中的注释 -->
    <context:component-scan base-package="com.spring.demo1" />

4.测试

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(value="classpath:applicationContext.xml")
public class Demo1 {
    
    //模板类
    @Resource(name="jdbcTemplate")
    private JdbcTemplate jdbcTemplate;
    
    /**
     * 插入操作
     */
    @Test
    public void m01(){
        jdbcTemplate.update("insert into t_account values (null,?,?)","测试3",10000);
    }
}

连接池的选择

1.DBCP连接池

先引入DBCP的2个jar包
        * com.springsource.org.apache.commons.dbcp-1.2.2.osgi.jar
        * com.springsource.org.apache.commons.pool-1.5.3.jar

    <!-- DBCP连接池 -->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql:///spring_day03"/>
        <property name="username" value="root"/>
        <property name="password" value="toor"/>
    </bean> 

2.C3P0连接池

先引入C3P0的jar包
        * com.springsource.com.mchange.v2.c3p0-0.9.1.2.jar

    <!-- C3P0连接池 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="com.mysql.jdbc.Driver"/>
        <property name="jdbcUrl" value="jdbc:mysql:///spring_day03"/>
        <property name="user" value="root"/>
        <property name="password" value="toor"/>
    </bean>

JDBC模板类的简单操作

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(value="classpath:applicationContext.xml")
public class Demo1 {
    
    //模板类
    @Resource(name="jdbcTemplate")
    private JdbcTemplate jdbcTemplate;
    
    /**
     * 插入操作
     */
    @Test
    public void m01(){
        jdbcTemplate.update("insert into t_account values (null,?,?)","测试3",10000);
    }
    
    /**
     * 更新操作
     */
    @Test
    public void m02(){
        jdbcTemplate.update("update t_account set name = ? where id = ?","测试3修改过10",4);
    }
    
    /**
     * 删除操作
     */
    @Test
    public void m03(){
        jdbcTemplate.update("delete from t_account where id=?",3);
    }
    
    /**
     * 查询一条记录
     */
    @Test
    public void m04(){
        Account account = jdbcTemplate.queryForObject("select * from t_account where id=?", new BeanMapper(), 1);
        System.out.println(account);
    }
    
    /**
     * 查询多条记录
     */
    @Test
    public void m05(){
        List<Account> list = jdbcTemplate.query("select * from t_account", new BeanMapper());
        for (Account account : list) {
            System.out.println(account);
        }
    }
    
}

class BeanMapper implements RowMapper<Account>{
    public Account mapRow(ResultSet rs, int arg1) throws SQLException {
        Account account = new Account();
        account.setId(rs.getInt("id"));
        account.setName(rs.getString("name"));
        account.setMoney(rs.getDouble("money"));
        return account;
    }
}