phoenix的upsert操作命令

2021-10-21 14:10:41 字數 1299 閱讀 1826

phoenix的查詢與絕大多數關係型資料庫的命令一致,但存在細微差別

檢視表

0: jdbc:phoenix:

>

!tables

檢視結構

0: jdbc:phoenix:

>

!desc

建立schema

create schema if not exists cust

新建表drop table if exists cust.khxx;

create table cust.

khxx

(id varchar not null

,name varchar not null

,gender varchar,

age varchar

birth varchar constraint pk primary key (id,name));

新增乙個字段

alter table cust.khxx add tel varchar;

新增多個字段

alter table cust.khxx add tel varchar,idcard varchar;

刪除資料

delete from cust.khxx where id='';

新增資料

upsert into cust.

khxx

(id,name,gender,age,birthday)

values

('a'

,'b'

,'c'

,'d'

,'e');

upsert into cust.

khxx

(id,name,gender,age,birthday) select '2' as id,name,gender,age,birthday from cust.khxx1 where id=

'1';

修改資料(將所有李四改為張三)

若原本為:1

,張三,nan,24,

0815

改為:1

,張三,男,24,

0815

upsert into cust.

khxx

(name,gender)

values

('張三'

,'男');

刪除字段

alter table cust.khxx drop column age;

刪除表drop table cust.khxx;

退出!exit

Phoenix系列 原子的Upsert

phoenix的插入語句是upsert,update和insert的組合語義。即,如果資料表中沒有這條記錄那麼插入這條記錄,如果有則更新。判斷是否存在相同的資料是使用on duplicate key來驗證的,這裡的key就是建表時候的主鍵 primary key 和oracle的merge into...

Phoenix的安裝部署

這裡我們使用的是 apache phoenix 4.14.0 cdh5.14.2 bin.tar.gz 將對應的安裝包上傳到對應的hbase集群其中乙個伺服器的 export softwares目錄下 解壓 tar zxvf apache phoenix 4.14.0 cdh5.14.2 bin.t...

Phoenix的簡單使用

在hbase的每台機器上進行解壓,進入phoenix目錄,將目錄下的phoenix 4.14.0 hbase 1.2 server.jar複製到hbase的安裝目錄下的lib目錄。如果沒有啟動hbase,則直接進行啟動,如果現在已經是啟動著的,需要重啟。啟動客戶端 python2 phoenix b...