hbase的Java基本操作

建表，建列簇操作

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<fields.length;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);

    }

添加数据，指定表名，列簇列名，以及rowkey和对应的value

//添加数据

    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<fields.length;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<values.length;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);

    }

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

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);

    }

修改rowkey下的对应的单独的列簇：列名的值

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);

    }

删除指定的rowkey内容

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();

    }

删除指定的表

public void deleteTable(String tablename)throws IOException

    {

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

        if(admin.tableExists(tableName))

        {

            admin.disableTable(tableName);

            admin.deleteTable(tableName);

        }

    }