Mybatis源码解读-预习JDBC

为大家介绍 Java 如何使用 JDBC 连接 MySQL 数据库。

这里要注意一点就是 MySQL 8.0 版本的驱动路径不一致

JDBC链接MySQL 主要是几个步骤

1、链接驱动

2、获取链接

3、Statement初始化

4、执行SQL

5、处理结果集（如果是查询）

6、关闭资源（结果集，链接，Statement）

package org.apache.ibatis.jdbc;

import java.sql.*;
import java.util.Objects;

public class JdbcRunner {
  private static String DROP = " drop table begincode ";
  private static String CREATE = "create table begincode (\n" +
    "suppid int not null,\n" +
    "name varchar(80) null,\n" +
    "status varchar(2) not null,\n" +
    " phone varchar(80) null,\n" +
    "constraint pk_supplier primary key (suppid)\n" +
    ")";
  private static String QUERY = "select * from begincode";
  private static String ADD = "insert into begincode values(1,'begincode','T','1383838381')";

  // MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL
//  static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
//  static final String DB_URL = "jdbc:mysql://localhost:3306/test";

  // MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URL
  static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
  static final String DB_URL = "jdbc:mysql://localhost:3306/test?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";
  // 数据库用户名，改成自己数据库的用户名
  static final String username = "username";
  // 数据库密码，改成自己数据库的密码
  static final String password = "password";

  public static void main(String[] args) {
    Connection conn = null;
    Statement statement = null;
    try {
      // 1.连接驱动类
      Class.forName(JDBC_DRIVER);
      // 2.获取连接
      conn = DriverManager.getConnection(DB_URL, username, password);

      statement = conn.createStatement();
      /**
       * DDL 操作
       * 删表
       */
      statement.executeUpdate(DROP);
      /**
       * DDL 操作
       * 建表
       */
      statement.executeUpdate(CREATE);
      /**
       * 插入数据
       */
      statement.executeUpdate(ADD);
      /**
       * 查询
       */
      ResultSet resultset = statement.executeQuery(QUERY);
      while (resultset.next()) {
        System.out.println(resultset.getInt("suppid"));
        System.out.println(resultset.getString("name"));
        System.out.println(resultset.getString("status"));
        System.out.println(resultset.getString("phone"));
      }
      resultset.close();
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try {
        // 6.关闭资源
        if (Objects.nonNull(statement)) {
          statement.close();
        }
        if (Objects.nonNull(conn)) {
          conn.close();
        }
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }
}

执行后表数据

创建的表信息

输出结果

控制台输出结果