phoenix连接hbase
一、安装phoennix添加配置
1、将phoenix-server-hbase-2.4-5.1.2.jar拷贝至hbase的的lib下
cp phoenix-server-hbase-2.4-5.1.2.jar ../hbase/lib/
2、配置phoenix可以访问hbase的系统表
(1)将以下配置添加至hbase-site.xml中
<property><name>phoenix.schema.isNamespaceMappingEnabled</name><value>true</value></property><property><name>phoenix.schema.mapSystemTablesToNamespace</name><value>true</value></property>
(2)将hbase-stie.xml拷贝到phoenix/bin目录下
cp ../hbase/conf/hbase-site.xml ../phoenix/bin/
二、启动phoenix服务
1、启动hbase
../hbase/bin/start-hbase.sh
2、启动phoenix
python3 ../phoenix/bin/sqlline.py server200:2181
server200:2181为zookeeper地址
三、 phoenix常用语法
官网文档 https://phoenix.apache.org/language/index.html
(1)创建表
create table test1(id varchar primary key,a varchar,b varchar);
id主键可视为hbase的rowkey
(2)插入数据
upsert into TEST1 values('202211160089','liuping','chenyingying');
(3) 查询数据
select * from TEST1;
(4)视图/表映射
由于phoenix 无法直接访问hbase创建的非系统表,可以通过视图/表映射对非系统表进行查询,但视图不可修改,表映射可读可写
在hbase上创建表名为eftb列族为fm1 、fm2的表
create 'reftb','fm1','fm2'
向表中添加数据
put 'reftb','010101','fm1:name','zhangsan'put 'reftb','010101','fm2:age','九千岁'
<1>视图映射
create view "reftb"(id varchar primary key,"fm1"."name" varchar,"fm2"."age" varchar);
<2>表映射
create table "reftb"(id varchar primary key,"fm1"."name" varchar,"fm2"."age" varchar);
<3>查看数据
(5)添加修改数据(增改语法相同)
upsert into "reftb" values('010102','诸葛村夫','五十');upsert into "reftb" values('010101','常山赵子龙','七十');
(6)删除数据
delete from "reftb" where ID='010101';
(7)创建schema(数据库名,对用hbase是的namespace)
CREATE SCHEMA IF NOT EXISTS "my_schema";
四、java代码集成phoenix
1、添加依赖
implementation 'org.apache.phoenix:phoenix-client-hbase-2.4:5.1.2'
2、编写代码
public class PhoenixJdbcUtils {private final static Logger LOGGER = LoggerFactory.getLogger(PhoenixJdbcUtils.class);private static Connection connection;static {Properties properties =new Properties();PhoenixDriver instance = PhoenixDriver.INSTANCE;try {connection = instance.connect("jdbc:phoenix:server200:2181", properties);///connection = DriverManager.getConnection("jdbc:phoenix:server200:2181", properties);} catch (SQLException e) {e.printStackTrace();}}/*** 插入数据* @throws SQLException*/public static void testUpsertData() throws SQLException {PreparedStatement psUpsert = connection.prepareStatement( " upsert into \"reftb\" values('168936','刘备','63')");boolean addData = psUpsert.execute();LOGGER.info("addData---------"+addData);connection.commit();}/*** 查询数据* @throws SQLException*/public static void testQueryData() throws SQLException {PreparedStatement psQuery = connection.prepareStatement(" select * from \"reftb\" ");ResultSet resultSet = psQuery.executeQuery();while (resultSet.next()) {LOGGER.info("id--{}",resultSet.getString(1));LOGGER.info("name--{}",resultSet.getString(2));LOGGER.info("age--{}",resultSet.getString(3));}}public static void main(String[] args) {try {testQueryData();testUpsertData();} catch (Exception e) {e.printStackTrace();}}
}
phoenix连接hbase相关推荐
- [Squirrel基础]-- squirrel安装(通过Phoenix连接 HBase)
注意:使用Squirrel 链接 Phoenix的前提是 HBase 集群已经集成了 Phoenix 一.下载安装(squirrel是一个连接hbase数据库的界面工具) 从网址http://www ...
- squirrel 通过phoenix 连接 hbase
squirrel下载 从网址http://www.squirrelsql.org/ 下载相应版本的squirrel的安装jar包,好比下载squirrel-sql-3.8.1-standard.jar ...
- 安装Phoenix连接Hase
文章目录 前言 一.下载Phoenix 二.安装步骤 1.执行命令,下载安装包 2.复制Jar包 3.启动 总结 前言 Phoenix 构建在 HBase 之上的开源 SQL 层.能够让我们使用标准的 ...
- Phoenix连接安全模式下的HBase集群
Phoenix连接安全模式下的HBase集群 HBase集群开启安全模式(即启用kerberos认证)之后,用户无论是用HBase shell还是Phoenix去连接HBase都先需要通过kerber ...
- [saiku] 使用 Apache Phoenix and HBase 结合 saiku 做大数据查询分析
saiku不仅可以对传统的RDBMS里面的数据做OLAP分析,还可以对Nosql数据库如Hbase做统计分析. 本文简单介绍下一个使用saiku去查询分析hbase数据的例子. 1.phoenix和h ...
- springboot集成phoenix,操作hbase
文章目录 前言 1.版本要求 1.1 对hbase版本的支持 2.微服务集成 2.1 创建gradle项目,添加依赖 2.2 application.yml配置 2.3 准备调试环境 2.3.1 服务 ...
- SpringBoot 使用Phoenix操作HBase数据库教程
SpringBoot 使用Phoenix操作HBase数据库教程 文章目录 添加 Phoenix 相关依赖 控制器实现Hbase数据库操作 好的html源码下载 文章目录 借助 Apache Phoe ...
- Apache Phoenix:HBase之上的SQL工具[1] 简介与架构
Apache Phoenix:HBase之上的SQL工具[1] 简介与架构 作者:胡佳辉(Dennis) 时间:2019年1月1日 CSDN博客:https://blog.csdn.net/gob ...
- Phoenix查询hbase
https://www.cnblogs.com/linbingdong/p/5832112.html 这个很全看这个HBase,一个NoSQL数据库,可存储大量非关系型数据. HBase,可以用HB ...
最新文章
- Rhel7/Centos7 修改运行级别
- 【转】内存耗用:VSS/RSS/PSS/USS
- 四轴PID控制算法详解(单环PID、串级PID)
- python矩形填充颜色_在Python中找到所有用0填充的矩形
- java中的asList_Java中的Arrays.asList()方法
- jQuery 学习笔记之十二 (选项卡)
- C语言课后习题(57)
- 数据之路 - Python爬虫 - PySpider框架
- 数据结构笔记(二十三)--哈夫曼树
- 49个Python学习资源:从初学者到高级玩家都有了
- WinRAR 32位解压缩软件 v5.21 汉化免费版
- webservice的wsdl文件怎么生成
- 下载Django中文官方文档
- 如何用电脑下载网页中的视频?
- Emule服务器与设置
- 天梯赛java题解 L1-087 机工士姆斯塔迪奥分数 20
- 接口防止重复提交,订单避免重复下单
- C语言——计算某日是该年的第几天
- 服务器内存怎么看型号,怎么查看服务器内存的型号
- 它来了它来了,群晖NAS外网远程访问设置教程终于来了