Java基于JDBC连接MySQL数据库功能实例详解

前言

在Java程序中，经常需要使用数据库进行数据的存储和读取，而MySQL是广泛使用的开源关系型数据库之一。本文讲解使用Java的JDBC API连接MySQL数据库的方法和步骤，以及常见的增删查改操作。

步骤

1. 导入JDBC驱动

使用Java访问MySQL数据库需要导入MySQL JDBC连接驱动，可以在MySQL官网上下载。将其拷贝到Java项目目录的lib文件夹下，并在项目中添加该驱动依赖。

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>{version}</version>
</dependency>

2. 建立数据库连接

在Java程序中，通过使用DriverManager类，调用getConnection方法连接数据库。需要提供MySQL服务器的地址、端口号、数据库名称、用户名和密码等信息。

Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8", "root", "password");

3. 增加数据

向MySQL数据库中增加数据的方法是使用Statement对象执行SQL语句，可以使用executeUpdate方法，它将返回一个表示受影响行数的整数。例如：

Statement statement = conn.createStatement();
String sql = "INSERT INTO users (name, age) VALUES ('Tom', 25)";
int rows = statement.executeUpdate(sql);
System.out.println("新增用户成功，受影响行数：" + rows);

4. 查询数据

查询数据需要使用ResultSet对象，先创建Statement对象执行SQL，然后调用executeQuery方法获取ResultSet对象，遍历每一行数据即可。

Statement statement = conn.createStatement();
String sql = "SELECT * FROM users WHERE age > 20";
ResultSet rs = statement.executeQuery(sql);
while (rs.next()) {
    String name = rs.getString("name");
    int age = rs.getInt("age");
    System.out.println("姓名：" + name + "，年龄：" + age);
}

5. 修改数据

修改数据和增加数据类似，只需使用UPDATE语句，例如：

Statement statement = conn.createStatement();
String sql = "UPDATE users SET age = 28 WHERE name = 'Tom'";
int rows = statement.executeUpdate(sql);
System.out.println("更新用户成功，受影响行数：" + rows);

6. 删除数据

删除数据需要使用DELETE语句，例如：

Statement statement = conn.createStatement();
String sql = "DELETE FROM users WHERE age > 30";
int rows = statement.executeUpdate(sql);
System.out.println("删除用户成功，受影响行数：" + rows);

示例

下面是两个使用Java连接MySQL数据库的示例：

示例一：查询并输出数据

Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8", "root", "password");
Statement statement = conn.createStatement();
String sql = "SELECT * FROM users WHERE age > 20";
ResultSet rs = statement.executeQuery(sql);
while (rs.next()) {
    String name = rs.getString("name");
    int age = rs.getInt("age");
    System.out.println("姓名：" + name + "，年龄：" + age);
}
rs.close();
statement.close();
conn.close();

示例二：插入一条数据

Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8", "root", "password");
Statement statement = conn.createStatement();
String sql = "INSERT INTO users (name, age) VALUES ('Tom', 25)";
int rows = statement.executeUpdate(sql);
System.out.println("新增用户成功，受影响行数：" + rows);
statement.close();
conn.close();

结语

以上就是使用Java基于JDBC连接MySQL数据库的详细攻略。在实际开发中，还需要注意异常处理和连接池的使用，以提高程序的稳定性和效率。