java phoenix

作者:原创时间:2022-04-19
文档

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();
}
}

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

显示全文
java ping java pipeline java rsa公钥加密 java rsa私钥加密 java rtp java runnable java runtime.exec java rxjava java sandbox java script java selector java selenium java semaphore java separator java sequence java serializable java serializable接口 java serialversionuid java setlayout java platform java paypal java path java rsa加密 java rotate java reverse java reverse() java retrofit java resume java resultset java result java rest java requests java partial java request java parser java repeat java parse java pandas java override java render