深入分析JavaWeb Item29 -- 使用JDBC处理大数据(MySql + Oracle)
import java.sql.*;
public class LargeDataExample {
private static final String DB_DRIVER = "com.mysql.cj.jdbc.Driver";
private static final String CONNECTION_URL = "jdbc:mysql://localhost:3306/mydb";
private static final String USERNAME = "root";
private static final String PASSWORD = "password";
public static void main(String[] args) {
// 注册JDBC驱动
try {
Class.forName(DB_DRIVER);
} catch (ClassNotFoundException e) {
e.printStackTrace();
return;
}
// 打开连接
try (Connection connection = DriverManager.getConnection(CONNECTION_URL, USERNAME, PASSWORD)) {
// 执行查询
try (Statement statement = connection.createStatement()) {
String query = "SELECT * FROM my_large_table";
ResultSet resultSet = statement.executeQuery(query);
// 处理结果
while (resultSet.next()) {
// 获取并处理数据
int id = resultSet.getInt("id");
String data = resultSet.getString("data");
// ... 进行其他处理
}
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
这段代码展示了如何使用JDBC连接MySQL数据库,执行一个查询并处理结果集。它使用了try-with-resources结构来自动关闭数据库连接和相关资源,以避免内存泄漏。注意,这里的CONNECTION_URL
、USERNAME
和PASSWORD
需要根据实际情况进行替换。
评论已关闭