浅说JDBC连接

偏执的太偏执、 2024-04-08 10:13 60阅读 0赞

**目录**

1.三大重点

1.1.ORM 框架

1.2.连接池

解决方案在5解决方案

1.3.日志log

2.问题

3.解决方案

3.1 1个连接？ 单例模式。

3.2 若干个连接（服务者）。

3.3 使用第三方的连接池组件 C3P0

--------------------

## 1.三大重点 ##

### 1.1.ORM 框架 ###

jdbc取出来的是记录集 resultSet,遍历（同时取字段）

取出来直接就是对象集合。配置（表book ----------实体类Book）

### 1.2.连接池 ###

web开发

如果现在同时有 十万个浏览器在访问 网站，是不是就有 十万个连接Connection在内存中？

### **解决方案在5解决方案** ###

### 1.3.日志log ###

jdbc：报错？是否看到了执行的sql语句是什么？

增删改查

classpath:类的查找路径

## 2.问题 ##

web开发同时有10万个浏览器访问网站，就有10万个连接，内存就会被撑爆

## 3.解决方案 ##

### 3.1 1个连接？ 单例模式。 ###

public class JDBCUtil {
        static Connection con = null;
        public static Connection getConnection(){
            if (con != null){
                return con;
            }
            else {
                try {
                    Class.forName("com.mysql.jdbc.Driver");
                    con = DriverManager.getConnection("jdbc:mysql://localhost:3306/shop?user=root&password=123456");
                } catch (ClassNotFoundException e) {
                    e.printStackTrace();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
                return con;
            }
        }
    }
    public class MyTest {
        public static void main(String[] args) throws Exception{
            Connection con = JDBCUtil.getConnection();
            Connection con2 = JDBCUtil.getConnection();
            System.out.println(con == con2);  //false
            System.out.println(con);
            System.out.println(con2);
        }
    }
    如何判断连接是否被关闭？
    
     try {
                if (con != null) {
                    if (!con.isClosed()) {
                        return con;
                    } else {
                        con = DriverManager.getConnection(URL,USER,PASSWORD);
                        return con;
                    }
                } else {
                    con = DriverManager.getConnection("jdbc:mysql://localhost:3306/shop?user=root&password=123456");
                    return con;
                }
            } catch (SQLException throwables) {
                throwables.printStackTrace();
                return con;
            }

### 3.2 若干个连接（服务者）。 ###

维护——编写连接池类

*  DBpool

private static final String DIRVER = "com.mysql.jdbc.Driver";
        private static final String URL = "jdbc:mysql://localhost:3306/shop?";
        private static final String USER = "root";
        private static final String PASSWORD = "123456";
    
    
        static Connection[] cons;  //10个，null
        static int count = 0;
        //静态代码块
        static {
            try {
                System.out.println("加载驱动");
                Class.forName(DIRVER);
    
                //准备10个连接
                cons = new Connection[10];
                for (int i = 0; i < cons.length; i++) {
                    cons[i] = DriverManager.getConnection(URL,USER,PASSWORD);
                }
    
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            }
    
        }
        public static Connection getConnection() {
            count = count % 10 ;
            return cons[count++];
    
        }

*  有什么办法可以强制连接的DBPool的方法名是getConnection（）
 *

Class DBPool implements DataSource{
    		getConnection (){
    		
    		}
    }

### 3.3 使用第三方的连接池组件 C3P0 ###

new ComboPooledDataSource();
    
    
    
     //use  C3P0,数据源（连接池是数据源），ComboPooledDataSource()
            ComboPooledDataSource dataSource = new ComboPooledDataSource();
            dataSource.setDriverClass("com.mysql.jdbc.Driver");
            dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/shop");
            dataSource.setUser("root");
            dataSource.setPassword("123456");
    
            Connection con = dataSource.getConnection();
    
            Statement stmt = con.createStatement();
    
            ResultSet re = stmt.executeQuery("select * from book");
            while (re.next()){
                System.out.println(re.getString("name"));
            }