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

public class OceanBaseExample {
    public static void main(String[] args) {
        // OceanBase数据库连接信息
        String url = "jdbc:OceanBase://your_oceanbase_server:your_oceanbase_port/your_database";
        String user = "your_username";
        String password = "your_password";

        // 加载OceanBase JDBC驱动
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            System.err.println("无法加载OceanBase JDBC驱动");
            e.printStackTrace();
            return;
        }

        // 建立连接
        try (Connection connection = DriverManager.getConnection(url, user, password)) {
            System.out.println("成功连接到OceanBase数据库");

            // 执行查询
            try (Statement statement = connection.createStatement()) {
                String sql = "SELECT * FROM your_table";
                try (ResultSet resultSet = statement.executeQuery(sql)) {
                    // 处理查询结果
                    while (resultSet.next()) {
                        // 从结果集中获取数据，例如 resultSet.getString("column_name")
                    }
                }
            }

        } catch (SQLException e) {
            System.err.println("连接或查询过程中发生错误");
            e.printStackTrace();
        }
    }
}