java phoenix

java phoenix是什么，让我们一起了解一下？

使用java代码，连接phoenix，从而实现phbase数据库的增删改查。phoenix定位为OLTP和操作型分析（operational analytics），大多用于在线业务，稳定性要求第一位。

Phoenix核心能力是什么？

1、SQL引擎层：支持标准SQL 92，转为SQL为HBase API，算子、过滤条件下推到Server端，并行执行，轻量级事务、二级索引，动态列、分页查询等多种SQL层能力。

2、JDBCDriver

3、Metadata管理

4、集成Spark、Hive、Pig、Flume和MapReduce

Java连接Phoenix有什么方式？

Phoenix JDBC Driver有两种：

1、Thick Driver。直接连接zookeeper和hbase，包名 phoenix-

2、Thin Driver。构建在http服务之上的jdbc驱动，包名 phoenix-

连接HBase测试源码如下：

public static void main(String[] args) throws Throwable {
try {
Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
//这里配置zookeeper的地址，可单个，多个(用","分隔)可以是域名或者ip
String url = "jdbc:phoenix:master,slave1,slave2,slave3:2181";
Connection conn = DriverManager.getConnection(url);
Statement statement = conn.createStatement();
long time = System.currentTimeMillis();
ResultSet rs = statement.executeQuery("select * from test");
while (rs.next()) {
String myName = rs.getString("name"); //表中的列名
System.out.println("myName=" + myName);
}
long timeUsed = System.currentTimeMillis() - time;
System.out.println("time " + timeUsed + "mm");
// 关闭连接
rs.close();
statement.close();
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}

以上就是小编今天的分享了，希望可以帮助到大家。