import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class OceanBaseResultSetExample {
public static void main(String[] args) {
try {
// 加载 JDBC 驱动
Class.forName("oracle.jdbc.driver.OracleDriver");
// OceanBase 数据库连接 URL
String url = "jdbc:oracle:thin:@localhost:1521:your_oceanbase_sid";
// 用户名和密码
String user = "your_username";
String password = "your_password";
// 获取连接
try (Connection connection = DriverManager.getConnection(url, user, password)) {
// 执行查询的 SQL 语句
String sql = "SELECT * FROM your_table_name";
// 预编译 SQL 语句
try (PreparedStatement statement = connection.prepareStatement(sql)) {
// 执行查询并获取结果集
try (ResultSet resultSet = statement.executeQuery()) {
// 处理结果集
while (resultSet.next()) {
// 获取每行数据的列值
int column1Value = resultSet.getInt("column1");
String column2Value = resultSet.getString("column2");
// ... 根据需要获取其他列的值
// 在这里可以对每一行的数据进行处理
System.out.println("Column1: " + column1Value + ", Column2: " + column2Value);
}
}
}
}
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
}
}
}
在上述代码中:
- your_oceanbase_sid 是 OceanBase 数据库的 SID。
- your_username 和 your_password 是连接数据库时使用的用户名和密码。
- your_table_name 是要查询的表名。
具体的 SQL 语句和列名需要根据你的数据库表结构进行调整。
注意,上述代码使用了 try-with-resources 语句,确保在使用完连接、语句和结果集后及时关闭资源。这有助于避免资源泄漏。
请确保根据你的实际情况修改连接 URL、用户名、密码、SQL 语句和表名。此外,具体的连接 URL 格式和配置属性可能会因 OceanBase 数据库版本的不同而有所不同。建议查阅当前版本的 OceanBase 文档以获取最准确和最新的信息。
转载请注明出处:http://www.pingtaimeng.com/article/detail/11438/OceanBase