9月19日

向hbase插入数据的函数

public void charu(String rowkey, String no, String cxfw, String md, String cxd, String sj) throws IOException {
Connection connection= UDB.getConnection();
//1.获取表对象
Table table = connection.getTable(TableName.valueOf("kj"));
//2.创建put对象

Put put1 = new Put(Bytes.toBytes(rowkey));

//3.给put对象赋值

put1.addColumn(Bytes.toBytes("no"),Bytes.toBytes(""),Bytes.toBytes(no));
put1.addColumn(Bytes.toBytes("cxfw"),Bytes.toBytes(""),Bytes.toBytes(cxfw));
put1.addColumn(Bytes.toBytes("md"),Bytes.toBytes(""),Bytes.toBytes(md));
put1.addColumn(Bytes.toBytes("cxd"),Bytes.toBytes(""),Bytes.toBytes(cxd));
put1.addColumn(Bytes.toBytes("sj"),Bytes.toBytes(""),Bytes.toBytes(sj));

table.put(put1);
table.close();

}

我在想把这些操作函数转换成向javaweb那样的dao和udb函数