java phoenix 连接hbase

1 <dependency>
2     <groupId>org.apache.phoenix</groupId>
3     <artifactId>phoenix-core</artifactId>
4     <version>5.0.0-HBase-2.0</version>
5 </dependency>

除此之外还需要导入phoenix-5.0.0-HBase-2.0-client.jar

把以下文件拷贝到resources文件夹下

 1 public class Demo {
 2     public static void main(String[] args) throws SQLException {
 3         Connection connection = BaseDB.getConnection();
 4
 5         String sql = "select * from test";
 6         PreparedStatement prepareStatement = connection.prepareStatement(sql);
 7         ResultSet rs = prepareStatement.executeQuery();
 8         while (rs.next()) {
 9             System.out.println(rs.getInt(1));
10             System.err.println(rs.getString(2));
11         }
12
13     }
14 }
15 public class BaseDB {
16     public static Connection getConnection() {
17         try {
18             Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
19             return DriverManager.getConnection("jdbc:phoenix");
20         } catch (Exception e) {
21             e.printStackTrace();
22             return null;
23         }
24     }
25 }

原文地址:https://www.cnblogs.com/tele-share/p/10805044.html

时间: 2024-10-11 03:30:27

java phoenix 连接hbase的相关文章

phoenix连接hbase数据库,创建二级索引报错:Error: org.apache.phoenix.exception.PhoenixIOException: Failed after attempts=36, exceptions: Tue Mar 06 10:32:02 CST 2018, null, java.net.SocketTimeoutException: callTimeou

环境描述: 操作系统版本:CentOS release 6.5 (Final) 内核版本:2.6.32-431.el6.x86_64 phoenix版本:phoenix-4.10.0 hbase版本:hbase-1.2.6 表SYNC_BUSINESS_INFO_BYDAY数据库量:990万+ 问题描述: 通过phoenix客户端连接hbase数据库,创建二级索引时,报下面的错误: 0: jdbc:phoenix:host-10-191-5-226> create index SYNC_BUSI

Phoenix连接安全模式下的HBase集群

Phoenix连接安全模式下的HBase集群 HBase集群开启安全模式(即启用kerberos认证)之后,用户无论是用HBase shell还是Phoenix去连接HBase都先需要通过kerberos认证.如果没有通过kerberos认证,则hbase shell或phoenix都会报找不到kerberos tgt的错误而无法访问HBase(以下以phoenix为例): 对于HBase shell来说,用户可以在命令行先用kinit命令(kinit -kt <user keytab> &l

Java访问Phoenix连接

两种方法,一种是直接使用jdbc连接,一种是使用spring连接. jdbc连接和访问oracle步骤相同: ///////////// 测试Phoenix连接 /////////////// String testSQL = "select \"1\",\"2\" from fengji where rowid like '1-20170413%'"; try { Class.forName("org.apache.phoenix.j

JAVA上连接ubuntu14.04上的Hbase

对于新手来说,连接虚拟机上的Hbase有点繁琐,而且网上的配置不太适合初学者,今天我就整理了一下,希望对你们有帮助,第一次发博客. 1.首先去官网下载Hbase的压缩包.我这里用的是1.2.1 http://hbase.apache.org/ 2.把他上传到ubuntu里,我这里安装了vmware tools,所有直接拉进去,命令行的快捷键是ctrl+Alt+T,vmware tools安装参照这里 http://jingyan.baidu.com/album/93f9803f0d9d9be0e

Phoenix on HBase

(一)概要 Apache Phoenix是基于BSD许可开源的一个Java中间层,可以让开发者在Apache HBase上执行SQL查询.Apache Phoenix主要特性: 嵌入式的JDBC驱动,实现了大部分的java.sql接口,包括元数据API 可以通过多部行键或是键/值单元对列进行建模 完善的查询支持,可以使用多个谓词以及优化的扫描键 DDL支持:通过CREATE TABLE.DROP TABLE及ALTER TABLE来添加/删除列 版本化的模式仓库:当写入数据时,快照查询会使用恰当

JAVA程序操作hbase的Maven配置pom.xml文件

软件151  卢炜杰 由于工作需要,用到Java连接Hbase读写数据.原来的方式是直接将依赖的jar包全部下载下来,然后工程里面引用. 现想重构下,改为使用Maven管理,遇到了各种坑,各种不好使,特总结下. <dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-it</artifactId> <version>1.1.2</version>

局域网内任何一台pc上windows下eclipse远程连接hbase数据库

通过很长一段时间的反复失败,终于在windows下实现远程连接hbase数据库,在不断的尝试过程中深感一个详细的文档的重要性,于是就把我配置的详细过程记录下来.文中如果有些地方用词不当,或者理解错误,欢迎您们评论. 一.运行平台 hbase服务器端:Ubuntu 14.04 64位:HBASE1.1.3:JAVA 1.8: hbase客服端:windows32/64位:JAVA1.8:eclipse 4.5: 二.linux服务器端环境配置 1.  安装java 1.8软件 1)下载java软件

全网最详细的hive-site.xml配置文件里如何添加达到Hive与HBase的集成,即Hive通过这些参数去连接HBase(图文详解)

不多说,直接上干货! 一般,普通的情况是 <configuration> <property> <name>javax.jdo.option.ConnectionURL</name> <value>jdbc:mysql://master:3306/metastore?createDatabaseIfNotExist=true</value> </property> <property> <name>

Java JDBC连接SQL Server2005错误:通过端口 1433 连接到主机 localhost 的 TCP/IP 连接失败 及sql2008外围服务器

转载:Java JDBC连接SQL Server2005错误:通过端口 1433 连接到主机 localhost 的 TCP/IP 连接失败 错误原因如下: Exception in thread "main" org.hibernate.exception.JDBCConnectionException: Cannot open connection at org.hibernate.exception.SQLStateConverter.convert(SQLStateConver