JDBC Java 连接 MySQL 数据库

迈不过友情╰ 2021-11-01 22:38 499阅读 0赞

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

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

Java 工程结构：

![1309478-20190715172959697-1218507221.png][]

Demo.java 文件中的内容：

1 package com.mk;
     2 
     3 import java.sql.Connection;
     4 import java.sql.DriverManager;
     5 import java.sql.PreparedStatement;
     6 import java.sql.ResultSet;
     7 import java.sql.SQLException;
     8 
     9 public class Demo {
    10 
    11   public static void main(String[] args) {
    12     Connection connection = null;
    13     PreparedStatement ps = null;
    14     ResultSet rs = null;
    15     try {
    16       // 加载 MySQL JDBC 驱动类
    17       Class.forName("com.mysql.jdbc.Driver");
    18       // 建立连接（连接对象内部其实包含了Socket对象，是一个远程的连接，比较耗时！这是Connection对象管理的一个要点！）
    19       // 真正开发中，为了提高效率，都会使用连接池来管理连接对象！
    20       connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/game", "root", "123456");
    21       // 查询语句
    22       String sql = "SELECT * FROM user WHERE username=?";   // ? 占位符
    23       // 使用 PreparedStatement，防止 SQL 注入
    24       ps = connection.prepareStatement(sql);
    25       // 设置占位符参数
    26       ps.setString(1, "mk");
    27       // 返回查询结果
    28       rs = ps.executeQuery();
    29       while (rs.next()) {
    30         System.out.println("id: " + rs.getInt("id"));
    31         System.out.println("username: " + rs.getString("username"));
    32         System.out.println("password: " + rs.getString("password"));
    33       }
    34     } catch (ClassNotFoundException e) {
    35       e.printStackTrace();
    36     } catch (SQLException e) {
    37       e.printStackTrace();
    38     } finally {
    39       if (rs != null) {
    40         try {
    41           rs.close();
    42         } catch (SQLException e) {
    43           e.printStackTrace();
    44         }
    45       }
    46       if (ps != null) {
    47         try {
    48           ps.close();
    49         } catch (SQLException e) {
    50           e.printStackTrace();
    51         }
    52       }
    53       if (connection != null) {
    54         try {
    55           connection.close();
    56         } catch (SQLException e) {
    57           e.printStackTrace();
    58         }
    59       }
    60     }
    61   }
    62 }

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

id: 1
    username: mk
    password: 123

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

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

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

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

![1309478-20190715174743714-1015166228.png][]

db.properties 文件中的内容：

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

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

1 package com.mk;
     2 
     3 import java.io.IOException;
     4 import java.sql.Connection;
     5 import java.sql.DriverManager;
     6 import java.sql.PreparedStatement;
     7 import java.sql.ResultSet;
     8 import java.sql.SQLException;
     9 import java.util.Properties;
    10 
    11 public class Demo {
    12   static Properties properties = null;  // 用于读取和处理资源文件中的信息
    13   static {                              // 类加载的时候被执行一次
    14     properties = new Properties(); 15     try { 16       properties.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("db.properties")); 17 // System.out.println(properties.getProperty("mysqlDriver")); // 根据提供的键找到值 18 // System.out.println(properties.getProperty("mysqlUrl")); 19 // System.out.println(properties.getProperty("mysqlUser")); 20 // System.out.println(properties.getProperty("mysqlPassword"));
    21     } catch (IOException e) { 22 e.printStackTrace(); 23 } 24 } 25   
    26   public static void main(String[] args) {
    27     Connection connection = null;
    28     PreparedStatement ps = null;
    29     ResultSet rs = null;
    30     try {
    31       // 加载 MySQL JDBC 驱动类
    32       Class.forName(properties.getProperty("mysqlDriver")); 33       // 建立连接（连接对象内部其实包含了Socket对象，是一个远程的连接，比较耗时！这是Connection对象管理的一个要点！）
    34       // 真正开发中，为了提高效率，都会使用连接池来管理连接对象！
    35       String mysqlUrl = properties.getProperty("mysqlUrl"); 36       String mysqlUser = properties.getProperty("mysqlUser"); 37       String mysqlPassword = properties.getProperty("mysqlPassword"); 38       connection = DriverManager.getConnection(mysqlUrl, mysqlUser, mysqlPassword); 39       // 查询语句
    40       String sql = "SELECT * FROM user WHERE username=?";   // ? 占位符
    41       // 使用 PreparedStatement，防止 SQL 注入
    42       ps = connection.prepareStatement(sql);
    43       // 设置占位符参数
    44       ps.setString(1, "mk");
    45       // 返回查询结果
    46       rs = ps.executeQuery();
    47       while (rs.next()) {
    48         System.out.println("id: " + rs.getInt("id"));
    49         System.out.println("username: " + rs.getString("username"));
    50         System.out.println("password: " + rs.getString("password"));
    51       }
    52     } catch (ClassNotFoundException e) {
    53       e.printStackTrace();
    54     } catch (SQLException e) {
    55       e.printStackTrace();
    56     } finally {
    57       if (rs != null) {
    58         try {
    59           rs.close();
    60         } catch (SQLException e) {
    61           e.printStackTrace();
    62         }
    63       }
    64       if (ps != null) {
    65         try {
    66           ps.close();
    67         } catch (SQLException e) {
    68           e.printStackTrace();
    69         }
    70       }
    71       if (connection != null) {
    72         try {
    73           connection.close();
    74         } catch (SQLException e) {
    75           e.printStackTrace();
    76         }
    77       }
    78     }
    79   }
    80 }

转载于:https://www.cnblogs.com/Satu/p/10652494.html

[1309478-20190715172959697-1218507221.png]: /images/20211101/59c6a204f3b74578814a4e58a2918cf8.png
[Java _.properties]: https://www.cnblogs.com/Satu/p/11079745.html
[1309478-20190715174743714-1015166228.png]: /images/20211101/325a0c24beca402389218401d52f12ff.png