Java操作Hbase数据库(二)方法封装版.docx

Java操作Hbase数据库（封装成方法版）创建表，添加数据，查看数据，删除数据，删除表等2016年7月30日16:26:16Huangxin[永州职业技术学院]package my.hbaseProgram;import java.util.List;import java.util.ArrayList;import java.util.Scanner;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.HColumnDescriptor;import org.apache.hadoop.hbase.HTableDescriptor;import org.apache.hadoop.hbase.KeyValue;import org.apache.hadoop.hbase.client.Delete;import org.apache.hadoop.hbase.client.Get;import org.apache.hadoop.hbase.client.HBaseAdmin;import org.apache.hadoop.hbase.client.HTable;import org.apache.hadoop.hbase.client.Put;import org.apache.hadoop.hbase.client.Result;import org.apache.hadoop.hbase.client.ResultScanner;import org.apache.hadoop.hbase.client.Scan;importorg.apache.hadoop.hbase.thrift.generated.Hbase;publicclass HbaseTest_FangFa {/** * @param args *///声明静态配置privatestatic Configuration conf = null;privatestatic HBaseAdmin admin=null;privatestatic Put putData = null;static{conf = HBaseConfiguration.create();conf.set(hbase.rootdir, hdfs://192.168.137.200:9000/hbase);conf.set(hbase.zookeeper.quorum, 192.168.137.200,192.168.137.101,192.168.137.102,192.168.137.103);//}//(方法一)判断表是否存在,如果存在就删除privatestaticvoid isExistDel(String tableName) throws Exception{admin = new HBaseAdmin(conf);if(admin.tableExists(tableName)){admin.disableTable(tableName);//禁用admin.deleteTable(tableName);//删除}}//（方法二）创建数据表publicstaticvoid createTable(String tableName,String[] columnFamilys) throws Exception{//调用前面方法一，删除已经存在的tableName表isExistDel(tableName);//新建一个表的描述HTableDescriptor desc = new HTableDescriptor(tableName);//添加列簇的描述for (String strFamily : columnFamilys) {HColumnDescriptor Colfamily = new HColumnDescriptor(strFamily.getBytes());desc.addFamily(Colfamily);}//添加到表里面admin.createTable(desc);//admin.close();System.out.println(创建表的定义 +tableName+ 成功！);}//(方法三)添加一条数据publicstaticvoid addRow(String tableName,String row,String columnFamily,String column,String value)throws Exception{//根