[Mysql]Java轻松连接MySQL，告别数据库小白困境

引言在Java编程中，数据库操作是必不可少的技能之一。MySQL作为一款流行的开源关系型数据库，被广泛应用于各种项目中。本文将详细介绍如何使用Java轻松连接MySQL数据库，帮助您从数据库小白成长为...

引言

在Java编程中，数据库操作是必不可少的技能之一。MySQL作为一款流行的开源关系型数据库，被广泛应用于各种项目中。本文将详细介绍如何使用Java轻松连接MySQL数据库，帮助您从数据库小白成长为一名熟练的数据库操作者。

准备工作

在开始之前，请确保您已经完成了以下准备工作：

1. 安装MySQL数据库：从官网下载并安装MySQL数据库，并确保其正常运行。

2. 创建数据库和表：在MySQL中创建一个数据库和至少一个表，用于后续的连接和操作。

3. 添加MySQL JDBC驱动：将MySQL JDBC驱动添加到Java项目中，可以通过以下两种方式：

   • 下载MySQL JDBC驱动包，并将其添加到项目的lib目录下。
   • 在项目的pom.xml文件中添加以下依赖：

     mysql mysql-connector-java 8.0.26 

连接MySQL数据库

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

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class Main { public static void main(String[] args) { // 数据库连接参数 String url = "jdbc:mysql://localhost:3306/数据库名?useSSL=false&serverTimezone=UTC"; String username = "用户名"; String password = "密码"; // 加载MySQL JDBC驱动 try { Class.forName("com.mysql.cj.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); return; } // 建立数据库连接 try (Connection connection = DriverManager.getConnection(url, username, password)) { System.out.println("连接成功！"); } catch (SQLException e) { e.printStackTrace(); } }
}

操作数据库

连接成功后，您可以使用以下方法操作数据库：

查询数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class Main { public static void main(String[] args) { // 数据库连接参数 String url = "jdbc:mysql://localhost:3306/数据库名?useSSL=false&serverTimezone=UTC"; String username = "用户名"; String password = "密码"; // SQL查询语句 String sql = "SELECT * FROM 表名"; // 加载MySQL JDBC驱动 try { Class.forName("com.mysql.cj.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); return; } // 建立数据库连接 try (Connection connection = DriverManager.getConnection(url, username, password); PreparedStatement statement = connection.prepareStatement(sql); ResultSet resultSet = statement.executeQuery()) { // 遍历结果集 while (resultSet.next()) { // 获取字段值 int id = resultSet.getInt("id"); String name = resultSet.getString("name"); // ... 其他字段 // 打印结果 System.out.println("ID: " + id + ", Name: " + name); } } catch (SQLException e) { e.printStackTrace(); } }
}

插入数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class Main { public static void main(String[] args) { // 数据库连接参数 String url = "jdbc:mysql://localhost:3306/数据库名?useSSL=false&serverTimezone=UTC"; String username = "用户名"; String password = "密码"; // SQL插入语句 String sql = "INSERT INTO 表名 (字段1, 字段2) VALUES (?, ?)"; // 加载MySQL JDBC驱动 try { Class.forName("com.mysql.cj.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); return; } // 建立数据库连接 try (Connection connection = DriverManager.getConnection(url, username, password); PreparedStatement statement = connection.prepareStatement(sql)) { // 设置参数值 statement.setInt(1, 1); statement.setString(2, "张三"); // 执行插入操作 int affectedRows = statement.executeUpdate(); if (affectedRows > 0) { System.out.println("插入成功！"); } } catch (SQLException e) { e.printStackTrace(); } }
}

更新数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class Main { public static void main(String[] args) { // 数据库连接参数 String url = "jdbc:mysql://localhost:3306/数据库名?useSSL=false&serverTimezone=UTC"; String username = "用户名"; String password = "密码"; // SQL更新语句 String sql = "UPDATE 表名 SET 字段1 = ? WHERE 字段2 = ?"; // 加载MySQL JDBC驱动 try { Class.forName("com.mysql.cj.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); return; } // 建立数据库连接 try (Connection connection = DriverManager.getConnection(url, username, password); PreparedStatement statement = connection.prepareStatement(sql)) { // 设置参数值 statement.setString(1, "新值"); statement.setInt(2, 1); // 执行更新操作 int affectedRows = statement.executeUpdate(); if (affectedRows > 0) { System.out.println("更新成功！"); } } catch (SQLException e) { e.printStackTrace(); } }
}

删除数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class Main { public static void main(String[] args) { // 数据库连接参数 String url = "jdbc:mysql://localhost:3306/数据库名?useSSL=false&serverTimezone=UTC"; String username = "用户名"; String password = "密码"; // SQL删除语句 String sql = "DELETE FROM 表名 WHERE 字段1 = ?"; // 加载MySQL JDBC驱动 try { Class.forName("com.mysql.cj.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); return; } // 建立数据库连接 try (Connection connection = DriverManager.getConnection(url, username, password); PreparedStatement statement = connection.prepareStatement(sql)) { // 设置参数值 statement.setInt(1, 1); // 执行删除操作 int affectedRows = statement.executeUpdate(); if (affectedRows > 0) { System.out.println("删除成功！"); } } catch (SQLException e) { e.printStackTrace(); } }
}

总结

通过本文的介绍，相信您已经掌握了使用Java连接MySQL数据库的方法。在实际开发过程中，请根据项目需求灵活运用各种数据库操作，不断积累经验，成为一名优秀的数据库操作者。