JDBC回顾

本是古典何须时尚 2022-11-07 13:20 175阅读 0赞

## JDBC介绍 ##

百度百科：Java数据库连接，（Java Database Connectivity，简称JDBC）是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。

个人理解：  
没有JDBC：因为各个数据库软件都是自成体系，对外提供服务时没有统一标准，不像http接口，因为http协议的存在及约束，对接一个新接口非常方便。且数据库连接本身也非常复杂，当我们需要连接不同数据库时，自己手写连接不现实，使用数据库厂商提供的工具连接自然可以，但开发限制较大，不同数据库的连接，执行，结果集处理均不能保证一致，应用切换数据库代价更是无比巨大，可能换一个数据库，数据库连接查询及结果处理的代码全部需要重写，bug也会更多。  
JDBC意义：JAVA提供统一的数据库访问API，仅仅是一套标准，一系列规范化的操作。且不提供具体实现，而是不同数据库开发商根据jdbc标准提供具体实现，如何实现不需要开发者关心。这样可以做到，对数据库的连接，执行，结果集处理使用同一套规范与标准，提高开发效率与容错率，降低开发难度及与数据库的耦合度。

## JDBC使用与测试 ##

### 造数据 ###

建表

CREATE TABLE `t_test`(
      `id` BIGINT(20) NOT NULL AUTO_INCREMENT,
      `code` VARCHAR(32) DEFAULT NULL COMMENT '编码',
      `name` VARCHAR(64) DEFAULT NULL COMMENT '名称',
      PRIMARY KEY (`id`)
    )

插入数据  
INSERT INTO t\_test(CODE, NAME) VALUES(‘ZS’,‘张三’), (‘LS’,‘李四’), (‘ZL’,‘张龙’), (‘ZH’,‘赵虎’);

查询  
![在这里插入图片描述][20210312143432843.png]

### 示例代码 ###

public class MainTest { 
    
        public static void main(String[] args) throws Exception { 
    	    // 1.加载驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
    
    		// 2.创建连接
            Connection mysqlConnection = DriverManager.getConnection(
                    "jdbc:mysql://host:port/dbName",
                    "username ",
                    "password"
            );
    
    		// 3.创建statement，用于执行静态sql
            Statement statement = mysqlConnection.createStatement();
    
    		// 4.执行查询sql，会返回结果集
            String sql = "select * from t_test;";
            ResultSet resultSet = statement.executeQuery(sql);
    
    		// 5.读取结果集
            while (resultSet.next()) { 
                System.out.println(resultSet.getString("code")+" : "+resultSet.getString("name"));
            }
        }
    }

### 解读 ###

上述使用jdbc执行一个查询并处理返回值共分五步：

1.  加载驱动
2.  创建连接
3.  创建statement，用于执行静态sql
4.  执行查询sql，会返回结果集
5.  读取结果集

### 为何要加载驱动 ###

Class.forName(“com.mysql.cj.jdbc.Driver”);  
这一步根据字面意思，使用Class类，去加载名为“com.mysql.cj.jdbc.Driver”的类，即加载mysql的驱动。乍一看简直是一脸懵逼，这句代码就能加载驱动了？而且为什么要加载驱动？没这么写过代码呀！

试着慢慢分析吧，首先Class.forName ！  
Java class在没有被需要用到时，是不会被加载到JVM内存中。当我们new一个从没用过的类时，JVM首先会去找这个类有么有在内存中，没有的话会先去加载这个类，然后  
com.mysql.cj.jdbc.Driver源码：

package com.mysql.cj.jdbc;
    import java.sql.SQLException;
    public class Driver extends NonRegisteringDriver implements java.sql.Driver { 
        //
        // Register ourselves with the DriverManager
        //
        static { 
            try { 
                java.sql.DriverManager.registerDriver(new Driver());
            } catch (SQLException E) { 
                throw new RuntimeException("Can't register driver!");
            }
        }
    
        /** * Construct a new driver and register it with DriverManager * * @throws SQLException * if a database error occurs. */
        public Driver() throws SQLException { 
            // Required for Class.forName().newInstance()
        }
    }

static代码块会在类被加载时执行，其他也没了，而static中就一句代码java.sql.DriverManager.registerDriver(new Driver());

注册了一个实现java.sql.Driver的mysql驱动，即把mysql厂商提供的驱动注册到了驱动管理器中，具体作用肯定是供后续使用，这里暂时无法明确用途。

### 创建连接 ###

Connection mysqlConnection = DriverManager.getConnection(
                    "jdbc:mysql://host:port/dbName",
                    "username ",
                    "password"
            );

创建连接阶段会根据提供的数据库信息进行数据库连接创建，这一步就需要连接具体的mysql数据库了，除了用户名、密码、数据库地址信息，似乎没有看到如何告诉jvm需要连mysql还是oracle或者其他数据库，url中倒是有mysql字样，难道用的这个连的？

先看下创建连接的代码：

// Worker method called by the public getConnection() methods.
    private static Connection getConnection(
        String url, java.util.Properties info, Class<?> caller) throws SQLException { 
        /* * When callerCl is null, we should check the application's * (which is invoking this class indirectly) * classloader, so that the JDBC driver class outside rt.jar * can be loaded from here. */
        ClassLoader callerCL = caller != null ? caller.getClassLoader() : null;
        synchronized(DriverManager.class) { 
            // synchronize loading of the correct classloader.
            if (callerCL == null) { 
                callerCL = Thread.currentThread().getContextClassLoader();
            }
        }
    
        if(url == null) { 
            throw new SQLException("The url cannot be null", "08001");
        }
    
        println("DriverManager.getConnection(\"" + url + "\")");
    
        // Walk through the loaded registeredDrivers attempting to make a connection.
        // Remember the first exception that gets raised so we can reraise it.
        SQLException reason = null;
    
        for(DriverInfo aDriver : registeredDrivers) { 
            // If the caller does not have permission to load the driver then
            // skip it.
            if(isDriverAllowed(aDriver.driver, callerCL)) { 
                try { 
                    println(" trying " + aDriver.driver.getClass().getName());
                    Connection con = aDriver.driver.connect(url, info);
                    if (con != null) { 
                        // Success!
                        println("getConnection returning " + aDriver.driver.getClass().getName());
                        return (con);
                    }
                } catch (SQLException ex) { 
                    if (reason == null) { 
                        reason = ex;
                    }
                }
    
            } else { 
                println(" skipping: " + aDriver.getClass().getName());
            }
    
        }
    
        // if we got here nobody could connect.
        if (reason != null)    { 
            println("getConnection failed: " + reason);
            throw reason;
        }
    
        println("getConnection: no suitable driver found for "+ url);
        throw new SQLException("No suitable driver found for "+ url, "08001");
    }

Connection con = aDriver.driver.connect(url, info);

这里可以看到，遍历已注册的驱动，挨个调用驱动创建连接，这里java只提供了接口，即Driver.connect.并没有提供具体实现，而是各个数据库厂商自己提供实现，提供如何去连接他们的数据库，返回一个可用的连接。

而这个驱动注册就是第一步加载驱动的意义：需要主动把厂商的驱动注册到jdbc的驱动管理器中，这样用户创建数据库连接时，jdbc的驱动管理器就使用已注册的驱动去创建对应数据库的连接。

如果项目中同时连接多种数据库，如果区分需要连哪个呢？  
Jdbc不做决策，而是遍历所有驱动，挨个去创建连接，谁先创建成功了，就返回谁的连接。

### 注意 ###

当前jdbc已经不需要手动加载驱动了，新的驱动管理器的静态代码块中已经自动进行了驱动加载。

public class DriverManager { 
    	…
    static { 
        loadInitialDrivers();
        println("JDBC DriverManager initialized");
    }
    …
    }

方式为遍历寻找所有java.sql.Driver接口的实现类，然后挨个执行Class.forName(XXX);

### 增删改查 ###

private static void test_query() throws Exception { 
    	String sql = "select * from t_test;";
    	ResultSet resultSet = statement.executeQuery(sql);
    
    	while (resultSet.next()) { 
    		System.out.println(resultSet.getString("code")+" : "+resultSet.getString("name"));
    	}
    }
    
    private static void test_insert() throws Exception { 
    	String sql = "INSERT INTO t_test(CODE, NAME) VALUES('ZS','张三'), ('LS','李四'), ('ZL','张龙'), ('ZH','赵虎');";
    	boolean result = statement.execute(sql);
    	System.out.println(result);
    }
    
    private static void test_update() throws Exception { 
    	transaction(false);
    	String sql = "UPDATE t_test set name='张66' where code='ZS'";
    	boolean result = statement.execute(sql);
    	System.out.println(result);
    	commit();
    }
    
    private static void test_delete() throws Exception { 
    	String sql = "DELETE FROM t_test WHERE code IN ('ZS', 'LS', 'ZL', 'ZH');";
    	boolean result = statement.execute(sql);
    	System.out.println(result);
    }

### 事务控制 ###

事务控制在connection层，默认是自动提交的，如果需要进行事务控制及业务回滚，需要将自动提交事务设置为false，然后可以在发生异常或者业务错误的情况下手动执行rollback回滚事务，或者在执行完成后手动执行commit提交事务。

// 将自动提交事务设置为false
    mysqlConnection.setAutoCommit(false);
    
    try{ 
    	// do something
    } catch (SQLException e) { 
    	e.printStackTrace();
    	//手动执行rollback回滚事务
    	mysqlConnection.rollback();
    }
    
    //手动执行commit提交事务
    mysqlConnection.commit();

### 后续待补充 ###

[20210312143432843.png]: /images/20221023/549c9c4fe71b4e55a241a4431c01e3de.png