<link rel="stylesheet" href="https://js.how234.com/third-party/SyntaxHighlighter/shCoreDefault.css" type="text/css" /><script type="text/javascript" src="https://js.how234.com/third-party/SyntaxHighlighter/shCore.js"></script><script type="text/javascript"> SyntaxHighlighter.all(); </script>
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();}}