9月18日

在导包成功后，我自己写了相关的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; // 返回一个集合
}