|
conf.set("hbase.zookeeper.quorum","gpmaster,gpseg");
}
public HBaseTest() throws Exception {
Configuration HBASE_CONFIG = newConfiguration();
HBASE_CONFIG.set("hbase.zookeeper.quorum","192.168.1.128");
HBASE_CONFIG.set("hbase.zookeeper.property.clientPort","2181");
cfg = newHBaseConfiguration(HBASE_CONFIG);
admin = new HBaseAdmin(cfg);
}
/**
* create a table
* @param tableName
* @param familys
* @throws Exception
*/
public static voidcreateTable(String tableName,String[] familys) throws Exception
{
@SuppressWarnings("deprecation")
HBaseAdmin admin= new HBaseAdmin(conf);
if(admin.tableExists(tableName)) {
System.out.println("tablealready exist!");
} else {
HTableDescriptortableDesc = new HTableDescriptor();
for (int i=0;i < familys.length; i++)
{
tableDesc.addFamily(newHColumnDescriptor(familys[i]));
}
admin.createTable(tableDesc);
System.out.println("createtable " + tableName + " ok.");
}
}
/**
* Delete a table
* @param args
*/
public static voiddeleteTable(String tableName) throws Exception {
try {
HBaseAdminadmin = new HBaseAdmin(conf);
admin.disableTable(tableName);
admin.deleteTable(tableName);
System.out.println("deletetable " + tableName + " ok.");
} catch(MasterNotRunningException e) {
e.printStackTrace();
} catch (ZooKeeperConnectionExceptione) {
e.printStackTrace();
}
}
/**
* Add a record
* @param args
*/
public static voidaddRecord (String tableName,String rowKey,String family,String qualifier,Stringvalue) throws Exception {
try {
HTable table= new HTable(conf,tableName);
Put put = newPut(Bytes.toBytes(rowKey));
table.put(put);
System.out.println("insertrecord" + rowKey + " to table " + tableName + " ok.");
} catch(IOException e) {
e.printStackTrace();
}
}
/**
* Delete a record
* @param args
*/
public static voiddelRecord(String tableName,String rowKey) throws Exception {
HTable table =new HTable(conf,tableName);
Listlist = new ArrayList();
Delete del = newDelete(rowKey.getBytes());
list.add(del);
table.delete(list);
System.out.println("delrecord " + rowKey +" ok.");
}
/**
* Get one record
* @param args
*/
public static voidgetOneRecord (String tableName, String rowKey) throws Exception {
HTable table =new HTable(conf, tableName);
Get get = newGet(rowKey.getBytes());
Result rs =table.get(get);
for ( KeyValue kv: rs.raw()){
System.out.println(newString(kv.getRow()) + " ");
System.out.println(newString(kv.getFamily()) +":");
System.out.println(newString(kv.getQualifier()) + " ");
System.out.println(kv.getTimestamp()+ " ");
System.out.println(newString(kv.getValue()));
}
}
/**
* Get all records
* @param args
*/
public static voidgetAllRecord(String tableName) {
try {
HTable table= new HTable(conf, tableName);
Scan s = new Scan();
ResultScannerss = table.getScanner(s);
for (Result r: ss) {
for(KeyValue kv : r.raw()) {
System.out.println(newString(kv.getRow()) + " ");
System.out.println(newString(kv.getFamily()) +":");
System.out.println(newString(kv.getQualifier()) + " ");
System.out.println(kv.getTimestamp()+ " ");
System.out.println(newString(kv.getValue()));
}
}
} catch (Exceptione) {
e.printStackTrace();
}
}
public static voidmain(String[] args) {
try {
StringtableName = "scores";
String[]familys = {"grade", "course"};
HBaseTest.createTable(tableName,familys);
// add recordzkb
HBaseTest.addRecord(tableName,"lilei", "grade", "", "5");
HBaseTest.addRecord(tableName,"lilei", "course", "", "90");
HBaseTest.addRecord(tableName,"lilei", "course", "math", "97");
HBaseTest.addRecord(tableName,"lilei", "course", "art", "87");
//add recordhaonu
HBaseTest.addRecord(tableName,"hanmeimei", "grade", "", "4");
HBaseTest.addRecord(tableName,"hanmeimei", "course", "math", "89");
System.out.println("================getone record==================");
HBaseTest.getOneRecord(tableName,"lilei");
System.out.println("================getall record==================");
HBaseTest.getAllRecord(tableName);
System.out.println("================delone record==================");
HBaseTest.delRecord(tableName,"hanmeimei");
HBaseTest.getAllRecord(tableName);
System.out.println("================showall record==================");
HBaseTest.getAllRecord(tableName);
} catch(Exception e) {
e.printStackTrace();
}
}
}
?
|