Hbase的基本sql使用

运用ambari安装phoenix,连接hbase,运用sql语句 

@H_502_3@ 数据存储在HBase中，通过sql进行CRUD操作 @H_502_3@ 创建test表

create table test(@H_502_3@ pk VARCHAR primary key,@H_502_3@ col1 VARCHAR null,@H_502_3@ col2 VARCHAR null,@H_502_3@ col3 VARCHAR null@H_502_3@ );

@H_502_3@ 创建SRC_TABLE表

create table SRC_TABLE (@H_502_3@ pk VARCHAR primary key,@H_502_3@ col1 VARCHAR null,@H_502_3@ col2 VARCHAR null,@H_502_3@ col3 VARCHAR null@H_502_3@ );@H_502_3@  

@H_502_3@ 往SRC_TABLE表中插入三条数据

upsert INTO SRC_TABLE (pk,col1, col2, col3) VALUES('2','22', '22', '22');@H_502_3@ upsert INTO SRC_TABLE (pk,col1, col2, col3) VALUES('3','33', '33', '33') ;@H_502_3@ upsert INTO SRC_TABLE (pk,col1, col2, col3) VALUES('4','44', '44', '44') ;

sql示例： @H_502_3@ 向表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;

@H_502_3@  @H_502_3@ 从SRC_TABLE表中查出一部分列数据插入到test表中

upsert INTO test(pk,col2, col1) select pk,col2, col1 FROM SRC_TABLE; 

@H_502_3@ 修改test表中pk为1的列的值

upsert into test (pk,col1,col2) values ('1','value1', 'value2'); 

@H_502_3@ 删除test表中pk为1的那一列

delete from test where pk='1';@H_502_3@  @H_502_3@ 模糊查询删除所有的pk的列

  delete from test where pk like '%';

@H_502_3@ 以上就是hbase phoneix的sql语句的基本用法。@H_502_3@ --------------------- @H_502_3@ 作者：红象云腾大讲堂 @H_502_3@ 来源：CSDN @H_502_3@ 原文：https://blog.csdn.net/redoop123/article/details/79479889 @H_502_3@ 版权声明：本文为博主原创文章，转载请附上博文链接！