JDBC API 4.2（二）：编程步骤

￡神魔★判官ぃ 2023-06-13 09:37 11阅读 0赞

### 文章目录 ###

*   *   *  step 1 : 引入mysql-jdbc驱动包
         *  step 2 : 加载驱动
         *  step 3 : 建立与数据库的连接
         *  step 4 : 创建Statement
         *  step 5 : 执行SQL语句
         *  step 6 : 关闭连接
         *  try-with-resource

### step 1 : 引入mysql-jdbc驱动包 ###

我们通过JDBC API 访问数据库时，需要用到第三方的驱动类，这些驱动类根据JDBC API 规范实现了访问相应数据库的一些列方法。这里我们要访问MySQL 数据库，因此这里引用的是 mysql 驱动。

<dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>8.0.15</version>
            </dependency>

### step 2 : 加载驱动 ###

Class.forName()方法用于注册驱动程序类,此方法用于动态加载驱动程序类。

public static void main(String[] args) {
            //加载驱动
            try {
                //驱动类 com.mysql.jdbc.Driver
                Class.forName("com.mysql.jdbc.Driver");
                System.out.println("数据库驱动加载成功 ！");
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
        }

当运行以上代码，控制台会打印出这么一句话：

数据库驱动加载成功 ！
    Loading class `com.mysql.jdbc.Driver'. This is deprecated. The new driver class is `com.mysql.cj.jdbc.Driver'. The driver is automatically registered via the SPI and manual loading of the driver class is generally unnecessary.

很明显，驱动类【com.mysql.jdbc.Driver】已被弃用。 新的驱动程序类是\`com.mysql.cj.jdbc.Driver’。 驱动程序通过SPI自动注册，通常不需要手动加载驱动程序类。

> 注意：从JDBC 4.0开始，显式注册驱动程序是可选的。 我们只需要将相应的驱动jar放在类路径中，然后JDBC驱动程序管理器就可以自动检测并加载驱动程序。

### step 3 : 建立与数据库的连接 ###

使用DriverManager.getConnection()方法来创建一个Connection对象，它代表一个数据库的物理连接

### step 4 : 创建Statement ###

Connection接口的createStatement（）方法用于创建语句对象（Statement ）。 Statement 对象负责对数据库执行查询。

### step 5 : 执行SQL语句 ###

public static void main(String[] args) {
            //连接对象
            Connection conn = null;
            //SQL statement 对象
            Statement stmt = null;
            try {
                //01.加载驱动
                Class.forName("com.mysql.cj.jdbc.Driver");
                System.out.println("数据库驱动加载成功 ！");
                //02.创建连接对象
                conn = DriverManager.getConnection(
                        "jdbc:mysql://localhost:3306/lkf_db?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT",
                        "root", "root");
                //03.创建Statement
                stmt = conn.createStatement();
                System.out.println("连接成功，获取连接对象： " + conn);
                //04.执行SQL语句
                String sql = "CREATE TABLE `tb_user2` (\n" +
                        "  `id` bigint(20) NOT NULL AUTO_INCREMENT,\n" +
                        "  `user_name` varchar(30) DEFAULT NULL COMMENT '用户名',\n" +
                        "  `sex` int(1) DEFAULT '0' COMMENT '性别(0-男；1-女)',\n" +
                        "  `age` int(100) DEFAULT '0' COMMENT '年龄',\n" +
                        "  `birthday` datetime DEFAULT NULL COMMENT '生日',\n" +
                        "  `email` varchar(30) DEFAULT NULL COMMENT '邮箱',\n" +
                        "  `mobile` varchar(20) DEFAULT NULL COMMENT '手机号',\n" +
                        "  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间',\n" +
                        "  `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',\n" +
                        "  `status_flag` int(11) DEFAULT '0' COMMENT '状态（0-正常；1-停用）',\n" +
                        "  PRIMARY KEY (`id`)\n" +
                        ") ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8\n";
                int count = stmt.executeUpdate(sql);
                System.out.println("返回结果count：" + count);
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            }
        }

如果遇到以下错误提示：

java.sql.SQLException: The server time zone value 'ÖÐ¹ú±ê×¼Ê±¼ä' is unrecognized or represents more than one time zone. You must configure either the server or JDBC driver (via the serverTimezone configuration property) to use a more specifc time zone value if you want to utilize time zone support.

是因为新版本的数据库驱动需要指定UTC时区，将url地址后加上时区即可解决，“jdbc:mysql://localhost:3306/lkf\_db?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT”

### step 6 : 关闭连接 ###

Connection接口的close（）方法用于关闭连接，ResultSet 和 Statement 对象将会自动关闭。

> 注意：从Java 7开始，JDBC能够使用try-with-resources语句来自动关闭Connection，ResultSet和Statement类型的资源。

### try-with-resource ###

JDK1.7开始，java引入了 try-with-resources，将 try-catch-finally 简化为 try-catch，在编译时会自动转化为 try-catch-finally 语句。它要求在 try-with-resources 声明中定义的变量必须实现 AutoCloseable 接口，这样系统可以自动调用它们的close方法，从而替代了finally中关闭资源的功能。

public static void main( String[] args ) {
            try (
                    //01-创建连接
                    Connection conn = DriverManager.getConnection(
                            "jdbc:mysql://localhost:3306/lkf_db?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT",
                            "root", "root");
                    //02-创建 statement 对象
                    Statement stmt = conn.createStatement();
            ) {
                //03-执行SQL语句
                String sql = "CREATE TABLE `tb_user2` (\n" +
                        "  `id` BIGINT(20) NOT NULL AUTO_INCREMENT,\n" +
                        "  `user_name` VARCHAR(30) DEFAULT NULL COMMENT '用户名',\n" +
                        "  `sex` INT(1) DEFAULT '0' COMMENT '性别(0-男；1-女)',\n" +
                        "  `age` INT(100) DEFAULT '0' COMMENT '年龄',\n" +
                        "  `birthday` DATETIME DEFAULT NULL COMMENT '生日',\n" +
                        "  `email` VARCHAR(30) DEFAULT NULL COMMENT '邮箱',\n" +
                        "  `mobile` VARCHAR(20) DEFAULT NULL COMMENT '手机号',\n" +
                        "  `create_time` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间',\n" +
                        "  `update_time` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',\n" +
                        "  `status_flag` INT(11) DEFAULT '0' COMMENT '状态（0-正常；1-停用）',\n" +
                        "  PRIMARY KEY (`id`)\n" +
                        ") ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8\n";
                int count = stmt.executeUpdate(sql);
                System.out.println("返回结果count：" + count);
            } catch (SQLException e) {
                printSQLException(e);
            }
        }
    
        public static void printSQLException( SQLException ex ) {
            for (Throwable e : ex) {
                if (e instanceof SQLException) {
                    e.printStackTrace(System.err);
                    System.err.println("SQLState: " + ((SQLException) e).getSQLState());
                    System.err.println("Error Code: " + ((SQLException) e).getErrorCode());
                    System.err.println("Message: " + e.getMessage());
                    Throwable t = ex.getCause();
                    while (t != null) {
                        System.out.println("Cause: " + t);
                        t = t.getCause();
                    }
                }
            }
        }