使用MySQL Connector连接Java应用程序和MySQL数据库|极客笔记

使用MySQL Connector连接Java应用程序和MySQL数据库

MySQL是一个广泛使用的关系型数据库管理系统，而Java是一种常用的编程语言。为了在Java应用程序中使用MySQL数据库，我们可以使用MySQL Connector/J驱动程序。本文将详细介绍如何使用MySQL Connector/J连接Java应用程序和MySQL数据库。

安装和配置MySQL Connector/J

在开始之前，我们需要先安装MySQL Connector/J驱动程序并配置好Java环境。

首先，下载MySQL Connector/J驱动程序官方网站。
解压下载的文件并将mysql-connector-java-x.x.x.jar文件复制到Java项目的classpath中。
配置Java项目的pom.xml文件，将MySQL Connector/J添加为依赖项。

示例代码如下：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>x.x.x</version>
</dependency>

连接MySQL数据库

在Java应用程序中连接MySQL数据库，我们需要提供以下信息：

数据库的URL：指定数据库的位置和名称。
用户名和密码：用于身份验证和授权。

示例代码：

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

public class MySQLConnection {
    private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String USER = "root";
    private static final String PASSWORD = "password";

    public static void main(String[] args) {
        try {
            // 加载数据库驱动
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 建立数据库连接
            Connection connection = DriverManager.getConnection(URL, USER, PASSWORD);

            // 执行数据库操作
            // ...

            // 关闭数据库连接
            connection.close();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

运行结果：

无输出，表示连接成功。

执行SQL查询

连接建立后，我们可以使用Java执行SQL查询语句来从数据库中检索数据。

示例代码：

import java.sql.*;

public class MySQLQuery {
    private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String USER = "root";
    private static final String PASSWORD = "password";

    public static void main(String[] args) {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            Connection connection = DriverManager.getConnection(URL, USER, PASSWORD);

            // 创建和执行查询语句
            String query = "SELECT * FROM employees";
            Statement statement = connection.createStatement();
            ResultSet resultSet = statement.executeQuery(query);

            // 处理查询结果
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                int age = resultSet.getInt("age");

                System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age);
            }

            resultSet.close();
            statement.close();
            connection.close();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

运行结果：

ID: 1, Name: John, Age: 25
ID: 2, Name: Emma, Age: 28
ID: 3, Name: David, Age: 30
...

执行SQL更新

除了查询，我们还可以使用Java修改数据库中的数据。

示例代码：

import java.sql.*;

public class MySQLUpdate {
    private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String USER = "root";
    private static final String PASSWORD = "password";

    public static void main(String[] args) {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            Connection connection = DriverManager.getConnection(URL, USER, PASSWORD);

            // 创建和执行更新语句
            String update = "UPDATE employees SET age = 30 WHERE name = 'John'";
            Statement statement = connection.createStatement();
            int rowsAffected = statement.executeUpdate(update);

            System.out.println("Rows affected: " + rowsAffected);

            statement.close();
            connection.close();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

运行结果：

Rows affected: 1

执行SQL插入

我们还可以使用Java向数据库中插入新的数据。

示例代码：

import java.sql.*;

public class MySQLInsert {
    private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String USER = "root";
    private static final String PASSWORD = "password";

    public static void main(String[] args) {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            Connection connection = DriverManager.getConnection(URL, USER, PASSWORD);

            // 创建和执行插入语句
            String insert = "INSERT INTO employees (name, age) VALUES ('Alice', 27)";
            Statement statement = connection.createStatement();
            int rowsAffected = statement.executeUpdate(insert);

            System.out.println("Rows affected: " + rowsAffected);

            statement.close();
            connection.close();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

运行结果：

Rows affected: 1

执行SQL删除

最后，我们可以使用Java从数据库中删除数据。

示例代码：

import java.sql.*;

public class MySQLDelete {
    private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String USER = "root";
    private static final String PASSWORD = "password";

    public static void main(String[] args) {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            Connection connection = DriverManager.getConnection(URL, USER, PASSWORD);

            // 创建和执行删除语句
            String delete = "DELETE FROM employees WHERE name = 'David'";
            Statement statement = connection.createStatement();
            int rowsAffected = statement.executeUpdate(delete);

            System.out.println("Rows affected: " + rowsAffected);

            statement.close();
            connection.close();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

运行结果：

Rows affected: 1

总结

本文介绍了如何使用MySQL Connector/J连接Java应用程序和MySQL数据库。我们需要安装和配置MySQL Connector/J驱动程序，并提供数据库的URL、用户名和密码来建立连接。通过使用Java的Statement和ResultSet对象，我们可以执行SQL查询、更新、插入和删除操作。这些示例代码可以让您快速上手，在实际项目中使用MySQL数据库。