hbase java操作代码简介和NoClassDefFoundError: org/apache/hadoop/hbase/HBaseConfiguratio – 后知后觉的it路 – ITeye技术网站

    for f in /usr/local/hbaselib/*.jar; do  
      if [ "$HADOOP_CLASSPATH" ]; then  
        export HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$f  
      else  
        export HADOOP_CLASSPATH=$f  
      fi  
    done

Java代码  

1. import java.io.IOException;
2. import java.util.ArrayList;
3. import java.util.List;
5. import org.apache.hadoop.conf.Configuration;
6. import org.apache.hadoop.hbase.HBaseConfiguration;
7. import org.apache.hadoop.hbase.HColumnDescriptor;
8. import org.apache.hadoop.hbase.HTableDescriptor;
9. import org.apache.hadoop.hbase.MasterNotRunningException;
10. import org.apache.hadoop.hbase.ZooKeeperConnectionException;
11. import org.apache.hadoop.hbase.client.Get;
12. import org.apache.hadoop.hbase.client.HBaseAdmin;
13. import org.apache.hadoop.hbase.client.HTable;
14. import org.apache.hadoop.hbase.client.Put;
15. import org.apache.hadoop.hbase.client.Result;
16. import org.apache.hadoop.hbase.client.ResultScanner;
17. import org.apache.hadoop.hbase.client.Scan;
18. import org.apache.hadoop.hbase.util.Bytes;
21. public class HbaseTest {
23.     public static String TableName = “stu”;
24.     public static String RowKey = “m1”;
25.     public static String FamilyColumn1 = “base”;
26.     public static String FamilyColumn2 = “more”;
29.     /**
30.      * 1 创建表， 删除表  此时只涉及表名 列族名称
31.      * 2 表中新增记录，追加记录，删除记录   只有在表记录新增，查询时 才涉及rowkey
32.      * 3 表中查询记录
33.      * HBaseAdmin
34.      * HTable
35.      */
36.     public static void main(String[] args) throws Exception {
37.         // 0 创建配置信息
38.         Configuration conf = getConf();
39.         // 1 ddl语句
40.         ddl(conf,TableName,FamilyColumn1,FamilyColumn2);
42.         // 2 dml语句
43.         //dml(conf);
44.     }
47.     private static void dml(Configuration conf) throws IOException {
48.         // 1 创建dml操作类 HTable
49.         HTable hTable = new HTable(conf, TableName);
50.         // 2 指定新增记录操作类 Put 并初始化
51.         List<Put> puts = new ArrayList<Put>();
52.         Put put1 = new Put(Bytes.toBytes(RowKey)); // 指定行健是在Put上指定的
53.         put1.add(Bytes.toBytes(FamilyColumn1), Bytes.toBytes(“name”), Bytes.toBytes(“张三”));
55.         Put put2 = new Put(Bytes.toBytes(RowKey)); // 指定行健
56.         put2.add(Bytes.toBytes(FamilyColumn2), Bytes.toBytes(“age”), Bytes.toBytes(29));
58.         puts.add(put1);
59.         puts.add(put2);
60.         // 3 新增到hbase表中
61.         hTable.put(puts);
63.         // 4 查看记录:
64.         Get get = new Get(Bytes.toBytes(RowKey)); // 查询时 指定要查询的是那条记录—》根据rowkey确定
65.         Result result = hTable.get(get);
66.         System.out.println(result); // keyvalues={m1/f1:name/1419389290472/Put/vlen=6/ts=0, m1/f2:age/1419389290474/Put/vlen=4/ts=0}
67.         String nameVal = Bytes.toString(result.getValue(Bytes.toBytes(FamilyColumn1), Bytes.toBytes(“name”))); // 根据列族名和列名来查询对应value数值
68.         System.out.println(nameVal); // 打印出 : 张三
69.         int  ageVal = Bytes.toInt(result.getValue(Bytes.toBytes(FamilyColumn2), Bytes.toBytes(“age”))); // 根据列族名和列名来查询对应value数值
70.         System.out.println(ageVal); // 打印出 :29
72.     }
74.     // 更细节的查询方式  scan 
75.     private static void scan() throws IOException {
76.         final Configuration conf = getConf();
77.         final HTable hTable = new HTable(conf, TableName);
79.         //使用scan对象可以设定startRow、stopRow
80.         Scan scan = new Scan();
81.         //scan.addColumn(family, qualifier); 扫描时  详细扫描范围
82.         //scan.addFamily(family) 
83.         //scan.setStartRow(startRow);
84.         //scan.setStopRow(stopRow);
85.         //scan.setFilter(filter);
86.         final ResultScanner scanner = hTable.getScanner(scan);
88.         //指定列簇、列
89.         //final ResultScanner scanner = hTable.getScanner(Bytes.toBytes(“f1”), Bytes.toBytes(“c1”));
90.         for (Result result : scanner) {
91.             System.out.println(result);
92.         }
94.         hTable.close();
95.     }
98.     private static void ddl(Configuration conf, String tableName, String…familyNames)
99.             throws MasterNotRunningException, ZooKeeperConnectionException,IOException {
101.         // 1 创建表
102.         HBaseAdmin hBaseAdmin = new HBaseAdmin(conf);
103.         HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);
104.         // 1.1 给表增加列族
105.         for(String familyName : familyNames) {
106.             HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(familyName);
107.             hTableDescriptor.addFamily(hColumnDescriptor);
108.         }
109.         // 1.2 开始创建表
110.         if(!hBaseAdmin.tableExists(TableName)){
111.             hBaseAdmin.createTable(hTableDescriptor);
112.         }
113.         System.out.println(“创建后，表”+TableName+“是否存在： “ + hBaseAdmin.tableExists(TableName));
114.         // 2 更改表状态
115.         //hBaseAdmin.disableTable(TableName); // 停用此表 会输出： Started disable of myhbasetable   Disabled myhbasetable
116.         //hBaseAdmin.enableTable(TableName); // 启动此表
117.         // 3 删除表
118.         //hBaseAdmin.deleteTable(TableName); // 删除表
119.         //System.out.println(“删除后，表”+TableName+”是否存在： ” + hBaseAdmin.tableExists(TableName));
120.     }
123.     /**
124.      * master在本地host配置为 : master 192.168.1.110
125.      * 搭建hbase 集群为:
126.      * h2master 192.168.1.110
127.      * h2sliver113 192.168.1.113
128.      * h2sliver114 192.168.1.114
129.      * hadoop单节点：
130.      * h2single 192.168.1.221
131.      * @return
132.      */
133.     private static Configuration getConf() {
134.         Configuration conf = HBaseConfiguration.create();
135.         conf.set(“hbase.rootdir”, “hdfs://h2single:9000/hbase”); // 指定hbase在hdfs的路径
136.         conf.set(“hbase.zookeeper.quorum”, “h2sliver113:2181”);   // 指定zk集群 这里只写一个zk节点就可以了
137.         return conf;
138.     }
142. }

Java代码  

1. import java.util.ArrayList;
2. import java.util.List;
4. import org.apache.hadoop.conf.Configuration;
5. import org.apache.hadoop.hbase.HBaseConfiguration;
6. import org.apache.hadoop.hbase.HColumnDescriptor;
7. import org.apache.hadoop.hbase.HTableDescriptor;
8. import org.apache.hadoop.hbase.client.Delete;
9. import org.apache.hadoop.hbase.client.Get;
10. import org.apache.hadoop.hbase.client.HBaseAdmin;
11. import org.apache.hadoop.hbase.client.HTable;
12. import org.apache.hadoop.hbase.client.Put;
13. import org.apache.hadoop.hbase.client.Result;
14. import org.apache.hadoop.hbase.client.ResultScanner;
15. import org.apache.hadoop.hbase.client.Scan;
17. public class HBaseTest1 {
19.     private static final String TABLE_NAME = “stu”;
20.     private static final String FAMILY_NAME = “f1”;
21.     private static final String COLUMN_NAME = “name”;
22.     private static final String COLUMN_AGE = “age”;
23.     private static final String ROW_KEY1 = “r1”;
24.     private static final String ROW_KEY2 = “r2”;
26.     public static void main(String[] args) throws Exception {
27.         //构造能够访问HBase的configuration对象
28.         Configuration conf = HBaseConfiguration.create();
29.         conf.set(“hbase.rootdir”, “hdfs://h2single:9000/hbase”);
30.         conf.set(“hbase.zookeeper.quorum”, “h2sliver113:2181”);
32.         //HBaseAdmin是对HBase进行ddl操作的核心类
33.         HBaseAdmin hBaseAdmin = new HBaseAdmin(conf);
35.         if(!hBaseAdmin.tableExists(TABLE_NAME)){
36.             HTableDescriptor htableDescriptor = new HTableDescriptor(TABLE_NAME);
37.             htableDescriptor.addFamily(new HColumnDescriptor(FAMILY_NAME));
38.             hBaseAdmin.createTable(htableDescriptor);
39.             System.out.println(“table create success”);
40.         }else{
41.             System.out.println(“table exists”);
42.         }
45.         //使用HTable可以对HBase的表中的数据进行增删改查
46.         HTable hTable = new HTable(conf, TABLE_NAME);
48.         // 增加数据
49.         List<Put> putList = new ArrayList<Put>();
51.         Put put1 = new Put(ROW_KEY1.getBytes());
52.         put1.add(FAMILY_NAME.getBytes(), COLUMN_NAME.getBytes(), “zhangsan”.getBytes());
53.         put1.add(FAMILY_NAME.getBytes(), COLUMN_AGE.getBytes(), “23”.getBytes());
54.         putList.add(put1);
56.         Put put2 = new Put(ROW_KEY2.getBytes());
57.         put2.add(FAMILY_NAME.getBytes(), COLUMN_NAME.getBytes(), “lisi”.getBytes());
58.         put2.add(FAMILY_NAME.getBytes(), COLUMN_AGE.getBytes(), “24”.getBytes());
59.         putList.add(put2);
60.         hTable.put(putList);
62.         // 根据rowkey得到记录后 获取此记录对应的列信息
63.         Get get = new Get(ROW_KEY1.getBytes());
64.         Result get1 = hTable.get(get);
65.         String name1 = new String(get1.getValue(FAMILY_NAME.getBytes(), COLUMN_NAME.getBytes()));
66.         String age1 = new String(get1.getValue(FAMILY_NAME.getBytes(), COLUMN_AGE.getBytes()));
67.         //System.out.println(get1+”\t”+name1+”\t”+age1);
69.         // 指定行范围来查询多条记录 
70.         Scan scan = new Scan();
71.         scan.setStartRow(ROW_KEY1.getBytes());
72.         scan.setStopRow(ROW_KEY2.getBytes());
73.         ResultScanner scanner = hTable.getScanner(scan);
74.         for (Result result : scanner) {
75.             String rowKey = new String(result.getRow());
76.             String name = new String(result.getValue(FAMILY_NAME.getBytes(), COLUMN_NAME.getBytes()));
77.             String age = new String(result.getValue(FAMILY_NAME.getBytes(), COLUMN_AGE.getBytes()));
78.             System.out.println(rowKey+“\t”+name+“\t”+age1);
79.         }
81.         // 根据rowkey删除记录
82.         Delete delete = new Delete(ROW_KEY1.getBytes());
83.         hTable.delete(delete);
85.         // 删除表
86.         hBaseAdmin.disableTable(TABLE_NAME);
87.         hBaseAdmin.deleteTable(TABLE_NAME);
88.     }
90. }