Druid：入门

雨点打透心脏的1/2处 2024-03-22 15:32 40阅读 0赞

#### 说明 ####

Druid：数据库连接池实现技术，由阿里巴巴提供的
    	1. 步骤：
    		1. 导入jar包 druid-1.0.9.jar
    		2. 定义配置文件：
    			* 是properties形式的
    			* 可以叫任意名称，可以放在任意目录下
    		3. 加载配置文件。Properties
    		4. 获取数据库连接池对象：通过工厂来来获取  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. 提供静态代码块加载配置文件，初始化连接池对象
    		3. 提供方法
    			1. 获取连接方法：通过数据库连接池获取连接
    			2. 释放资源
    			3. 获取连接池的方法

#### 配置文件druid.properties ####

driverClassName=com.mysql.jdbc.Driver
    url=jdbc:mysql:///db3
    username=root
    password=root
    # 初始线程个数
    initialSize=5
    # 最大线程个数
    maxActive=10
    # 最大连接数据库的等待时间
    maxWait=3000

#### 简单代码 ####

import com.alibaba.druid.pool.DruidDataSourceFactory;
    
    import javax.sql.DataSource;
    import java.io.IOException;
    import java.io.InputStream;
    import java.sql.Connection;
    import java.util.Properties;
    
    /**
     * Druid演示
     */
    public class DruidDemo {
        
        public static void main(String[] args) throws Exception {
        
            //1.导入jar包
            //2.定义配置文件
            //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();
            System.out.println(conn);
    
        }
    }

#### 工具类 ####

import com.alibaba.druid.pool.DruidDataSourceFactory;
    
    import javax.sql.DataSource;
    import java.io.IOException;
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import java.util.Properties;
    
    /**
     * Druid连接池的工具类
     */
    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;
        }
    
    }

#### 使用 ####

import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    /**
     * 使用新的工具类
     */
    public class DruidDemo {
        
    
        public static void main(String[] args) {
        
            /*
             * 完成添加操作：给account表添加一条记录
             */
            Connection conn = null;
            PreparedStatement pstmt = null;
            try {
        
                //1.获取连接
                conn = JDBCUtils.getConnection();
                //2.定义sql
                String sql = "insert into account values(null,?,?)";
                //3.获取pstmt对象
                pstmt = conn.prepareStatement(sql);
                //4.给？赋值
                pstmt.setString(1,"王五");
                pstmt.setDouble(2,3000);
                //5.执行sql
                int count = pstmt.executeUpdate();
                System.out.println(count);
            } catch (SQLException e) {
        
                e.printStackTrace();
            }finally {
        
                //6. 释放资源
                JDBCUtils.close(pstmt,conn);
            }
        }
    
    }