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

public class OceanBaseCursorExample {

    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)) {
                // 调用存储过程并使用游标获取结果集
                ResultSet resultSet = executeProcedureWithCursor(connection);

                // 处理结果集
                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();
        }
    }

    private static ResultSet executeProcedureWithCursor(Connection connection) throws SQLException {
        // 调用存储过程的 SQL 语句，其中使用 OUT 参数来返回结果集的游标
        String callProcedureSql = "{CALL your_procedure_name(?, ?)}";

        try (CallableStatement callableStatement = connection.prepareCall(callProcedureSql)) {
            // 注册 OUT 参数，该参数用于返回结果集的游标
            callableStatement.registerOutParameter(1, OracleTypes.CURSOR);

            // 设置其他输入参数（如果有的话）
            callableStatement.setString(2, "input_parameter_value");

            // 执行存储过程
            callableStatement.execute();

            // 获取结果集的游标
            ResultSet resultSet = (ResultSet) callableStatement.getObject(1);

            return resultSet;
        }
    }
}