运用ambari安装phoenix,连接hbase,运用sql语句
数据存储在HBase中,通过SQL进行CRUD操作
创建test表
create table test(
pk VARCHAR primary key,
col1 VARCHAR null,
col2 VARCHAR null,
col3 VARCHAR null
);
创建SRC_TABLE表
create table SRC_TABLE (
pk VARCHAR primary key,
col1 VARCHAR null,
col2 VARCHAR null,
col3 VARCHAR null
);
往SRC_TABLE表中插入三条数据
upsert INTO SRC_TABLE (pk,col1, col2, col3) VALUES('2','22', '22', '22');
upsert INTO SRC_TABLE (pk,col1, col2, col3) VALUES('3','33', '33', '33') ;
upsert INTO SRC_TABLE (pk,col1, col2, col3) VALUES('4','44', '44', '44') ;
SQL示例:
向表test中插入一条数据
upsert INTO test(pk,col1, col2, col3) VALUES('1','11', '22', '33');
从SRC_TABLE表中查出数据插入到test表中
upsert INTO test select pk,col1,col2,col3 FROM SRC_TABLE;
从SRC_TABLE表中查出一部分列数据插入到test表中
upsert INTO test(pk,col2, col1) select pk,col2, col1 FROM SRC_TABLE;
修改test表中pk为1的列的值
upsert into test (pk,col1,col2) values ('1','value1', 'value2');
删除test表中pk为1的那一列
delete from test where pk='1';
模糊查询删除所有的pk的列
delete from test where pk like '%';
以上就是hbase phoneix的sql语句的基本用法。
---------------------
作者:红象云腾大讲堂
来源:CSDN
原文:https://blog.csdn.net/redoop123/article/details/79479889
版权声明:本文为博主原创文章,转载请附上博文链接!