java连接phoenix

1、在pom文件中加入jar包
·
org.apache.phoenix
phoenix-core
4.14.0-HBase-1.2

2、写一个测试，检验是否可以建立连接
·public static void main(String[] args) {
Properties props = new Properties();
props.setProperty(“phoenix.query.timeoutMs”, “1200000”);
props.setProperty(“hbase.rpc.timeout”, “1200000”);
props.setProperty(“hbase.client.scanner.timeout.period”, “1200000”);

try {Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");// 这里配置zookeeper的地址，可单个，也可多个。可以是域名或者ipString     url       = "jdbc:phoenix:172.26.xx.xx,172.26.xx.xx,172.26.xx.xx:2181:/hbase-unsecure";Connection conn      = DriverManager.getConnection(url, props);System.out.println(conn);Statement  statement = conn.createStatement();String    sql  = "select count(1) from order_1 limit 10";long      time = System.currentTimeMillis();ResultSet rs   = statement.executeQuery(sql);while (rs.next()) {int count = rs.getInt(1);System.out.println("row count is " + count);}long timeUsed = System.currentTimeMillis() - time;System.out.println("time " + timeUsed + "mm");// 关闭连接rs.close();statement.close();conn.close();} catch (Exception e) {e.printStackTrace();
}

}
3、得到结果：
·
·可以看出140w数据，count操作需要3s

4、出现异常hconnection-0x3cc1435c java.lang.Thread.getStackTrace(Thread.java:1559)

·HConnection established 表示连接已建立
·获取堆栈时，出现异常。不用管，可以继续运行的
·继续运行，出现以下信息
2018-12-06 15:02:07.405 [INFO] [Caller.callWithRetries(RpcRetryingCaller.java:142)] [hconnection-0x2807bdeb-shared–pool1-t1:40068] - Call exception, tries=10, retries=35, started=38482 ms ago, cancelled=false, msg=row ‘SYSTEM:CATALOG,’ on table ‘hbase:meta’ at region=hbase:meta,1.1588230740, hostname=test-dn-59-26.wakedata.gz,16020,1537408837649, seqNum=0
获取不到数据，访问元数据后，得到数据在test-dn-59-26.wakedata.gz这台机器上。
原因：没有配置相应的host

java连接phoenix相关推荐

phoenix php,Python实现连接phoenix的实例
这篇文章主要介绍了Python连接phoenix的方法,简单说明了phoenix的概念.功能并结合具体实例形式分析了Python连接phoenix的相关操作技巧,需要的朋友可以参考下本文实例讲述了P ...
使用Squirrel连接Phoenix
1.环境介绍操作系统:windows 10 jdk版本:windows x64 8u291 squirrel版本:3.9.1(4.2.0不兼容) squrirel下载地址: https://sour ...
phoenix hbase java_求助:java调用phoenix失败！
我在本地启动Java工程,连接phoenix没有问题,新增表.查询.修改都可以完成. 但是我把环境部署到hadoop集群master上面的时候,tomcat启动后就报错,提示连接phoenix失败. ...
java连接mongodb_java连接mongodb源码解读
用mongdb也大半年了,一直是业务上的逻辑实现了就ok.然而这样并不能进步--因此今天查了查java连接mongodb驱动的源码,搜到的各种信息整合一下,方便以后深入的使用. 先贴连接数据库代码Li ...
java 连接 pgsql
首先在jdbc的配置中新增pgsql的配置属性: pgsql.driverClassName=org.postgresql.Driver pgsql.url=jdbc:postgresql://12. ...
java连接Hbase数据库
java连接Hbase数据库如果是是连接机群上的Hbase服务,需要提前将相关的几个xml文件存放在本地的编程目录下,否则开发端无法获取机群信息及授权: hdfs-site.xml core-sit ...
java连接Orcale数据库并查询、插入、删除数据
java连接Orcale数据库并查询.插入.删除数据 oci和thin是Oracle提供的两套Java访问Oracle数据库方式. thin是一种瘦客户端的连接方式 oci是一种胖客户端的连接方式 J ...
java linux mysql数据库_Linux Java连接MySQL数据库
Linux(Ubuntu平台)Java通过JDBC连接MySQL数据库,与Windows平台类似,步骤如下: 解压 jdbc: tar -zxvf mysql-connector-java-5.1.1 ...
【Java】Java连接Mysql数据库的demo示例
[Java]Java连接Mysql数据库的demo示例 1.安装mysql数据库 2.下载java-mysql-connector.jar包 3.完成java配置 4.写java代码运行测试 1.安装 ...
Java连接Oracle数据库常用方法
JDBC的六大步骤: 注册驱动获取连接获取执行sql语句对象执行sql语句处理结果集关闭资源 oracle URL: jdbc:oracle:thin:@localhost:1521:SID ...

java连接phoenix

java连接phoenix相关推荐

最新文章

热门文章