java - phoenix

来源：趣味经验馆 1.25W

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的地址，可单个，多个(用","分隔)可以是域名或者ipString 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();}}

phoenix java