Java连接MySQL数据库实例

在Java编程中，数据库连接是非常重要的一部分内容。这篇文章将会详细介绍如何使用Java连接MySQL数据库，并提供完整的代码示例。

一、准备工作

1、下载MySQL数据库。

2、安装MySQL并完成配置。

3、下载MySQL JDBC驱动程序，将其放在项目的classpath下，或者将其导入项目中的lib文件夹下。

4、创建一个Java项目。

二、连接MySQL数据库

首先，我们需要在Java程序中创建一个与MySQL服务器的连接。下面是一个Java连接MySQL数据库的示例：

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

public class MySQLJDBCExample {
        public static void main(String[] argv) {
                System.out.println("-------- MySQL JDBC Connection Testing ------------");

                try {
                        Class.forName("com.mysql.jdbc.Driver");
                } catch (ClassNotFoundException e) {
                        System.out.println("Where is your MySQL JDBC Driver?");
                        e.printStackTrace();
                        return;
                }

                System.out.println("MySQL JDBC Driver Registered!");

                Connection connection = null;

                try {
                        connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydatabase", "root", "password");
                } catch (SQLException e) {
                        System.out.println("Connection Failed! Check output console");
                        e.printStackTrace();
                        return;
                }

                if (connection != null) {
                        System.out.println("You made it, take control your database now!");
                } else {
                        System.out.println("Failed to make connection!");
                }
        }
}

请注意，除了要导入java.sql和java.sql.DriverManager外，还需要在代码中指定MySQL JDBC驱动程序。这可以通过Class.forName（）方法来完成。

三、执行查询

接下来，我们将执行一个SELECT查询来获取数据库中的数据，并将结果存储在一个ResultSet对象中。下面是一个Java执行SELECT查询的示例：

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

public class MySQLJDBCExample {
        public static void main(String[] argv) {
                System.out.println("-------- MySQL JDBC Connection Testing ------------");

                try {
                        Class.forName("com.mysql.jdbc.Driver");
                } catch (ClassNotFoundException e) {
                        System.out.println("Where is your MySQL JDBC Driver?");
                        e.printStackTrace();
                        return;
                }

                System.out.println("MySQL JDBC Driver Registered!");

                Connection connection = null;
                Statement statement = null;

                try {
                        connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydatabase", "root", "password");

                        statement = connection.createStatement();
                        String sql = "SELECT id, name, age FROM users";
                        ResultSet resultSet = statement.executeQuery(sql);

                        while (resultSet.next()) {
                                int id = resultSet.getInt("id");
                                String name = resultSet.getString("name");
                                int age = resultSet.getInt("age");

                                System.out.println("ID: " + id);
                                System.out.println("Name: " + name);
                                System.out.println("Age: " + age);
                        }
                } catch (SQLException e) {
                        System.out.println("Connection Failed! Check output console");
                        e.printStackTrace();
                        return;
                }

                if (connection != null) {
                        System.out.println("You made it, take control your database now!");
                } else {
                        System.out.println("Failed to make connection!");
                }
        }
}

请注意，ResultSet中的数据可以使用getInt（）、getString（）等类型特定的方法来访问，并且需要对ResultSet对象进行处理。在这个例子中，我们使用一个while循环来处理ResultSet对象中的每行数据。

四、更新数据

除了查询数据外，我们还可以更新数据库中的数据。下面是一个Java更新MySQL数据库中的数据的示例：

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

public class MySQLJDBCExample {
        public static void main(String[] argv) {
                System.out.println("-------- MySQL JDBC Connection Testing ------------");

                try {
                        Class.forName("com.mysql.jdbc.Driver");
                } catch (ClassNotFoundException e) {
                        System.out.println("Where is your MySQL JDBC Driver?");
                        e.printStackTrace();
                        return;
                }

                System.out.println("MySQL JDBC Driver Registered!");

                Connection connection = null;
                PreparedStatement preparedStatement = null;

                try {
                        connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydatabase", "root", "password");

                        String sql = "UPDATE users SET age = ? WHERE id = ?";
                        preparedStatement = connection.prepareStatement(sql);

                        preparedStatement.setInt(1, 29);
                        preparedStatement.setInt(2, 1);

                        int rowsUpdated = preparedStatement.executeUpdate();
                        if (rowsUpdated > 0) {
                                System.out.println("An existing user was updated successfully!");
                        }
                } catch (SQLException e) {
                        System.out.println("Connection Failed! Check output console");
                        e.printStackTrace();
                        return;
                }

                if (connection != null) {
                        System.out.println("You made it, take control your database now!");
                } else {
                        System.out.println("Failed to make connection!");
                }
        }
}

在这个例子中，我们使用PreparedStatement对象，并使用？占位符来避免SQL注入攻击的风险。此外，我们还使用setInt（）方法来设置数据并执行更新操作。

五、总结

通过这篇文章，您学习了如何使用Java连接MySQL数据库，并执行SELECT查询、更新数据等操作。这是Java程序中非常重要的一部分内容，希望这篇文章能对您提供一些帮助。