极客笔记Java连接MySQL数据库代码
介绍
MySQL是一种广泛使用的关系型数据库管理系统，而Java则是一种强大的编程语言。在开发Java应用程序时，经常需要与MySQL数据库进行交互。本文章将详细介绍如何使用Java连接MySQL数据库，包括建立连接、执行查询和更新操作等。
环境准备
在开始之前，需要确保已经安装并配置好以下环境：
- Java开发环境
- MySQL数据库
- MySQL的Java连接驱动程序（JDBC驱动）
可以从MySQL官方网站下载最新的MySQL JDBC驱动程序。
建立数据库连接
首先，我们需要在Java中建立与MySQL数据库的连接。Java提供了java.sql包中的一些类和接口用于实现这一功能。下面是一个简单的示例代码，演示了如何建立与MySQL数据库的连接：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class Main {
public static void main(String[] args) {
// 数据库连接参数
String url = "jdbc:mysql://localhost:3306/mydatabase";
String username = "root";
String password = "123456";
try {
// 加载驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 建立数据库连接
Connection connection = DriverManager.getConnection(url, username, password);
// 打印连接成功信息
System.out.println("成功连接到数据库!");
// 关闭数据库连接
connection.close();
} catch (ClassNotFoundException e) {
System.out.println("找不到驱动程序");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("连接数据库失败");
e.printStackTrace();
}
}
}
运行上述代码后，如果输出成功连接到数据库的信息，则表示已经成功建立与MySQL数据库的连接。
执行查询操作
一旦成功建立数据库连接，我们就可以执行各种SQL查询操作了。使用Java连接MySQL数据库时，需要借助于java.sql.Statement接口和java.sql.ResultSet接口。下面是一个示例代码，演示了如何执行查询操作并获取结果：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class Main {
public static void main(String[] args) {
// 数据库连接参数
String url = "jdbc:mysql://localhost:3306/mydatabase";
String username = "root";
String password = "123456";
try {
// 加载驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 建立数据库连接
Connection connection = DriverManager.getConnection(url, username, password);
// 创建Statement对象
Statement statement = connection.createStatement();
// 执行查询操作
String sql = "SELECT * 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 + ", Name: " + name + ", Age: " + age);
}
// 关闭ResultSet对象
resultSet.close();
// 关闭Statement对象
statement.close();
// 关闭数据库连接
connection.close();
} catch (ClassNotFoundException e) {
System.out.println("找不到驱动程序");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("连接数据库失败");
e.printStackTrace();
}
}
}
运行上述代码，将会从名为users的表中查询数据，并打印出每条数据的ID、姓名和年龄信息。
执行更新操作
除了执行查询操作，我们还可以执行各种更新操作，例如插入、更新和删除等。与执行查询操作类似，需要使用java.sql.Statement接口来执行更新操作。下面是一个示例代码，演示了如何执行插入操作：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class Main {
public static void main(String[] args) {
// 数据库连接参数
String url = "jdbc:mysql://localhost:3306/mydatabase";
String username = "root";
String password = "123456";
try {
// 加载驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 建立数据库连接
Connection connection = DriverManager.getConnection(url, username, password);
// 创建Statement对象
Statement statement = connection.createStatement();
// 执行插入操作
String sql = "INSERT INTO users (name, age) VALUES ('Alice', 20)";
int rows = statement.executeUpdate(sql);
System.out.println("插入成功，影响行数：" + rows);
// 关闭Statement对象
statement.close();
// 关闭数据库连接
connection.close();
} catch (ClassNotFoundException e) {
System.out.println("找不到驱动程序");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("连接数据库失败");
e.printStackTrace();
}
}
}
运行上述代码后，将会向名为users的表中插入一条数据，并输出插入成功的信息。
总结
本文介绍了如何使用Java连接MySQL数据库，包括建立连接、执行查询和更新操作等。使用Java连接MySQL数据库时，需要借助于java.sql包中的类和接口，特别是java.sql.Connection、java.sql.Statement和java.sql.ResultSet等。