2020-05-29 · 數(shù)據(jù)庫連接池 & JDBC Template

一、數(shù)據(jù)庫連接池:

1. 概念:其實(shí)就是一個容器(集合),存放數(shù)據(jù)庫連接的容器。
            當(dāng)系統(tǒng)初始化好后,容器被創(chuàng)建,容器中會申請一些連接對象,當(dāng)用戶來訪問數(shù)據(jù)庫時,從容器中獲取連接對象,用戶訪問完之后,會將連接對象歸還給容器。

2. 好處:
        1. 節(jié)約資源
        2. 用戶訪問高效

3. 實(shí)現(xiàn):
        1. 標(biāo)準(zhǔn)接口:DataSource   javax.sql包下的
            1. 方法:
                * 獲取連接:getConnection()
                * 歸還連接:Connection.close()。如果連接對象Connection是從連接池中獲取的,那么調(diào)用Connection.close()方法,則不會再關(guān)閉連接了。而是歸還連接

        2. 一般我們不去實(shí)現(xiàn)它,有數(shù)據(jù)庫廠商來實(shí)現(xiàn)
            1. C3P0:數(shù)據(jù)庫連接池技術(shù)
            2. Druid:數(shù)據(jù)庫連接池實(shí)現(xiàn)技術(shù),由阿里巴巴提供的

C3P0:數(shù)據(jù)庫連接池技術(shù)

* 步驟:
            1. 導(dǎo)入jar包 (兩個) c3p0-0.9.5.2.jar mchange-commons-java-0.2.12.jar ,
                * 不要忘記導(dǎo)入數(shù)據(jù)庫驅(qū)動jar包
            2. 定義配置文件:
                * 名稱: c3p0.properties 或者 c3p0-config.xml
                * 路徑:直接將文件放在src目錄下即可。

            3. 創(chuàng)建核心對象 數(shù)據(jù)庫連接池對象 ComboPooledDataSource
            4. 獲取連接: getConnection
* 代碼:
  //1.創(chuàng)建數(shù)據(jù)庫連接池對象
        //父類引用指向子類實(shí)例化對象
        DataSource ds = new ComboPooledDataSource();

        //2.獲取連接對象
        Connection conn = ds.getConnection();

        //3.打印
        //輸出日志信息。
        System.out.println(conn);

Druid:數(shù)據(jù)庫連接池實(shí)現(xiàn)技術(shù),由阿里巴巴提供

1. 步驟:
            1. 導(dǎo)入jar包 druid-1.0.9.jar
            2. 定義配置文件:
                * 是properties形式的
                * 可以叫任意名稱,可以放在任意目錄下
            3. 加載配置文件。Properties
            4. 獲取數(shù)據(jù)庫連接池對象:通過工廠來來獲取  DruidDataSourceFactory
            5. 獲取連接:getConnection
* 代碼:
//3.加載配置文件
            Properties pro = new Properties();
            InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
            pro.load(is);
            //4.獲取連接池對象
            DataSource ds = DruidDataSourceFactory.createDataSource(pro);
            //5.獲取連接
            Connection conn = ds.getConnection();
2. 定義工具類
            1. 定義一個類 JDBCUtils
            2. 提供靜態(tài)代碼塊加載配置文件,初始化連接池對象
            3. 提供方法
                1. 獲取連接方法:通過數(shù)據(jù)庫連接池獲取連接
                2. 釋放資源
                3. 獲取連接池的方法


        * 代碼:
            public class JDBCUtils {

                //1.定義成員變量 DataSource
                private static DataSource ds ;
            
                static{
                    try {
                        //1.加載配置文件
                        Properties pro = new Properties();
                        pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
                        //2.獲取DataSource
                        ds = DruidDataSourceFactory.createDataSource(pro);
                    } catch (IOException e) {
                        e.printStackTrace();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            
                /**
                 * 獲取連接
                 */
                public static Connection getConnection() throws SQLException {
                    return ds.getConnection();
                }
            
                /**
                 * 釋放資源
                 */
                public static void close(Statement stmt,Connection conn){
                   /* if(stmt != null){
                        try {
                            stmt.close();
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
            
                    if(conn != null){
                        try {
                            conn.close();//歸還連接
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }*/
            
                   close(null,stmt,conn);
                }
            
            
                public static void close(ResultSet rs , Statement stmt, Connection conn){
            
            
                    if(rs != null){
                        try {
                            rs.close();
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
            
            
                    if(stmt != null){
                        try {
                            stmt.close();
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
            
                    if(conn != null){
                        try {
                            conn.close();//歸還連接
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
                }
            
                /**
                 * 獲取連接池方法
                 */
            
                public static DataSource getDataSource(){
                    return  ds;
                }
            
            }



二、Spring JDBC:

JDBCTemplate 介紹:

* Spring框架對JDBC的簡單封裝。提供了一個JDBCTemplate對象簡化JDBC的開發(fā)
    * 步驟:
        1. 導(dǎo)入jar包
        2. 創(chuàng)建JdbcTemplate對象。依賴于數(shù)據(jù)源DataSource
            * JdbcTemplate template = new JdbcTemplate(ds);

        3. 調(diào)用JdbcTemplate的方法來完成CRUD的操作
            * update():執(zhí)行DML語句。增、刪、改語句
            * queryForMap():查詢結(jié)果將結(jié)果集封裝為map集合,將列名作為key,將值作為value 將這條記錄封裝為一個map集合
                * 注意:這個方法查詢的結(jié)果集長度只能是1
            * queryForList():查詢結(jié)果將結(jié)果集封裝為list集合
                * 注意:將每一條記錄封裝為一個Map集合,再將Map集合裝載到List集合中
            * query():查詢結(jié)果,將結(jié)果封裝為JavaBean對象
                * query的參數(shù):RowMapper
                    * 一般我們使用BeanPropertyRowMapper實(shí)現(xiàn)類??梢酝瓿蓴?shù)據(jù)到JavaBean的自動封裝
                    * new BeanPropertyRowMapper<類型>(類型.class)
            * queryForObject:查詢結(jié)果,將結(jié)果封裝為對象
                * 一般用于聚合函數(shù)的查詢

JdbcTemplat 快速入門代碼案例:

//1.導(dǎo)入jar包
        //2.創(chuàng)建JDBCTemplate對象
        JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
        //3.調(diào)用方法
        String sql = "update account set balance = 1000 where id = ?";
        int count = template.update(sql, 1);
        System.out.println(count);

JDBCTemplate 執(zhí)行DML語句。增刪改操作:

//1. 獲取JDBCTemplate對象
    private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
    /**
     * 1. 修改1號數(shù)據(jù)的 salary 為 10000
     */
    @Test
    public void test1(){

        //2. 定義sql
        String sql = "update emp set salary = 10000 where id = 1001";
        //3. 執(zhí)行sql
        int count = template.update(sql);
        System.out.println(count);
    }

    /**
     * 2. 添加一條記錄
     */
    @Test
    public void test2(){
        String sql = "insert into emp(id,ename,dept_id) values(?,?,?)";
        int count = template.update(sql, 1015, "郭靖", 10);
        System.out.println(count);

    }

    /**
     * 3.刪除剛才添加的記錄
     */
    @Test
    public void test3(){
        String sql = "delete from emp where id = ?";
        int count = template.update(sql, 1015);
        System.out.println(count);
    }

JDBCTemplate 執(zhí)行DQL語句,查詢操作:

/**
     * 4.查詢id為1001的記錄,將其封裝為Map集合
     * 注意:這個方法查詢的結(jié)果集長度只能是1
     */
    @Test
    public void test4(){
        String sql = "select * from emp where id = ? or id = ?";
        Map<String, Object> map = template.queryForMap(sql, 1001,1002);
        System.out.println(map);
        //{id=1001, ename=孫悟空, job_id=4, mgr=1004, joindate=2000-12-17, salary=10000.00, bonus=null, dept_id=20}

    }

    /**
     * 5. 查詢所有記錄,將其封裝為List
     */
    @Test
    public void test5(){
        String sql = "select * from emp";
        List<Map<String, Object>> list = template.queryForList(sql);

        for (Map<String, Object> stringObjectMap : list) {
            System.out.println(stringObjectMap);
        }
    }

    /**
     * 6. 查詢所有記錄,將其封裝為Emp對象的List集合
     */

    @Test
    public void test6(){
        String sql = "select * from emp";
        List<Emp> list = template.query(sql, new RowMapper<Emp>() {

            @Override
            public Emp mapRow(ResultSet rs, int i) throws SQLException {
                Emp emp = new Emp();
                int id = rs.getInt("id");
                String ename = rs.getString("ename");
                int job_id = rs.getInt("job_id");
                int mgr = rs.getInt("mgr");
                Date joindate = rs.getDate("joindate");
                double salary = rs.getDouble("salary");
                double bonus = rs.getDouble("bonus");
                int dept_id = rs.getInt("dept_id");

                emp.setId(id);
                emp.setEname(ename);
                emp.setJob_id(job_id);
                emp.setMgr(mgr);
                emp.setJoindate(joindate);
                emp.setSalary(salary);
                emp.setBonus(bonus);
                emp.setDept_id(dept_id);

                return emp;
            }
        });


        for (Emp emp : list) {
            System.out.println(emp);
        }
    }

    /**
     * 6. 查詢所有記錄,將其封裝為Emp對象的List集合
     */

    @Test
    public void test6_2(){
        String sql = "select * from emp";
        List<Emp> list = template.query(sql, new BeanPropertyRowMapper<Emp>(Emp.class));
        for (Emp emp : list) {
            System.out.println(emp);
        }
    }

    /**
     * 7. 查詢總記錄數(shù)
     */

    @Test
    public void test7(){
        String sql = "select count(id) from emp";
        Long total = template.queryForObject(sql, Long.class);
        System.out.println(total);
    }
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

友情鏈接更多精彩內(nèi)容