DBUtils和鏈接池

時間  2019-11-09
標籤 dbutils 鏈接 简体版
原文   原文鏈接

DBUtils

若是隻使用JDBC進行開發，咱們會發現冗餘代碼過多，爲了簡化JDBC開發，本案例咱們講採用apache commons組件一個成員：DBUtils。java

DBUtils就是JDBC的簡化開發工具包。須要項目導入commons-dbutils-1.6.jar纔可以正常使用DBUtils工具。mysql

 

 

 

DBUtils是java編程中的數據庫操做實用工具，小巧簡單實用。sql

DBUtils封裝了對JDBC的操做，簡化了JDBC操做，能夠少寫代碼。數據庫

Dbutils三個核心功能介紹：apache

　　①QueryRunner中提供對sql語句操做的API.編程

　　②ResultSetHandler接口，用於定義select操做後，怎樣封裝結果集
數組

　　③DbUtils類，它就是一個工具類,定義了關閉資源與事務處理的方法tomcat

 

QueryRunner核心類

一、update(Connection conn, String sql, Object... params) ，用來完成表數據的增長、刪除、更新操做ide

二、query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) ，用來完成表數據的查詢操做工具

演示：

一、增刪改

    //添加
    public void addProduct() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="insert into product(pid,pname) values(?,?)";
        Object[] obj={"123456","inphone8"};
        qr.update(conn, sql,obj);
        DbUtils.close(conn);
    }
    //修改
    public void update() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="update product set pname=? where pid=?";
        Object[] obj={"vivox10","1234567"};
        qr.update(conn, sql,obj);
        DbUtils.close(conn);
    }
    //刪除
    public void delete() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="delete from product where pid=?";
        qr.update(conn, sql,"123456");
        qr.update(conn, sql,"1234567");
        DbUtils.close(conn);
    }

二、查詢

ResultSetHandler結果集處理類

 

JavaBean

JavaBean就是一個類，在開發中經常使用封裝數據。具備以下特性：

①須要實現接口：java.io.Serializable ，一般實現接口這步驟省略了，不會影響程序。

②提供私有字段：private 類型 字段名;

③提供getter/setter方法：

④提供無參構造

public class Product {
    private String pid;
    private String pname;
    private Double market_price;
    private Double shop_price;
    private String pimage;
    private String pdate;
    private Integer is_hot;
    private String pdesc;
    private Integer pflag;
    private String cid;
    //用包裝類能夠避免空指針,包裝類有null
    public String getPid() {
        return pid;
    }
    public void setPid(String pid) {
        this.pid = pid;
    }
    public String getPname() {
        return pname;
    }
    public void setPname(String pname) {
        this.pname = pname;
    }
    public Double getMarket_price() {
        return market_price;
    }
    public void setMarket_price(Double market_price) {
        this.market_price = market_price;
    }
    public Double getShop_price() {
        return shop_price;
    }
    public void setShop_price(Double shop_price) {
        this.shop_price = shop_price;
    }
    public String getPimage() {
        return pimage;
    }
    public void setPimage(String pimage) {
        this.pimage = pimage;
    }
    public String getPdate() {
        return pdate;
    }
    public void setPdate(String pdate) {
        this.pdate = pdate;
    }
    public Integer getIs_hot() {
        return is_hot;
    }
    public void setIs_hot(Integer is_hot) {
        this.is_hot = is_hot;
    }
    public String getPdesc() {
        return pdesc;
    }
    public void setPdesc(String pdesc) {
        this.pdesc = pdesc;
    }
    public Integer getPflag() {
        return pflag;
    }
    public void setPflag(Integer pflag) {
        this.pflag = pflag;
    }
    public String getCid() {
        return cid;
    }
    public void setCid(String cid) {
        this.cid = cid;
    }
    @Override
    public String toString() {
        return "Product [pid=" + pid + ", pname=" + pname + ", market_price=" + market_price + ", shop_price="
                + shop_price + ", pimage=" + pimage + ", pdate=" + pdate + ", is_hot=" + is_hot + ", pdesc=" + pdesc
                + ", pflag=" + pflag + ", cid=" + cid + "]";
    }
}

各方法演示：

    //ArrayHandler
    //將結果集中的第一條記錄封裝到一個Object[]數組中，數組中的每個元素就是這條記錄中的每個字段的值
    public void select1() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="select * from product";
        Object[] obj=qr.query(conn, sql,new ArrayHandler());
        for(Object o:obj){
            System.out.println(o);
        }
        DbUtils.close(conn);
    }
    //ArrayListHandler
    //將結果集中的每一條記錄都封裝到一個Object[]數組中，將這些數組在封裝到一個List集合中。
    public void select2() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="select * from product";
        List<Object[]> list=qr.query(conn, sql,new ArrayListHandler());
        for(Object[] obj:list){
            for(Object o:obj){
                System.out.print(o+"\t");
            }
            System.out.println();
        }
        DbUtils.close(conn);
    }
    //BeanHandler
    //將結果集中第一條記錄封裝到一個指定的javaBean中。
    //BeanHandler底層調用的是空參構造和get()&set(),因此javaBean必須有這兩個
    public void select3() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="select * from product";
        Product product=qr.query(conn,sql,new BeanHandler<Product>(Product.class));
        System.out.println(product);
        DbUtils.close(conn);
    }
    //BeanListHandler
    //將結果集中每一條記錄封裝到指定的javaBean中，將這些javaBean在封裝到List集合中
    public void select4() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="select * from product";
        List<Product> list=qr.query(conn,sql,new BeanListHandler<Product>(Product.class));
        for(Product p:list){
            System.out.println(p);
        }
        DbUtils.close(conn);
    }
    //ColumnListHandler
    //將結果集中指定的列的字段值，封裝到一個List集合中
    public void select5() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="select * from product";
        List<String> list=qr.query(conn,sql,new ColumnListHandler<String>("pname"));
        for(String s:list){
            System.out.println(s);
        }
        DbUtils.close(conn);
    }
    //ScalarHandler
    //它是用於單數據。例如select count(*) from 表操做。
    public void select6() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="select count(*) from product";
        Long count=qr.query(conn,sql,new ScalarHandler<Long>());
            System.out.println(count);
        DbUtils.close(conn);
    }
    //MapHandler
    //將結果集第一行封裝到Map集合中,Key 列名, Value 該列數據
    public void select7() throws SQLException{
        Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner();
        String sql="select * from product";
        Map<String,Object> map=qr.query(conn, sql,new MapHandler());
        Set<Map.Entry<String,Object>> set=map.entrySet();
        for(Map.Entry<String,Object> entry:set){
            System.out.println(entry.getKey()+entry.getValue());
        }
        DbUtils.close(conn);
    }
    //MapListHandler
    //將結果集第一行封裝到Map集合中,Key 列名, Value 該列數據,Map集合存儲到List集合
    public void select8() throws SQLException{
        //Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner(DBUtils.getDataSource());
        String sql="select * from product";
        List<Map<String,Object>> list=qr.query(sql,new MapListHandler());
        for(Map<String,Object> map:list){
            Set<Map.Entry<String,Object>> set=map.entrySet();
            for(Map.Entry<String,Object> entry:set){
                System.out.println(entry.getKey()+entry.getValue());
            }
        }
    }

鏈接池

實際開發中「得到鏈接」或「釋放資源」是很是消耗系統資源的兩個過程，爲了解決此類性能問題，一般狀況咱們採用鏈接池技術，

來共享鏈接Connection。這樣咱們就不須要每次都建立鏈接、釋放鏈接了，這些操做都交給了鏈接池

概念

用池來管理Connection，這樣能夠重複使用Connection。有了池，因此咱們就不用本身來建立Connection，而是經過池來獲取Connection對象。

當使用完Connection後，調用Connection的close()方法也不會真的關閉Connection，而是把Connection「歸還」給池。

池就能夠再利用這個Connection對象了。

規範

Java爲數據庫鏈接池提供了公共的接口：javax.sql.DataSource，各個廠商須要讓本身的鏈接池實現這個接口。

這樣應用程序能夠方便的切換不一樣廠商的鏈接池！

常見的鏈接池：DBCP、C3P0。

DBCP鏈接池

DBCP也是一個開源的鏈接池，是Apache Common成員之一，在企業開發中也比較常見，tomcat內置的鏈接池。

使用方法：

導入jar包

 

編寫工具類

鏈接數據庫表的工具類, 採用DBCP鏈接池的方式來完成，Java中提供了一個鏈接池的規則接口 ：

DataSource : 它是java中提供的鏈接池，做爲 DriverManager 工具的替代項。

在DBCP包中提供了DataSource接口的實現類，咱們要用的具體的鏈接池 BasicDataSource類

public class DBUtils {
        public static final String DRIVER = "com.mysql.jdbc.Driver";
        public static final String URL = "jdbc:mysql://localhost:3306/store_v1.0";
        public static final String USERNAME = "root";
        public static final String PASSWORD = "123456";
        /*
         * 建立鏈接池BasicDataSource
         */
        public static BasicDataSource dataSource = new BasicDataSource();
        //靜態代碼塊
        static{
            //對鏈接池對象 進行基本的配置
            dataSource.setDriverClassName(DRIVER); // 這是要鏈接的數據庫的驅動
            dataSource.setUrl(URL); //指定要鏈接的數據庫地址
            dataSource.setUsername(USERNAME); //指定要鏈接數據的用戶名
            dataSource.setPassword(PASSWORD); //指定要鏈接數據的密碼
        }
        /*
         * 返回鏈接池對象
         */
        public static DataSource getDataSource(){
            return dataSource;
        }
        //從鏈接池獲取鏈接
        public static Connection getConn(){
            Connection conn=null;
            try {
                conn=dataSource.getConnection();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            return conn;
        }
}

使用方法：

public void select8() throws SQLException{
        //Connection conn=JDBCUtils.getConn();
        QueryRunner qr=new QueryRunner(DBUtils.getDataSource());
        String sql="select * from product";
        List<Map<String,Object>> list=qr.query(sql,new MapListHandler());
        for(Map<String,Object> map:list){
            Set<Map.Entry<String,Object>> set=map.entrySet();
            for(Map.Entry<String,Object> entry:set){
                System.out.println(entry.getKey()+entry.getValue());
            }
        }
    }

常見配置項：

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程