1、创建表

private static Connection connection;

private static Admin admin;

public static void createTable(String tableName, String[] fields) throws IOException {

if(admin.tableExists(TableName.valueOf(tableName)))

{

deleteTable(tableName);

}

//2.TableDescriptorBuilder.newBuilder构建表描述构建器

TableDescriptorBuilder tableDescriptorBuilder = TableDescriptorBuilder.newBuilder(TableName.valueOf(tableName));

for (int i=0;i

{

//3.创建列簇构造描述器

ColumnFamilyDescriptorBuilder columnFamilyDescriptorBuilder = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(fields[i]));

//4.构建列簇描述

ColumnFamilyDescriptor cfDes = columnFamilyDescriptorBuilder.build();

//建立表与列簇的关联关系

tableDescriptorBuilder.setColumnFamily(cfDes);

}

TableDescriptor tableDescriptor = tableDescriptorBuilder.build();

admin.createTable(tableDescriptor);

}

public static void main(String[] args) throws IOException {

//用HBaseConfiguration.create();创建HBase的配置

Configuration configuration = HBaseConfiguration.create();

//用ConnectionFactory.createConnection创建HBase()连接

connection = ConnectionFactory.createConnection(configuration);

// 创建表，要给予HBase获取Admin对象

admin = connection.getAdmin();

String tablename = "WATER_BILL";

//1.创建表和列

String[] filed = {"H1", "H2", "H3"};

createTable(tablename, filed);

}

2、添加数据

public static void addRecord(String tableName, String row, String[] fields, String[] values) throws IOException {

Table table = connection.getTable(TableName.valueOf(tableName));

String []column=new String[110];

String columnFamily="";

for(int i=0;i

{

String []split=fields[i].split(":");

column[i]=split[1];

columnFamily=split[0];

}

Put put = new Put(Bytes.toBytes(row));

for(int i=0;i

{

put.addColumn(Bytes.toBytes(columnFamily),Bytes.toBytes(column[i]),Bytes.toBytes(values[i]));

}

//5.使用htable表执行put操作

table.put(put);

//关闭htable表对象

table.close();

}

public static void main(String[] args) throws IOException {

//用HBaseConfiguration.create();创建HBase的配置

Configuration configuration = HBaseConfiguration.create();

//用ConnectionFactory.createConnection创建HBase()连接

connection = ConnectionFactory.createConnection(configuration);

// 创建表，要给予HBase获取Admin对象

admin = connection.getAdmin();

String tablename = "WATER_BILL";

//1.创建表和列

// String[] filed = {"H1", "H2", "H3"};

// createTable(tablename, filed);

//2.向表tableName、行row(用S_Name表示)和字符串数组fields指定的单元格中添加对应的数据values。

// 其中，fields中每个元素如果对应的列族下还有相应的列限定符的话，用“columnFamily:column”表示。

// 例如，同时向“Math”、“Computer Science”、“English”三列添加成绩时，

// 字符串数组fields为{“Score:Math”, ”Score:Computer Science”, ”Score:English”}，数组values存储这三门课的成绩。

String[] fields = {"H1:S_NO", "H1:S_Name", "H1:S_Sex", "H1:S_Age"};

String[] values = {"2015001", "Zhangsan", "male", "23"};

String row = "Zhangsan";

addRecord(tablename, row, fields, values);

}

1|3查看表中某rowkey的列簇下的所有值，或者单个列簇：列名的值

3、查看表中的值

public static void scanColumn(String tableName,String rowKey, String column) throws IOException {

Table table = connection.getTable(TableName.valueOf(tableName));

Get get = new Get(rowKey.getBytes());

if(column.contains(":"))

{

//查询指定rowkey和列簇下的指定列名

String[] split = column.split(":");

get.addColumn(Bytes.toBytes(split[0]),Bytes.toBytes(split[1]));

Result result = table.get(get);

byte[] value = result.getValue(Bytes.toBytes(split[0]), Bytes.toBytes(split[1]));

if(Bytes.toString(value)!=null)

System.out.println(Bytes.toString(value));

else

System.out.println("null");

}

else

{

//查询指定rowkey和列簇下的所有数据

get.addFamily(column.getBytes());

Result result = table.get(get);

Cell[] cells = result.rawCells();

for (Cell cell:cells)

{

//获取列簇名称

String cf = Bytes.toString(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength());

//获取列的名称

String colunmName = Bytes.toString(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength());

//获取值

String value = Bytes.toString(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength());

if(value!=null)

System.out.println(cf+":"+colunmName+"=>"+value);

else

System.out.println(cf+":"+colunmName+"=>"+"null");

}

}

table.close();

}

public static void main(String[] args) throws IOException {

//用HBaseConfiguration.create();创建HBase的配置

Configuration configuration = HBaseConfiguration.create();

//用ConnectionFactory.createConnection创建HBase()连接

connection = ConnectionFactory.createConnection(configuration);

// 创建表，要给予HBase获取Admin对象

admin = connection.getAdmin();

String tablename = "WATER_BILL";

//1.创建表和列

// String[] filed = {"H1", "H2", "H3"};

// createTable(tablename, filed);

//2.向表tableName、行row(用S_Name表示)和字符串数组fields指定的单元格中添加对应的数据values。

// 其中，fields中每个元素如果对应的列族下还有相应的列限定符的话，用“columnFamily:column”表示。

// 例如，同时向“Math”、“Computer Science”、“English”三列添加成绩时，

// 字符串数组fields为{“Score:Math”, ”Score:Computer Science”, ”Score:English”}，数组values存储这三门课的成绩。

// String[] fields = {"H1:S_NO", "H1:S_Name", "H1:S_Sex", "H1:S_Age"};

// String[] values = {"2015001", "Zhangsan", "male", "23"};

// String row = "Zhangsan";

// addRecord(tablename, row, fields, values);

//3.浏览表tableName某一列的数据，如果某一行记录中该列数据不存在，则返回null。

// 要求当参数column为某一列族名称时，如果底下有若干个列限定符，则要列出每个列限定符代表的列的数据；

// 当参数column为某一列具体名称(例如“Score:Math”)时，只需要列出该列的数据。

String column = "H1:S_Name";

String rowkey = "Zhangsan";

scanColumn(tablename, rowkey, column);

}

3、修改列、列名的值

public static void modifyData(String tableName,String rowkey,String column,String value) throws IOException {

Table table = connection.getTable(TableName.valueOf(tableName));

//修改操作

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

String[] split = column.split(":");

String columnFamily=split[0];

String columnName=split[1];

put.addColumn(Bytes.toBytes(columnFamily),Bytes.toBytes(columnName),Bytes.toBytes(value));

table.put(put);

//查看修改后的数据

Get get = new Get(rowkey.getBytes());

get.addColumn(Bytes.toBytes(columnFamily),Bytes.toBytes(columnName));

Result result = table.get(get);

byte[] value2 = result.getValue(Bytes.toBytes(columnFamily),Bytes.toBytes(columnName));

if(Bytes.toString(value2)!=null)

System.out.println(columnFamily+":"+columnName+"=>"+Bytes.toString(value2));

else

System.out.println("null");

System.out.println("修改成功！！");

table.close();

}

public static void main(String[] args) throws IOException {

//用HBaseConfiguration.create();创建HBase的配置

Configuration configuration = HBaseConfiguration.create();

//用ConnectionFactory.createConnection创建HBase()连接

connection = ConnectionFactory.createConnection(configuration);

// 创建表，要给予HBase获取Admin对象

admin = connection.getAdmin();

String tablename = "WATER_BILL";

//1.创建表和列

// String[] filed = {"H1", "H2", "H3"};

// createTable(tablename, filed);

//2.向表tableName、行row(用S_Name表示)和字符串数组fields指定的单元格中添加对应的数据values。

// 其中，fields中每个元素如果对应的列族下还有相应的列限定符的话，用“columnFamily:column”表示。

// 例如，同时向“Math”、“Computer Science”、“English”三列添加成绩时，

// 字符串数组fields为{“Score:Math”, ”Score:Computer Science”, ”Score:English”}，数组values存储这三门课的成绩。

// String[] fields = {"H1:S_NO", "H1:S_Name", "H1:S_Sex", "H1:S_Age"};

// String[] values = {"2015001", "Zhangsan", "male", "23"};

// String row = "Zhangsan";

// addRecord(tablename, row, fields, values);

//3.浏览表tableName某一列的数据，如果某一行记录中该列数据不存在，则返回null。

// 要求当参数column为某一列族名称时，如果底下有若干个列限定符，则要列出每个列限定符代表的列的数据；

// 当参数column为某一列具体名称(例如“Score:Math”)时，只需要列出该列的数据。

// String column = "H1:S_Name";

// String rowkey = "Zhangsan";

// scanColumn(tablename, rowkey, column);

//4.modifyData(S修改表tableName，行row(可以用学生姓名S_Name表示)，

// 列column指定的单元格的数据tring tableName, String row, String column)

String colum = "H1:S_Name";

String rowkey = "Zhangsan";

String value = "XiaoFengZai";

modifyData(tablename, rowkey, colum, value);

}

3、删除指定行的内容

public static void deleteRow(String tableName, String row) throws IOException {

Table table = connection.getTable(TableName.valueOf(tableName));

//删除一条rowkey记录

Delete delete = new Delete(Bytes.toBytes(row));

table.delete(delete);

table.close();

}

public static void main(String[] args) throws IOException {

//用HBaseConfiguration.create();创建HBase的配置

Configuration configuration = HBaseConfiguration.create();

//用ConnectionFactory.createConnection创建HBase()连接

connection = ConnectionFactory.createConnection(configuration);

// 创建表，要给予HBase获取Admin对象

admin = connection.getAdmin();

String tablename = "WATER_BILL";

//1.创建表和列

// String[] filed = {"H1", "H2", "H3"};

// createTable(tablename, filed);

//2.向表tableName、行row(用S_Name表示)和字符串数组fields指定的单元格中添加对应的数据values。

// 其中，fields中每个元素如果对应的列族下还有相应的列限定符的话，用“columnFamily:column”表示。

// 例如，同时向“Math”、“Computer Science”、“English”三列添加成绩时，

// 字符串数组fields为{“Score:Math”, ”Score:Computer Science”, ”Score:English”}，数组values存储这三门课的成绩。

// String[] fields = {"H1:S_NO", "H1:S_Name", "H1:S_Sex", "H1:S_Age"};

// String[] values = {"2015001", "Zhangsan", "male", "23"};

// String row = "Zhangsan";

// addRecord(tablename, row, fields, values);

//3.浏览表tableName某一列的数据，如果某一行记录中该列数据不存在，则返回null。

// 要求当参数column为某一列族名称时，如果底下有若干个列限定符，则要列出每个列限定符代表的列的数据；

// 当参数column为某一列具体名称(例如“Score:Math”)时，只需要列出该列的数据。

// String column = "H1:S_Name";

// String rowkey = "Zhangsan";

// scanColumn(tablename, rowkey, column);

//4.modifyData(S修改表tableName，行row(可以用学生姓名S_Name表示)，

// 列column指定的单元格的数据tring tableName, String row, String column)

// String colum = "H1:S_Name";

// String rowkey = "Zhangsan";

// String value = "XiaoFengZai";

// modifyData(tablename, rowkey, colum, value);

//5.删除指定的rowkey内容

String rowkey="Zhangsan";

deleteRow(tablename,rowkey);

admin.close();

connection.close();

}

4、删除指定的表

public void deleteTable(String tablename)throws IOException

{

TableName tableName=TableName.valueOf("WATER_BILL");

if(admin.tableExists(tableName))

{

admin.disableTable(tableName);

admin.deleteTable(tableName);

}

}