Java连接MySQL数据库教程

MySQL是一种开源的关系型数据库管理系统，它使用SQL语言进行查询和管理数据。Java是一种面向对象的编程语言，它可以通过数据库连接驱动程序来连接MySQL数据库。本教程将介绍如何使用Java连接MySQL数据库，从而实现对数据库的增删改查操作。

一、导入MySQL数据库连接驱动程序

在使用Java连接MySQL数据库之前，我们需要先导入MySQL数据库连接驱动程序。MySQL Connector/J是MySQL官方提供的Java数据库连接驱动程序，我们可以从其官方网站上下载最新的MySQL Connector/J版本。下载完成之后，将其解压到项目的classpath路径下。

二、连接MySQL数据库

使用Java连接MySQL数据库需要两个关键的步骤：导入MySQL Connector/J驱动程序和建立数据库连接。下面是一个示例代码：

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

public class MySQLConnector {
    private static final String jdbcUrl = "jdbc:mysql://localhost:3306/test";
    private static final String username = "root";
    private static final String password = "password";

    public static Connection connect() throws SQLException {
        Connection connection = DriverManager.getConnection(jdbcUrl, username, password);
        return connection;
    }
}

上述代码中，我们首先定义了MySQL数据库的连接URL、用户名和密码。然后，在connect()方法中，我们使用DriverManager来建立与MySQL数据库的连接。如果连接成功，将返回一个Connection对象。

三、数据操作

1. 查询数据

下面是一个示例代码，演示如何从MySQL表中查询数据：

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

public class QueryDemo {
    public static void main(String[] args) throws SQLException {
        Connection connection = MySQLConnector.connect();
        Statement statement = connection.createStatement();
        ResultSet resultSet = statement.executeQuery("SELECT * FROM users");

        while (resultSet.next()) {
            int id = resultSet.getInt("id");
            String name = resultSet.getString("name");
            String email = resultSet.getString("email");
            System.out.printf("id: %d, name: %s, email: %s\n", id, name, email);
        }

        resultSet.close();
        statement.close();
        connection.close();
    }
}

上述代码中，我们首先通过MySQLConnector类中的connect()方法连接到MySQL数据库。然后，我们创建一个Statement对象，使用它来执行SQL语句。在这个示例代码中，我们使用的SQL语句是“SELECT * FROM users”，它会从users表中查询所有的记录并返回一个ResultSet对象。最后，我们通过ResultSet对象的next()方法逐行遍历返回的结果，使用getInt()和getString()方法获取每一行记录中每个列的数据。

2. 插入数据

下面是一个示例代码，演示如何向MySQL表中插入数据：

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

public class InsertDemo {
    public static void main(String[] args) throws SQLException {
        Connection connection = MySQLConnector.connect();
        Statement statement = connection.createStatement();

        String name = "Tom";
        String email = "tom@example.com";
        int rows = statement.executeUpdate("INSERT INTO users(name, email) VALUES('" + name + "', '" + email + "')");

        System.out.printf("%d row(s) affected\n", rows);

        statement.close();
        connection.close();    
    }
}

上述代码中，我们使用Statement对象的executeUpdate()方法向users表中插入了一行记录。INSERT语句的语法为“INSERT INTO table_name(column1, column2, ..., columnN) VALUES(value1, value2, ..., valueN)”。

3. 更新数据

下面是一个示例代码，演示如何更新MySQL表中的数据：

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

public class UpdateDemo {
    public static void main(String[] args) throws SQLException {
        Connection connection = MySQLConnector.connect();
        Statement statement = connection.createStatement();

        int rows = statement.executeUpdate("UPDATE users SET email='new_email@example.com' WHERE id=1");

        System.out.printf("%d row(s) affected\n", rows);

        statement.close();
        connection.close();    
    }
}

上述代码中，我们使用Statement对象的executeUpdate()方法更新了users表中id为1的记录。UPDATE语句的语法为“UPDATE table_name SET column1=value1, column2=value2, ..., columnN=valueN WHERE condition”。

4. 删除数据

下面是一个示例代码，演示如何从MySQL表中删除数据：

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

public class DeleteDemo {
    public static void main(String[] args) throws SQLException {
        Connection connection = MySQLConnector.connect();
        Statement statement = connection.createStatement();

        int rows = statement.executeUpdate("DELETE FROM users WHERE id=1");

        System.out.printf("%d row(s) affected\n", rows);

        statement.close();
        connection.close();    
    }
}

上述代码中，我们使用Statement对象的executeUpdate()方法删除了users表中id为1的记录。DELETE语句的语法为“DELETE FROM table_name WHERE condition”。

结论

通过上述介绍，我们可以看到使用Java连接MySQL数据库并实现增删改查的操作十分简单。我们只需导入MySQL Connector/J驱动程序、建立数据库连接、使用Statement对象执行SQL语句即可轻松地操作MySQL数据库。