MySQL - Java 语法



为了与数据库通信,Java 提供了一个名为 JDBC (Java Database Connectivity) 的库。JDBC 提供了一组专门用于数据库连接的类和方法,使 Java 开发人员能够执行诸如建立连接、执行查询和管理 MySQL 数据库中的数据等任务。

JDBC 安装

要将 MySQL 与 Java 一起使用,您需要使用 JDBC (Java Database Connectivity) 驱动程序将您的 Java 应用程序连接到 MySQL 数据库。以下是安装和使用 MySQL Connector/J 的一般步骤,它是 Java 的官方 MySQL JDBC 驱动程序:

步骤 1:下载 MySQL Connector/J

访问官方 MySQL Connector/J 下载页面:MySQL Connector/J 下载。

步骤 2:选择合适的版本

根据您的 MySQL 服务器版本和 Java 版本选择合适的版本。下载包含 JDBC 驱动程序的 ZIP 或 TAR 存档。

步骤 3:解压存档

将下载的存档内容解压到您计算机上的某个位置。

步骤 4:将 Connector/J 添加到您的 Java 项目

在您的 Java 项目中,将 Connector/J JAR 文件添加到您的类路径中。您可以在 IDE 中执行此操作,也可以手动将 JAR 文件复制到您的项目中。

步骤 5:在 Java 中连接到 MySQL 数据库

在您的 Java 代码中,使用 JDBC API 连接到 MySQL 数据库。

访问 MySQL 的 Java 函数

以下是从 Java 访问 MySQL 的主要函数:

序号 函数 & 描述
1

DriverManager.getConnection(String url, String user, String password)

使用指定的 URL、用户名和密码建立与数据库的连接。

2

createStatement()

创建一个 Statement 对象来执行 SQL 查询。

3

executeQuery(String sql)

执行 SQL SELECT 查询并返回包含结果集的 ResultSet 对象。

4

executeUpdate(String sql)

执行 SQL INSERT、UPDATE、DELETE 或其他非查询语句。

5

next()

将光标移动到结果集中的下一行。如果存在下一行,则返回 true,否则返回 false。

6

getInt(String columnLabel)

检索结果集当前行中指定列的值。

7

prepareStatement(String sql)

创建一个 PreparedStatement 对象来执行参数化 SQL 查询。

8

setXXX(int parameterIndex, XXX value)

设置预处理语句中指定参数的值。

9

executeQuery(), executeUpdate()

将预处理语句作为查询或更新执行。

10

setAutoCommit(boolean autoCommit)

启用或禁用自动提交模式。

11

commit()

提交当前事务。

12

rollback()

回滚当前事务。

基本示例

要使用 Java 连接和与 MySQL 数据库通信,您可以按照以下步骤操作:

  • 加载特定于您的数据库的 JDBC 驱动程序。
  • 使用“DriverManager.getConnection()”创建与数据库的连接。
  • 创建“Statement”或“PreparedStatement”来执行 SQL 查询。
  • 对于 SELECT 查询,使用“executeQuery()”,对于其他语句,使用“executeUpdate()”。
  • 迭代“ResultSet”以处理检索到的数据。
  • 关闭“ResultSet”、“Statement”和“Connection”以释放资源。
  • 将数据库代码包装在 try-catch 块中以处理异常。
  • 如果将多个操作作为单个单元执行,则使用事务。

以下示例显示了用于调用任何 MySQL 查询的 Java 程序的通用语法:

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

public class DatabaseInteractionExample {

    public static void main(String[] args) {
        try {
            // Load JDBC Driver
            Class.forName("com.mysql.cj.jdbc.Driver");

            // Connect to Database
            Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/your_database", "your_username", "your_password");

            // Execute Query
            Statement statement = connection.createStatement();
            ResultSet resultSet = statement.executeQuery("Your SQL Query");

            // Process Results
            while (resultSet.next()) {
                // Process data
            }

            // Close Resources
            resultSet.close();
            statement.close();
            connection.close();

            // Handle Exceptions
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }
    }
}
广告