Maven

pom.xml

  1.      <dependencies>
  2.         <dependency>
  3.             <groupId>org.apache.hbase</groupId>
  4.             <artifactId>hbase-client</artifactId>
  5.             <version>1.3.5</version>
  6.         </dependency>
  7.         <dependency>
  8.             <groupId>org.apache.hbase</groupId>
  9.             <artifactId>hbase-server</artifactId>
  10.             <version>1.3.5</version>
  11.         </dependency>
  12.     </dependencies>

静态代码块

  1. private static Connection connection = null;
  2.     private static Admin admin = null;;
  3.     static {
  4.         try {
  5.             Configuration configuration = HBaseConfiguration.create();
  6.             configuration.set("hbase.zookeeper.quorum", "aliyun:2181");
  7.             connection = ConnectionFactory.createConnection(configuration);
  8.             admin = connection.getAdmin();
  9.         } catch (IOException e) {
  10.             e.printStackTrace();
  11.         }
  12.     }

创建表

  1.     //创建表
  2.     public static void createTable(String tableName, String[] cols) throws IOException {
  4.         TableName table = TableName.valueOf(tableName);
  5.         if (admin.tableExists(table)) {
  6.             System.out.println("表已存在！");
  7.         } else {
  8.             HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);
  9.             for (String col : cols) {
  10.                 HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(col);
  11.                 hTableDescriptor.addFamily(hColumnDescriptor);
  12.             }
  13.             try {
  14.                 admin.createTable(hTableDescriptor);
  15.             } catch (IOException e) {
  16.                 e.printStackTrace();
  17.             }
  18.         }
  19.     }