文档中心

读Phoenix表

功能简介
使用Phoenix实现读数据。

示例代码
以下代码片段在cn.chinatelecom.hbase.sample.PhoenixSample.sampleSelectData方法中。
    /**
     * Select Data
     */
    public static boolean sampleSelectData(Configuration conf) {
        log.info("Entering sampleSelectData.");
        int result = 0;
        //default assume zookeeper is stand-alone, and phoenix query server is same as zookeeper
        String url = "jdbc:phoenix:thin:url=http://" + conf.get("hbase.zookeeper.quorum") + ":" +
                conf.get("phoenix.queryserver.http.port", "8765") +
                ";serialization=" + conf.get("phoenix.queryserver.serialization", "PROTOBUF");
        String sql = "SELECT * FROM PHOENIX_SAMPLE WHERE id = ?";
        try (Connection conn = DriverManager.getConnection(url); PreparedStatement preStat = conn.prepareStatement(sql)
        ) {
            preStat.setInt(1, 1);
            try (ResultSet resultSet = preStat.executeQuery()) {
                while (resultSet.next()) {
                    result++;
                    int id = resultSet.getInt("id");
                    String name = resultSet.getString(1);
                    int age = resultSet.getInt("age");
                    System.out.println("id: " + id);
                    System.out.println("name: " + name);
                    System.out.println("age: " + age);
                }
                log.info("Select data successfully.");
            }
        } catch (Exception e) {
            log.error("Select data failed.", e);
        }
        log.info("Exiting sampleSelectData.");
        return result >= 0;
    }