Spring中JDBC的模板的使用

矫情吗；* 2022-12-06 05:24 102阅读 0赞

#### Spring中JDBC的模板的使用 ####

#### Spring的JDBC的模板 ####

Spring是EE开发的一站式的框架，有EE开发的每层的解决方案。Spring对持久层也提供了解决方案：ORM模块和JDBC的模板。

创建项目，引入jar包：  
引入基本开发包：4 + 2。  
数据库驱动包。  
需要引入spring\_aop的jar包，不然报错。  
Spring的JDBC模板的jar包。

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

1、创建表

CREATE TABLE `t_act` (
        `no` int(11) NOT NULL AUTO_INCREMENT,
        `name` varchar(20) DEFAULT NULL,
        `balance` double(8,2) DEFAULT '0.00',
        PRIMARY KEY (`no`)
    ) ENGINE=InnoDB AUTO_INCREMENT=1001 DEFAULT CHARSET=utf8

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

2、使用JDBC的模板：保存数据

@Test
    public void test01() { 
        // 创建连接池对象
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        // 设置连接数据库的基本信息
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/study_test");
        dataSource.setUsername("root");
        dataSource.setPassword("666666");
    
        // 创建jdbc模板
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        jdbcTemplate.update("insert into t_act values(null, ?, ?)", "王五", 2000d);
    }

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

3、将连接池和模板交给Spring管理

（1）编写Spring的配置文件

<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
        <property name="url" value="jdbc:mysql://localhost:3306/study_test" />
        <property name="username" value="user" />
        <property name="password" value="666666" />
    </bean>
    
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource" />
    </bean>

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

（2）再使用Jdbc的模板

@RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration(value = "classpath:applicationContext.xml")
    public class JdbcTest02 { 
    
        @Resource(name = "jdbcTemplate")
        private JdbcTemplate jdbcTemplate;
    
        @Test
        public void test01() { 
            jdbcTemplate.update("insert into t_act values(null, ?, ?)", "赵六", 2000d);
        }
    }

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

4、使用开源的数据库连接池

（1）DBCP的使用

在Spring配置文件中配置DBCP连接池

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
        <property name="url" value="jdbc:mysql://localhost:3306/study_test" />
        <property name="username" value="root" />
        <property name="password" value="666666" />
    </bean>
    
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource" />
    </bean>

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

（2）C3P0的使用

在Spring配置文件中配置c3p0连接池

<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="com.mysql.jdbc.Driver" />
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/study_test" />
        <property name="user" value="root" />
        <property name="password" value="666666" />
    </bean>
    
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource" />
    </bean>

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

5、抽取数据库连接信息到属性文件

在实际开发中，一般不会把数据库的连接信息直接写在配置文件中。  
而是另外写在属性文件中，在配置文件中去读取配置文件中的信息。

（1）定义一个属性文件jdbc.properties

jdbc.driverClass=com.mysql.jdbc.Driver
    jdbc.url=jdbc:mysql://localhost:3306/study_test
    jdbc.username=root
    jdbc.password=666666

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

（2）在Spring的配置文件中引入属性文件

第一种：通过一个bean标签引入属性文件（很少使用）

<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location" value="classpath:jdbc.properties" />
    </bean>

第二种：通过context标签引入属性文件（常用）

<context:property-placeholder location="classpath:jdbc.properties" />

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

（3）在连接池中获取属性文件的值

（4）最终Spring配置文件内容为

<context:property-placeholder location="classpath:jdbc.properties" />
    
        
        <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
            <property name="driverClass" value="${jdbc.driverClass}" />
            <property name="jdbcUrl" value="${jdbc.url}" />
            <property name="user" value="${jdbc.username}" />
            <property name="password" value="${jdbc.password}" />
        </bean>
    
        
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <property name="dataSource" ref="dataSource" />
        </bean>

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

6、使用JDBC的模板完成CRUD的操作

（1）保存操作

// insert操作：增删改用update()，查询用query()
    @Test
    public void test01() { 
        jdbcTemplate.update("insert into t_act values(null, ?, ?)", "赵六", 2000d);
    }

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

（2）删除操作

// delete操作
    @Test
    public void test02() { 
        jdbcTemplate.update("delete from t_act where id=?", 1009);
    }

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

（3）修改操作

// update操作
    @Test
    public void test03() { 
        jdbcTemplate.update("update t_act set balance = ? where id = ?", 1000d, 1004);
    }

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

（4）查询操作

（01）查询某个属性：

// select操作：查询某一个属性
    @Test
    public void test04() { 
        // 查询一个字段
        Double balance = jdbcTemplate.queryForObject("select balance from t_act where id=?", Double.class, 1001);
        System.out.println(balance);  // 2000.0
    
        // 查询统计个数
        Long count = jdbcTemplate.queryForObject("select count(*) from t_act", Long.class);
        System.out.println(count);  // 4
    }

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

（02）查询返回一条记录，封装到对象中：

// 查询一条记录，封装到一个对象中
    @Test
    public void test05() { 
        Account account = jdbcTemplate.queryForObject("select * from t_act where id=?", new MyRowMapper(), 1001);
        System.out.println(account);  // Account{id=1001, name='张三', balance=2000.0}
    }

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

（03）查询多条记录，封装到List集合中：

// 查询多条记录，封装到List集合中
    @Test
    public void test06() { 
        List<Account> list = jdbcTemplate.query("select * from t_act", new MyRowMapper());
        for (Account a : list) { 
            System.out.println(a);
        }
    }

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

（04）数据封装

public class Account { 
    
        private Integer id;
        private String name;
        private Double balance;
        // ......
    }

class MyRowMapper implements RowMapper<Account> { 
    
        @Override
        public Account mapRow(ResultSet rs, int rowNum) throws SQLException { 
            Account act = new Account();
            act.setId(rs.getInt("id"));
            act.setName(rs.getString("name"));
            act.setBalance(rs.getDouble("balance"));
            return act;
        }
    }

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