Phoenix + HBase,让你像操作MySQL一样操作HBase
Phoenix关联HBase的操作(三种情况)
情况一:Hbase已经有已存在的表了,可在Phoenix中创建对应的视图,视图只能做查询操作,不能做增删改
- hbase中已创建表且有数据,表名:phoenix
- 在phoenix中创建对应视图
create view "phoenix"( pk varchar primary key, "info"."name" varchar, "info"."age" varchar );
- 查询视图数据
情况二:Hbase已存在表,可在Phoenix中创建对应的表,对表的操作可读可写,意味着可以对Hbase的表进行插入查询,删除操作。
-
hbase中已存在表并且有数据
- 在phoenix中创建对应的表
create table "t_person"( id VARCHAR PRIMARY KEY, "f"."id" VARCHAR, "f"."name" VARCHAR, "f"."age" VARCHAR ) column_encoded_bytes=0;
-
在phoenix中查询数据
- 在phoenix中插入数据
此时查看hbase中对应的t_person表数据
情况三:Hbase没有表;可直接在Phoeinx中创建表,对应的Habse中也会自动建表,在Phoenix中对表操作就是直接对Hbase中的表进行操作。
-
在phoenix中直接建表,t_test表会在hbase中同步创建
-
插入数据看phoenix和hbase中的效果
- 通过Java客户端操作phoenix
package com.fwmagic.hbase; import org.junit.After; import org.junit.Before; import org.junit.Test; import java.sql.*; /** * 通过Phoenix操作Hbase */ public class PhoenixQueryHbase { Connection connection = null; PreparedStatement ps = null; ResultSet rs = null; @Before public void init() throws Exception { connection = DriverManager.getConnection("jdbc:phoenix:hd1,hd2,hd3:2181"); } /** * 建表并查询 * * @throws Exception */ @Test public void create() throws Exception { Statement statement = connection.createStatement(); statement.executeUpdate("create table test(id integer primary key ,animal varchar )"); //新增和更新都是一个操作:upsert statement.executeUpdate("upsert into test values (1,'dog')"); statement.executeUpdate("upsert into test values (2,'cat')"); connection.commit(); PreparedStatement preparedStatement = connection.prepareStatement("select * from test"); rs = preparedStatement.executeQuery(); while (rs.next()) { String id = rs.getString("id"); String animal = rs.getString("animal"); String format = String.format("id:%s,animal:%s", id, animal); System.out.println(format); } } /** * 查询已有的表 * * @throws Exception */ @Test public void testQuery() throws Exception { String sql = "select * from tc"; try { ps = connection.prepareStatement(sql); rs = ps.executeQuery(); while (rs.next()) { String id = rs.getString("ID"); String name = rs.getString("NAME"); String age = rs.getString("AGE"); String sex = rs.getString("SEX"); String format = String.format("id:%s,name:%s,age:%s,sex:%s", id, name, age, sex); System.out.println(format); } } catch (SQLException e) { e.printStackTrace(); } finally { if (rs != null) rs.close(); if (ps != null) ps.close(); if (connection != null) connection.close(); } } /** * 删除数据 * * @throws Exception */ @Test public void delete() throws Exception { try { ps = connection.prepareStatement("delete from test where id=2"); ps.executeUpdate(); connection.commit(); } catch (SQLException e) { e.printStackTrace(); } finally { if (rs != null) rs.close(); if (ps != null) ps.close(); if (connection != null) connection.close(); } } /** * 删除表 * * @throws Exception */ @Test public void dropTable() throws Exception { try { ps = connection.prepareStatement("drop table test"); ps.execute(); } catch (SQLException e) { e.printStackTrace(); } finally { if (rs != null) rs.close(); if (ps != null) ps.close(); if (connection != null) connection.close(); } } @After public void close() throws Exception { if (rs != null) rs.close(); if (ps != null) ps.close(); if (connection != null) connection.close(); } }
- 示例代码下载
https://gitee.com/fang_wei/fwmagic-hbase
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
不要再问了,数据库不建议上Docker
前言 近2年Docker非常的火热,各位开发者恨不得把所有的应用、软件都部署在Docker容器中,但是您确定也要把数据库也部署的容器中吗? 这个问题不是子虚乌有,因为在网上能够找到很多各种操作手册和视频教程,小编整理了一些数据库不适合容器化的原因供大家参考,同时也希望大家在使用时能够谨慎一点。 目前为止将数据库容器化是非常不合理的,但是容器化的优点相信各位开发者都尝到了甜头,希望随着技术的发展能够更加完美的解决方案出现。 Docker不适合部署数据库的7大原因 1、数据安全问题 不要将数据储存在容器中,这也是 Docker 官方容器使用技巧中的一条。容器随时可以停止、或者删除。当容器被rm掉,容器里的数据将会丢失。为了避免数据丢失,用户可以使用数据卷挂载来存储数据。但是容器的 Volumes 设计是围绕 Union FS 镜像层提供持久存储,数据安全缺乏保证。如果容器突然崩溃,数据库未正常关闭,可能会损坏数据。另外,容器里共享数据卷组,对物理机硬件损伤也比较大。 即使你要把 Docker 数据放在主机来存储 ,它依然不能保证不丢数据。 Docker volumes 的设计围绕 Unio...
- 下一篇
VMWARE下复制centos8虚拟机导致IP丢失问题处理
在vmware下安装完一台centos8服务后再进行复制后出现如下问题 拷贝前的源centos与拷贝后的centos服务都没有了IP,需要重新设置 对于这个情况经反复测试需要在 centos8的/etc/sysconfig/network-scripts下增加一个eth0的配置来解决 解决顺序如下 1,cd/etc/sysconfig/network-scripts 到相应目录下,先执行 su 命令,将自己切换到 root 权限下 su root 2,su成功后执行 cp ens33 eth0 将这个目录下原有的ens33配置文件 copy一份命名为eth0 3,执行ip addr 命令先取到相应网卡的mac地址,执行结果如下 在这里复制ens33对应的ether数据 00:0c:29:52:22:d1 , 这个值在稍后编辑eth0文件时要用到 4,vi eth0文件 在里边着重修改增加反复选择的几条,原配置文件中的ONBOOT,NAME,DEVICE等参数注意注释掉(这里用的是另外一台已经处理好的虚拟机进行截图,所以显示的mac不一样。不会vi编辑的只要进入文件后打一下insert键...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- SpringBoot2整合Thymeleaf,官方推荐html解决方案
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- CentOS7,8上快速安装Gitea,搭建Git服务器
- CentOS8编译安装MySQL8.0.19
- SpringBoot2全家桶,快速入门学习开发网站教程
- CentOS7,CentOS8安装Elasticsearch6.8.6
- Docker安装Oracle12C,快速搭建Oracle学习环境
- Hadoop3单机部署,实现最简伪集群
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题