文档中心

写Phoenix表

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

示例代码
以下代码片段在 cn.chinatelecom.hbase.sample.PhoenixSample.sampleUpsertData方法中。
    /**
     * Upsert data
     */
    public static boolean sampleUpsertData(Configuration conf) {
        log.info("Entering sampleUpsertData.");
        int result = -1;
        //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 = "UPSERT INTO PHOENIX_SAMPLE VALUES(1,'Tom',25)";
        try (Connection conn = DriverManager.getConnection(url); Statement stat = conn.createStatement()) {
            result = stat.executeUpdate(sql);
            log.info("Upsert data successfully.");
        } catch (Exception e) {
            log.error("Upsert data failed.", e);
        }
        log.info("Exiting sampleUpsertData.");
        return result >= 0;
    }