1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207
|
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.derby.iapi.sql.dictionary.TableDescriptor;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
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.MasterNotRunningException;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.ZooKeeperConnectionException;
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.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;
import com.google.protobuf.ServiceException;
public class TestHbaseRemote {
private static Configuration conf = null;
/**
* Initialization
*/
static {
conf = HBaseConfiguration.create();
}
/**
* Create a table
*/
public static void creatTable(String tableName, String[] familys)
throws Exception {
HBaseAdmin admin = new HBaseAdmin(conf);
if (admin.tableExists(tableName)) {
System.out.println("la table existe déjà !");
}
else {
HTableDescriptor tableDesc = new HTableDescriptor(TableName.valueOf(tableName));
for (int i = 0; i < familys.length; i++) {
tableDesc.addFamily(new HColumnDescriptor(familys[i]));
}
admin.createTable(tableDesc);
System.out.println("create table " + tableName + " ok.");
}
}
/**
* Delete a table
*/
public static void deleteTable(String tableName) throws Exception {
try {
HBaseAdmin admin = new HBaseAdmin(conf);
admin.disableTable(tableName);
admin.deleteTable(tableName);
System.out.println("delete table " + tableName + " ok.");
} catch (MasterNotRunningException e) {
e.printStackTrace();
} catch (ZooKeeperConnectionException e) {
e.printStackTrace();
}
}
/**
* Put (or insert) a row
*/
public static void addRecord(String tableName, String rowKey,
String family, String qualifier, String value) throws Exception {
try {
HTable table = new HTable(conf, tableName);
Put put = new Put(Bytes.toBytes(rowKey));
put.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), Bytes
.toBytes(value));
table.put(put);
System.out.println("insert recored " + rowKey + " to table "
+ tableName + " ok.");
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* Delete a row
*/
public static void delRecord(String tableName, String rowKey)
throws IOException {
HTable table = new HTable(conf, tableName);
List<Delete> list = new ArrayList<Delete>();
Delete del = new Delete(rowKey.getBytes());
list.add(del);
table.delete(list);
System.out.println("del recored " + rowKey + " ok.");
}
/**
* Get a row
*/
public static void getOneRecord (String tableName, String rowKey) throws IOException{
HTable table = new HTable(conf, tableName);
Get get = new Get(rowKey.getBytes());
Result rs = table.get(get);
for(Cell kv : rs.rawCells()){
System.out.print(new String(CellUtil.cloneRow(kv)) + " ");
System.out.print(new String(CellUtil.cloneFamily(kv)) + ":");
System.out.print(new String(CellUtil.cloneQualifier(kv)) + " ");
System.out.print(kv.getTimestamp() + " ");
System.out.println(new String(CellUtil.cloneValue(kv)));
}
}
/**
* Scan (or list) a table
*/
public static void getAllRecord (String tableName) {
try{
HTable table = new HTable(conf, tableName);
Scan s = new Scan();
ResultScanner ss = table.getScanner(s);
for(Result r:ss){
for(Cell kv : r.rawCells() ){
System.out.print(new String(CellUtil.cloneRow(kv)) + " ");
System.out.print(new String(CellUtil.cloneFamily(kv)) + ":");
System.out.print(new String(CellUtil.cloneQualifier(kv)) + " ");
System.out.print(kv.getTimestamp() + " ");
System.out.println(new String(CellUtil.cloneValue(kv)));
}
}
} catch (IOException e){
e.printStackTrace();
}
}
public static void main(String[] agrs) {
Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "192.168.0.11,192.168.0.31,192.168.0.32");
config.set("hbase.master", "192.168.0.11:60000");
config.set("hbase.zookeeper.property.clientport", "2181");
config.set("hbase.client.retries.number", Integer.toString(0));
config.set("zookeeper.session.timeout", Integer.toString(60000));
config.set("zookeeper.recovery.retry", Integer.toString(0));
try {
String tablename = "scores";
String[] familys = { "degre", "lesson" };
TestHbaseRemote.creatTable(tablename, familys);
System.out.println("Table create table!");
// add record tivoli
TestHbaseRemote.addRecord(tablename, "tivoli", "degre", "", "5");
TestHbaseRemote.addRecord(tablename, "tivoli", "lesson", "francais", "90");
TestHbaseRemote.addRecord(tablename, "tivoli", "lesson", "sport", "97");
TestHbaseRemote.addRecord(tablename, "tivoli", "lesson", "dessin", "87");
System.out.println("Table add records!");
// add record lescure
TestHbaseRemote.addRecord(tablename, "lescure", "degre", "", "4");
TestHbaseRemote.addRecord(tablename, "lescure", "lesson", "math", "89");
TestHbaseRemote.addRecord(tablename, "lescure", "lesson", "physique", "29");
System.out.println("Table add records!");
// add record bordeaux
TestHbaseRemote.addRecord(tablename, "bordeaux", "degre", "", "93");
TestHbaseRemote.addRecord(tablename, "bordeaux", "lesson", "math", "3");
TestHbaseRemote.addRecord(tablename, "bordeaux", "lesson", "dessin", "2");
System.out.println("Table add records!");
// add record adeleter test
TestHbaseRemote.addRecord(tablename, "adeleter", "degre", "", "33");
TestHbaseRemote.addRecord(tablename, "adeleter", "lesson", "math", "3");
TestHbaseRemote.addRecord(tablename, "adeleter", "lesson", "musique", "2");
System.out.println("Table add records!");
System.out.println("===========get one record========");
TestHbaseRemote.getOneRecord(tablename, "tivoli");
System.out.println("===========show all record========");
TestHbaseRemote.getAllRecord(tablename);
System.out.println("===========del one record========");
TestHbaseRemote.delRecord(tablename, "adeleter");
TestHbaseRemote.getAllRecord(tablename);
System.out.println("===========show all record========");
TestHbaseRemote.getAllRecord(tablename);
} catch (Exception e) {
e.printStackTrace();
}
}
} |