phoenix中新建表，以及hbase已有表与phoenix映射

╰半橙微兮° 2022-02-02 14:19 567阅读 0赞

在phoenix的bin目录下输入命令进入phoenix

<table> 
 <tbody> 
  <tr> 
   <td style="width:46px;"> <p>1</p> </td> 
   <td> <p><code>.</code><code>/sqlline</code><code>.sh hadoop:2181</code></p> </td> 
  </tr> 
 </tbody> 
</table>

查看所有表格：

<table> 
 <tbody> 
  <tr> 
   <td style="width:48px;"> <p>1</p> </td> 
   <td> <p><code>！tables</code></p> </td> 
  </tr> 
 </tbody> 
</table>

新建表格

<table> 
 <tbody> 
  <tr> 
   <td style="width:46px;"> <p>1</p> </td> 
   <td> <p><code>.</code><code>/psql</code><code>.py hadoop:2181&nbsp;</code><code>/opt/stock_symbol</code><code>.sql</code></p> </td> 
  </tr> 
 </tbody> 
</table>

stock\_symbol.sql内容如下：

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> <p>3</p> <p>4</p> <p>5</p> <p>6</p> <p>7</p> <p>8</p> <p>9</p> <p>10</p> </td> 
   <td> <p><code>CREATE</code>&nbsp;<code>TABLE</code>&nbsp;<code>IF&nbsp;</code><code>NOT</code>&nbsp;<code>EXISTS WEB_STAT (&nbsp;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HOST&nbsp;</code><code>CHAR</code><code>(2)&nbsp;</code><code>NOT</code>&nbsp;<code>NULL</code><code>,&nbsp;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DOMAIN&nbsp;</code><code>VARCHAR</code>&nbsp;<code>NOT</code>&nbsp;<code>NULL</code><code>,&nbsp;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>FEATURE&nbsp;</code><code>VARCHAR</code>&nbsp;<code>NOT</code>&nbsp;<code>NULL</code><code>,&nbsp;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DATE</code>&nbsp;<code>DATE</code>&nbsp;<code>NOT</code>&nbsp;<code>NULL</code><code>,&nbsp;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>USAGE.CORE&nbsp;</code><code>BIGINT</code><code>,&nbsp;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>USAGE.DB&nbsp;</code><code>BIGINT</code><code>,&nbsp;</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>STATS.ACTIVE_VISITOR&nbsp;</code><code>INTEGER</code>&nbsp;</p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>CONSTRAINT</code>&nbsp;<code>PK&nbsp;</code><code>PRIMARY</code>&nbsp;<code>KEY</code>&nbsp;<code>(HOST, DOMAIN, FEATURE,&nbsp;</code><code>DATE</code><code>)&nbsp;</code></p> <p><code>);</code></p> </td> 
  </tr> 
 </tbody> 
</table>

导入数据：

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> </td> 
   <td> <p><code>.</code><code>/psql</code><code>.py -t WEB_STAT hadoop:2181&nbsp;</code><code>/opt/stock_symbol</code><code>.csv</code></p> </td> 
  </tr> 
 </tbody> 
</table>

一定要用逗号分割的csv

![1156822-20170716153627363-196920254.png][]

参考文档：

http://blog.csdn.net/fansy1990/article/details/22939887

**hbase已有表与phoenix映射**

HBASE 已有表LCT\_TEST

![1156822-20170716153826816-551366180.png][]

只需在phoenix中添加同名表即可映射到hbase的同名表

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> </td> 
   <td> <p><code>create</code>&nbsp;<code>table</code>&nbsp;<code>"LCT_TEST"</code><code>(</code><code>"ROW"</code>&nbsp;<code>varchar</code>&nbsp;<code>primary</code>&nbsp;<code>key</code><code>,&nbsp;</code><code>"op_www"</code><code>.</code><code>"exists"</code>&nbsp;<code>varchar</code>&nbsp;<code>,&nbsp;</code><code>"op_www"</code><code>.</code><code>"exists1"</code>&nbsp;<code>varchar</code><code>);&nbsp;&nbsp;</code></p> </td> 
  </tr> 
 </tbody> 
</table>

把HBASE中的ROW当作主键

**表名和列族以及列名需要用双引号括起来，因为HBase是区分大小写的，如果不用双引号括起来的话Phoenix在创建表的时候会自动将小写转换为大写字母**

**![1156822-20170716153945519-579336092.png][]**

![1156822-20170716154003769-114273851.png][]

参考文档：http://blog.csdn.net/maomaosi2009/article/details/45598985

[1156822-20170716153627363-196920254.png]: /images/20220202/eb16e98082ca4fd79232bd6eb17a2e0a.png
[1156822-20170716153826816-551366180.png]: /images/20220202/ab30a0652e5b471b88795bef31d8808c.png
[1156822-20170716153945519-579336092.png]: /images/20220202/1fb592a545664ad0a027aaa4e9dc3fa7.png
[1156822-20170716154003769-114273851.png]: /images/20220202/dcbd62b514584e0ca9d80ff58a7d941b.png