JDBC Java 连接 MySQL 数据库

MySQL 版本：Server version: 5.7.17-log MySQL Community Server (GPL)

---

用于测试的 MySQL 数据库：game

查看数据库中的表

mysql> SHOW TABLES;
+----------------+
| Tables_in_game |
+----------------+
| user           |
+----------------+
1 row in set (0.00 sec)

查看表的定义

mysql> DESC user;
+----------+-------------+------+-----+---------+----------------+
| Field    | Type        | Null | Key | Default | Extra          |
+----------+-------------+------+-----+---------+----------------+
| id       | int(8)      | NO   | PRI | NULL    | auto_increment |
| username | varchar(16) | NO   |     | NULL    |                |
| password | varchar(16) | NO   |     | NULL    |                |
+----------+-------------+------+-----+---------+----------------+
3 rows in set (0.00 sec)

查看表中的数据

mysql> SELECT * FROM user;
+----+----------+----------+
| id | username | password |
+----+----------+----------+
|  1 | mk       | 123      |
|  2 | seven    | 456      |
+----+----------+----------+
2 rows in set (0.00 sec)

使用 Java 连接 MySQL 数据库，查询表中的数据。

Java 工程结构：

Demo.java 文件中的内容：

package com.mk;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class Demo {

  public static void main(String[] args) {
    Connection connection = null;
    PreparedStatement ps = null;
    ResultSet rs = null;
    try {
      // 加载 MySQL JDBC 驱动类
      Class.forName("com.mysql.jdbc.Driver");
      // 建立连接（连接对象内部其实包含了Socket对象，是一个远程的连接，比较耗时！这是Connection对象管理的一个要点！）
      // 真正开发中，为了提高效率，都会使用连接池来管理连接对象！
      connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/game", "root", "123456");
      // 查询语句
      String sql = "SELECT * FROM user WHERE username=?";   // ? 占位符
      // 使用 PreparedStatement，防止 SQL 注入
      ps = connection.prepareStatement(sql);
      // 设置占位符参数
      ps.setString(1, "mk");
      // 返回查询结果
      rs = ps.executeQuery();
      while (rs.next()) {
        System.out.println("id: " + rs.getInt("id"));
        System.out.println("username: " + rs.getString("username"));
        System.out.println("password: " + rs.getString("password"));
      }
    } catch (ClassNotFoundException e) {
      e.printStackTrace();
    } catch (SQLException e) {
      e.printStackTrace();
    } finally {
      if (rs != null) {
        try {
          rs.close();
        } catch (SQLException e) {
          e.printStackTrace();
        }
      }
      if (ps != null) {
        try {
          ps.close();
        } catch (SQLException e) {
          e.printStackTrace();
        }
      }
      if (connection != null) {
        try {
          connection.close();
        } catch (SQLException e) {
          e.printStackTrace();
        }
      }
    }
  }
}

查询结果通过控制台输出：

id: 1
username: mk
password: 123

---

相关参考：Java 从资源文件（.properties）中读取数据

改进一下上面的例子，将连接 MySQL 数据库的 url、user、password 等参数放置在一个资源文件中，通过 Java 程序读取资源文件，获取相关信息。这样可以提高程序的灵活性，如果 url、user、password 等参数发生变更，只需修改资源文件即可。

在 Java 工程目录 src 下，添加一个文件：db.properties

db.properties 文件中的内容：

mysqlDriver=com.mysql.jdbc.Driver
mysqlUrl=jdbc:mysql://localhost:3306/game
mysqlUser=root
mysqlPassword=123456

修改 Demo.java 文件中的内容：

package com.mk;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

public class Demo {
  static Properties properties = null;  // 用于读取和处理资源文件中的信息
  static {                              // 类加载的时候被执行一次
    properties = new Properties();
    try {
      properties.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("db.properties"));
//      System.out.println(properties.getProperty("mysqlDriver"));  // 根据提供的键找到值
//      System.out.println(properties.getProperty("mysqlUrl"));
//      System.out.println(properties.getProperty("mysqlUser"));
//      System.out.println(properties.getProperty("mysqlPassword"));
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
  
  public static void main(String[] args) {
    Connection connection = null;
    PreparedStatement ps = null;
    ResultSet rs = null;
    try {
      // 加载 MySQL JDBC 驱动类
      Class.forName(properties.getProperty("mysqlDriver"));
      // 建立连接（连接对象内部其实包含了Socket对象，是一个远程的连接，比较耗时！这是Connection对象管理的一个要点！）
      // 真正开发中，为了提高效率，都会使用连接池来管理连接对象！
      String mysqlUrl = properties.getProperty("mysqlUrl");
      String mysqlUser = properties.getProperty("mysqlUser");
      String mysqlPassword = properties.getProperty("mysqlPassword");
      connection = DriverManager.getConnection(mysqlUrl, mysqlUser, mysqlPassword);
      // 查询语句
      String sql = "SELECT * FROM user WHERE username=?";   // ? 占位符
      // 使用 PreparedStatement，防止 SQL 注入
      ps = connection.prepareStatement(sql);
      // 设置占位符参数
      ps.setString(1, "mk");
      // 返回查询结果
      rs = ps.executeQuery();
      while (rs.next()) {
        System.out.println("id: " + rs.getInt("id"));
        System.out.println("username: " + rs.getString("username"));
        System.out.println("password: " + rs.getString("password"));
      }
    } catch (ClassNotFoundException e) {
      e.printStackTrace();
    } catch (SQLException e) {
      e.printStackTrace();
    } finally {
      if (rs != null) {
        try {
          rs.close();
        } catch (SQLException e) {
          e.printStackTrace();
        }
      }
      if (ps != null) {
        try {
          ps.close();
        } catch (SQLException e) {
          e.printStackTrace();
        }
      }
      if (connection != null) {
        try {
          connection.close();
        } catch (SQLException e) {
          e.printStackTrace();
        }
      }
    }
  }
}