极客笔记MySQL 如何连接Java到MySQL？
MySQL是一个非常流行的关系型数据库管理系统，Java是目前最为流行的编程语言之一。如果你需要将Java应用程序连接到MySQL数据库，你需要学习如何连接它们。在本文中，我们将介绍如何在Java应用程序中连接到MySQL数据库，以及如何执行基本数据库操作。
阅读更多：MySQL 教程
步骤1：下载和安装MySQL Connector/J
MySQL Connector/J是MySQL提供的官方JDBC驱动程序。您可以通过官方网站 https://dev.mysql.com/downloads/connector/j/ 下载MySQL Connector/J。您需要下载并安装相应的版本，以与您的JDK匹配。一旦安装完成，您就可以开始创建Java应用程序来连接MySQL数据库了。
步骤2：导入MySQL Connector/J到Java项目
在创建Java项目之前，您需要将MySQL Connector/J导入到您的Java项目中。 要做到这一点，您需要将MySQL Connector/J的JAR文件复制到Java项目的类路径中。比如我们可以将JAR文件放到项目的“lib”文件夹中。然后将JAR文件添加到项目的编译路径中。
步骤3：创建连接到数据库的Java应用程序
首先，我们需要创建连接到MySQL数据库的Java应用程序。在下面的示例中，我们将连接到一个名为“mydatabase”的数据库，并使用用户名“root”和密码“123456”进行身份验证。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class MySQLConnUtils {
public static Connection getConnection() throws SQLException,
ClassNotFoundException {
String hostName = "localhost";
String dbName = "mydatabase";
String userName = "root";
String password = "123456";
return getConnection(hostName, dbName, userName, password);
}
public static Connection getConnection(String hostName, String dbName,
String userName, String password) throws SQLException,
ClassNotFoundException {
Class.forName("com.mysql.jdbc.Driver");
// URL Connection for MySQL
// Example: jdbc:mysql://localhost:3306/mydatabase
String connectionURL = "jdbc:mysql://" + hostName + ":3306/" + dbName;
Connection conn = DriverManager.getConnection(connectionURL, userName,
password);
return conn;
}
}
此时我们仅仅是连接了数据库，并并没有进行任何操作。
步骤4：插入数据到MySQL数据库
接下来，我们将通过Java应用程序向MySQL数据库插入数据。在下面的示例中，我们将向“employees”表中插入一条新记录。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class InsertDataToDB {
public static void main(String[] args) {
try {
Connection conn = MySQLConnUtils.getConnection();
String sql = "INSERT INTO employees (employee_id, last_name, first_name, email) "
+ "VALUES (?, ?, ?, ?)";
PreparedStatement statement = conn.prepareStatement(sql);
statement.setInt(1, 1001);
statement.setString(2, "Doe");
statement.setString(3, "John");
statement.setString(4, "johndoe@email.com");
int rowsInserted = statement.executeUpdate();
if (rowsInserted > 0) {
System.out.println("A new contact was inserted successfully!");
}
conn.close();
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
在这个例子中，我们首先建立了一个连接到MySQL数据库。接下来，我们创建了一个SQL INSERT语句，并使用PreparedStatement将参数设置为执行。最后，我们执行更新，并检查已插入的行数以确保成功。
步骤5：查询MySQL数据库
最后，我们将通过Java应用程序从MySQL数据库中查询数据。在下面的示例中，我们将查询“employees”表，并打印所返回的所有记录。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class QueryDataFromDB {
public static void main(String[] args) {
try {
Connection conn = MySQLConnUtils.getConnection();
String sql = "SELECT * FROMemployees";
PreparedStatement statement = conn.prepareStatement(sql);
ResultSet resultSet = statement.executeQuery();
while (resultSet.next()) {
int employeeId = resultSet.getInt("employee_id");
String lastName = resultSet.getString("last_name");
String firstName = resultSet.getString("first_name");
String email = resultSet.getString("email");
System.out.println(employeeId + ", " + lastName + ", " + firstName + ", " + email);
}
conn.close();
} catch (SQLException ex) {
ex.printStackTrace();
} catch (ClassNotFoundException ex) {
ex.printStackTrace();
}
}
}
在这个例子中，我们首先建立了一个连接到MySQL数据库。接下来，我们创建了一个SQL SELECT语句，并使用PreparedStatement执行它。最后，我们迭代查询结果集，将结果打印到控制台上。
结论
在本文中，我们介绍了如何使用Java应用程序连接到MySQL数据库，并执行基本数据库操作，例如插入，更新和查询数据。虽然这只是Java与MySQL交互的基础，但它为您提供了一个入门，以便您了解何时需要连接到MySQL，以及如何执行基本的数据库操作。希望这篇文章可以帮助您更好地理解Java与MySQL之间的连接。