Spring框架之JDBC模板

﹏ヽ暗。殇╰゛Y 2022-12-09 05:20 190阅读 0赞

**一、使用传统模式创建JDBC模板的步骤：**

**1、创建项目，引入jar包：**

1.  引入基本开发包：
2.  数据库驱动
3.  Spring的JDBC模板的jar包
4.  Spring-tx.3.2.2.jar
    
    spring提供对事务的支持，事务的相关处理以及实现类就在这个Jar包中

**2、创建数据库和数据表**

**略...........**

**3、创建JDBC模板                          传统模式的连接方式：**

public class JdbcDemo01 {
        @Test
        public void demo01(){
            //1、创建连接池
            DriverManagerDataSource dataSource = new DriverManagerDataSource();
            //2、连接数据库
            dataSource.setDriverClassName("com.mysql.jdbc.Driver");
            dataSource.setUrl("jdbc:mysql:///spring_jdbc");
            dataSource.setUsername("root");
            dataSource.setPassword("0000");
            //3、创建JDBC模板
            JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
            jdbcTemplate.update("INSERT  INTO account VALUES (null,?,?)","小王",1000d);
        }
    }

**二、利用控制反转，将数据库连接池和模板交给Spring管理**

1、引入Spring的配置文件，将传统方式中的一些类交给Spring管理，从而通过配置信息来链接数据库

<bean name="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
            <!– 属性注入 –>
            <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
            <property name="url" value="jdbc:mysql:///spring_jdbc"/>
            <property name="username" value="root"/>
            <property name="password" value="0000"/>
    </bean>
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <property name="dataSource" ref="dataSource"/>
    </bean>

2、编写测试类

@RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration("classpath:applicationContext.xml")
    public class JdbcDemo02 {
        @Resource(name = "jdbcTemplate")
        private JdbcTemplate jdbcTemplate;
        @Test
        public void demo02(){
            jdbcTemplate.update("INSERT  INTO account VALUES (null,?,?)","小王",1000d);
        }
    }

三、 使用一些开源的数据库连接池

**1、常用的连接池配置 ,先要引入关键的依赖包**

**               1.1 DBCP       com.springsource.com.mchange.v2.c3p0-0.9.1.2.jar**

**               1.2C3PO        com.springsource.org.apache.commons.pool-1.5.3.jar**

<bean name="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>

**               **

四、由于数据库的种类多种多样，在配置连接池的时候，我们可以创建另一个配置文件，定义数据库的属性文件，目的提高代码的可重复利用，解耦。

1、创建一个jdbc.properties文件。例如，使用mysql数据库

jdbc.driverClass=com.mysql.jdbc.Driver
    jdbc.url=jdbc:mysql:///spring_jdbc
    jdbc.username=root
    jdbc.password=0000

2、引入本地属性文件 jdbc.properties

<context:property-placeholder location="classpath:jdbc.properties"/>
    
            
            <bean name="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>

3、编写测试类

JDBC模板实现增删改查的一些功能。

@RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration("classpath:applicationContext.xml")
    public class DbcpDemo {
        @Resource(name = "jdbcTemplate")
        private JdbcTemplate jdbcTemplate;
        @Test
        /*插入记录*/
        public void demo02 () {
          jdbcTemplate.update("INSERT  INTO account VALUES (null,?,?)","小华",1000d);
        }
        @Test
        /*查询操作*/
        public void demo03 () {
            /*查询某个人*/
            String name = jdbcTemplate.queryForObject("select name from account where id=?",String.class,1);
            System.out.println("第一条记录的名字："+name);
            /*查询记录总数*/
            Long count =  jdbcTemplate.queryForObject("select count(*) from account",long.class,null);
            System.out.println("总共有："+count);
    
        }
        /*将查询的对象封装到对象中*/
        @Test
        public void demo04 () {
            Account account = jdbcTemplate.queryForObject("select *from account where id=?",new MyRowMapper(),2);
            System.out.println(account);
        }
        class MyRowMapper implements RowMapper<Account>{
            @Override
            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.getDouble("money"));
                return account;
            }
        }
         /*将查询的多条数据封装到集合对象中*/
         @Test
         public void demo05 () {
             List<Account> list = (List<Account>) jdbcTemplate.query("select *from account",new MyRowMapper());
             for(Account account:list)
             System.out.println(account);
         }
    }