在導包成功后，我自己寫了相關的hbase操作函數

public static void getdata(String tablename) throws IOException {
Connection connection= UDB.getConnection();
//1.獲取表對象
Table table = connection.getTable(TableName.valueOf(tablename));
//2.構建scan對象
Scan scan = new Scan();

//3.掃描表
ResultScanner resultScanner = table.getScanner(scan);

//4.解析resultScanner
for (Result result : resultScanner) {
for (Cell cell : result.rawCells()) {
System.out.println(" 行 鍵 :" + Bytes.toString(CellUtil.cloneRow(cell)));
//得到列族
System.out.println(" 列 族 " + Bytes.toString(CellUtil.cloneFamily(cell)));
System.out.println(" 列 :" + Bytes.toString(CellUtil.cloneQualifier(cell)));
System.out.println(" 值 :" + Bytes.toString(CellUtil.cloneValue(cell)));
}
}

table.close();
UDB.close(connection);
}

//插入數據
public static void insert(String tablename,String rowkey,String cf,String cn,String value) throws IOException {
Connection connection= UDB.getConnection();
//1.獲取表對象
Table table = connection.getTable(TableName.valueOf(tablename));
//2.創建put對象
Put put = new Put(Bytes.toBytes(rowkey));

//3.給put對象賦值

put.addColumn(Bytes.toBytes(cf),Bytes.toBytes(cn),Bytes.toBytes(value));

table.put(put);

table.close();

}

public static List<data> getdatas(String tablename) throws IOException {
List<data> list = new ArrayList<data>(); // 創建集合
//List<dan> listdan = new ArrayList<dan>();
Connection connection = UDB.getConnection();

Table table = connection.getTable(TableName.valueOf(tablename));
//2.構建scan對象
Scan scan = new Scan();

//3.掃描表
ResultScanner resultScanner = table.getScanner(scan);
data data=null;
//4.解析resultScanner
for (Result result : resultScanner) {

List<dan> listdan = new ArrayList<dan>();
for (Cell cell : result.rawCells()) {
dan d=null;
System.out.println(" 行 鍵 :" + Bytes.toString(CellUtil.cloneRow(cell)));
//得到列族
System.out.println(" 列 族 " + Bytes.toString(CellUtil.cloneFamily(cell)));
System.out.println(" 列 :" + Bytes.toString(CellUtil.cloneQualifier(cell)));
System.out.println(" 值 :" + Bytes.toString(CellUtil.cloneValue(cell)));
d=new dan(Bytes.toString(CellUtil.cloneValue(cell)));
listdan.add(d);
System.out.println(d.getDan());
}

System.out.println(listdan.get(0).getDan());
// data.setCxd(listdan.get(0).getDan().toString());
System.out.println(listdan.get(1).getDan());
// data.setCxfw(listdan.get(1).getDan().toString());
// data.setMd(listdan.get(2).getDan());
// data.setNo(listdan.get(3).getDan());
// data.setSj(listdan.get(4).getDan());
data=new data(listdan.get(0).getDan(),listdan.get(1).getDan(),listdan.get(2).getDan(),listdan.get(3).getDan(),listdan.get(4).getDan());
list.add(data);

}

table.close();
UDB.close(connection);

return list; // 返回一個集合
}

總結

以上是生活随笔為你收集整理的9月18日的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。