Spring整合jdbc編程

一、Spring對Jdbc的支持

　   Spring為了提供對Jdbc的支持，在Jdbc API的基礎上封裝了一套實現，以此建立一個 JDBC 存取框架。

　　作為 Spring JDBC 框架的核心, JDBC 模板的設計目的是為不同類型的 JDBC 操作提供模板方法. 每個模板方法都能控制整個過程, 並允許覆蓋過程中的特定任務. 通過這種方式, 可以在盡可能保留靈活性的情況下, 將數據庫存取的工作量降到最低.

二、傳統的Jdbc實現

　　如下為傳統的Jdbc實現，該實現有兩個明顯的缺點就是（1）需要自己管理連接 （2）Jdbc操作重復代碼封裝與編寫

 

public void save() {
        try {
            String sql = "insert into aa(id,name) values(3,'happy');";
            Connection con = null;
            Statement stmt = null;
            Class.forName("com.mysql.jdbc.Driver");
            // 連接對象
            con = DriverManager.getConnection("jdbc:mysql://localhost:3306/kk", "root", "123456");
            // 執行命令對象
            stmt =  con.createStatement();
            // 執行
            stmt.execute(sql);            
            // 關閉
            stmt.close();
            con.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

三、Spring+Jdbc實現

　　相比於傳統的Jdbc實現，在Jdbc API的基礎上封裝了一套實現JdbcTemplate，JdbcTemplate的優點如下：

　　（1）配置基於模板設置

　　（2）完成了資源的創建和釋放的工作

　　（3）完成了對JDBC的核心流程的工作，包括SQL語句的創建和執行，簡化了對JDBC的操作

　　（4）僅需要傳遞DataSource就可以把它實例化

　　（5）JdbcTemplate只需要創建一次，減少了代碼復用的煩惱

　　（6）JdbcTemplate是線程安全類

　　步驟1.配置Spring+JDBC配置文件

<?xml version="1.0" encoding="UTF-8"?>
<!-- 名稱空間 -->
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xmlns:util="http://www.springframework.org/schema/util"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
        ">
        
        <!-- 1、聲明數據源對象：C3P0連接池 -->
        <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
            <!-- 加載jdbc驅動 -->
            <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
            <!-- jdbc連接地址 -->
            <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/kk"></property>
            <!-- 連接數據庫的用戶名 -->
            <property name="user" value="root"></property>
            <!-- 連接數據庫的密碼 -->
            <property name="password" value="123456"></property>
            <!-- 數據庫的初始化連接數 -->
            <property name="initialPoolSize" value="3"></property>
            <!-- 數據庫的最大連接數 -->
            <property name="maxPoolSize" value="10"></property>
            <!-- 數據庫最多執行的事務 -->
            <property name="maxStatements" value="100"></property>
            <!-- 連接數量不夠時每次的增量 -->
            <property name="acquireIncrement" value="2"></property>           
        </bean>
        
        <!--  創建jdbcTemplate對象 -->
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <property name="dataSource" ref="dataSource">
            </property>
        </bean>
        
        <bean id="jdbcUser" class="com.jyk.spring.jdbc.JdbcUser">
            <property name="jdbcTemplate" ref="jdbcTemplate">
            </property>
        </bean>
        
</beans>

　　步驟2.通過jdbcTemplate編寫對業務的增刪改查操作

package com.jyk.spring.jdbc;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;

public class JdbcUser {
    
    private JdbcTemplate jdbcTemplate;    

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public void save()
    {
        String sql = "insert into aa(id,name) values ('4','admin4')";
        //使用jdbc模板工具類來簡化數據庫執行前的操作
        jdbcTemplate.update(sql);
    }
    
    public person queryById(String id)
    {
        String sql = "select s.name from aa s where s.id=?";
        Map<String, Object> map = jdbcTemplate.queryForMap(sql, id);
        System.out.println(map);
        return null;
    }
    
    public List<person> queryAll()
    {
        String sql = "select * from aa";
        return jdbcTemplate.query(sql, new RowMapper<person>(){

            @Override
            public person mapRow(ResultSet rs, int index) throws SQLException {
                person p = new person();
                p.setId(rs.getInt("id"));
                p.setName(rs.getString("name"));
                return p;
            }});
    }
}

　　RowMapper的使用：在Jdbc的操作中，有很多情況下是要將ResultSet里的數據封裝到一個持久化Bean里，再把持久化Bean封裝到集合中。這樣會造成大量的代碼的重復，不利於代碼重用。而RowMapper正好解決了這個問題。