文档中心

创建Phoenix表

功能简介
Phoenix依赖HBase作为其后备存储，支持标准SQL和JDBC API的强大功能，使得SQL
用户可以访问HBase集群。

代码样例
以下代码片段在cn.chinatelecom.hbase.sample包的“PhoenixSample”类的
sampleCreateTable、sampleDropTable方法中。
/**
 * Create Table
 */
public static boolean sampleCreateTable(String url) {
        //url is queryserver url, sample: jdbc:phoenix:thin:url=http://localhost:8765;serialization=PROTOBUF
        int result = -1;
        String sql = "CREATE TABLE IF NOT EXISTS PHOENIX_SAMPLE (id integer not null primary key, name varchar(10), age integer)";
        try (Connection conn = DriverManager.getConnection(url); Statement stat = conn.createStatement()) {
            result = stat.executeUpdate(sql);
            log.info("Create Table successfully.");
        } catch (Exception e) {
            log.error("Create Table failed ", e);
        }
        return result >= 0;
}
/**
 * Drop Table
 */
public static boolean sampleDropTable(String url) {
        //url is queryserver url, sample: jdbc:phoenix:thin:url=http://localhost:8765;serialization=PROTOBUF
        int result = -1;
        String sql = "DROP TABLE IF EXISTS PHOENIX_SAMPLE";
        try (Connection conn = DriverManager.getConnection(url);
             Statement stat = conn.createStatement()) {
            result = stat.executeUpdate(sql);
            log.info("Drop Table successfully.");
        } catch (Exception e) {
            log.error("Drop Table failed ", e);
        }
        return result >= 0;
}