hbase 2.0.2 增删改查

package cn.hbase.demo;

import java.io.IOException;
import java.util.Iterator;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellScanner;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.regionserver.StripeStoreFileManager;
import org.apache.hadoop.hbase.util.Bytes;

/**
 * 增删改查 注意hbase中一行指的是一个列族,所以一行可能含有多条数据
 * 
 * @author Tele
 *
 */

public class CrudTable {
    private static Connection conn;
    private static Configuration conf;
    private static Admin admin;
    static {
        try {
            conf = HBaseConfiguration.create();
            conn = ConnectionFactory.createConnection(conf);
            admin = conn.getAdmin();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

    public static boolean isExistTable(String tableName) throws IOException {
        return admin.tableExists(TableName.valueOf(tableName));
    }

    /**
     * 创建表
     * 
     * @param tableName
     * @param columnFamily 列族,创建表时可以传递多个列族过来
     * @throws IOException
     */
    public static void createTable(String tableName, String... columnFamily) throws IOException {

        if (isExistTable(tableName)) {
            System.out.println("已经存在表" + tableName);
            return;
        } else {
            HTableDescriptor tableDescriptor = new HTableDescriptor(TableName.valueOf(tableName));
            for (String cf : columnFamily) {
                tableDescriptor.addFamily(new HColumnDescriptor(cf));
            }
            admin.createTable(tableDescriptor);
            System.out.println("成功创建了表" + tableName);
        }
    }

    /**
     * 创建多版本的表
     * 
     * @param tableName
     * @param columnFamily 列族,创建表时可以传递多个列族过来
     * @throws IOException
     */
    public static void createTableMultiVersion(String tableName, String veriosn, String... columnFamily)
            throws IOException {

        if (isExistTable(tableName)) {
            System.out.println("已经存在表" + tableName);
            return;
        } else {
            HTableDescriptor tableDescriptor = new HTableDescriptor(TableName.valueOf(tableName));
            for (String cf : columnFamily) {
                tableDescriptor.addFamily(new HColumnDescriptor(cf).setVersions(1, 3));
            }
            admin.createTable(tableDescriptor);
            System.out.println("成功创建了表" + tableName);
        }
    }

    /**
     * 删除表之前必须先禁用表
     * 
     * @param tableName
     * @throws IOException
     */
    public static void dropTable(String tableName) throws IOException {
        if (isExistTable(tableName)) {
            admin.disableTable(TableName.valueOf(tableName));
            admin.deleteTable(TableName.valueOf(tableName));
            System.out.println("表" + tableName + "删除成功");
        } else {
            System.out.println("表" + tableName + "不存在");
        }

    }

    /**
     * 添加一条数据
     * 
     * @param tableName
     * @param rowKey    行键
     * @param cf        列族
     * @param cn        列名
     * @param value
     * @throws IOException
     */
    public static void addRow(String tableName, String rowKey, String cf, String cn, String value) throws IOException {
        // 先判断表是否存在
        if (isExistTable(tableName)) {
            Table table = conn.getTable(TableName.valueOf(tableName));
            Put put = new Put(Bytes.toBytes(rowKey));
            put.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn), Bytes.toBytes(value));

            table.put(put);
            System.out.println("成功插入一条数据");
            table.close();
        } else {
            System.out.println("待插入的表不存在");
        }
    }

    /**
     * 删除一条数据
     * 
     * @param tableName
     * @param rowKey
     * @param cf
     * @param cn
     * @throws IOException
     */
    public static void deleteRow(String tableName, String rowKey, String cf, String cn) throws IOException {
        if (isExistTable(tableName)) {
            Table table = conn.getTable(TableName.valueOf(tableName));
            Delete delete = new Delete(Bytes.toBytes(rowKey));
            delete.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn));
            table.delete(delete);
            System.out.println("删除成功");
            table.close();
        } else {
            System.out.println("表不存在");
        }

    }

    /**
     * 删除一行数据,即删除该行数据对应的一个列族的数据
     * 
     * @param tableName
     * @param rowKey
     * @param cf
     * @throws IOException
     */
    public static void deleteMultiRow(String tableName, String rowKey, String cf) throws IOException {
        if (isExistTable(tableName)) {
            Table table = conn.getTable(TableName.valueOf(tableName));
            Delete delete = new Delete(Bytes.toBytes(rowKey));
            delete.addFamily(Bytes.toBytes(cf));
            table.delete(delete);
            System.out.println("删除成功");
            table.close();
        } else {
            System.out.println("表不存在");
        }
    }

    /**
     * 查询指定列族.列名的数据,一个reuslt代表一个列的全部数据
     * 
     * @param tableName
     * @param rowKey
     * @param cf
     * @param cn
     * @throws IOException
     */
    public static void getRow(String tableName, String rowKey, String cf, String cn) throws IOException {
        if (isExistTable(tableName)) {
            Table table = conn.getTable(TableName.valueOf(tableName));
            Get get = new Get(Bytes.toBytes(rowKey));
            get.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn));
            Result result = table.get(get);

            // 遍历result
            CellScanner cellScanner = result.cellScanner();
            while (cellScanner.advance()) {
                Cell cell = cellScanner.current();
                System.out.println("行键:" + Bytes.toString(CellUtil.copyRow(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();
        } else {
            System.out.println("表不存在");
        }
    }

    /**
     * 查询指定列多个版本的数据
     * 
     * @param tableName
     * @param rowKey
     * @param cf
     * @param cn
     * @throws IOException
     */
    public static void getRowMultiVersion(String tableName, String rowKey, String cf, String cn) throws IOException {
        if (isExistTable(tableName)) {
            Table table = conn.getTable(TableName.valueOf(tableName));
            Get get = new Get(Bytes.toBytes(rowKey));

            // get.setMaxVersions();
            get.readAllVersions();

            get.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn));
            Result result = table.get(get);

            // 遍历result
            CellScanner cellScanner = result.cellScanner();
            while (cellScanner.advance()) {
                Cell cell = cellScanner.current();
                System.out.println("行键:" + Bytes.toString(CellUtil.copyRow(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();
        } else {
            System.out.println("表不存在");
        }
    }

    /**
     * 查询指定列族数据 一个reuslt代表一个行键的全部数据
     * 
     * @param tableName
     * @param rowKey
     * @param cf
     * @param cn
     * @throws IOException
     */
    public static void getMultiRows(String tableName, String rowKey, String cf) throws IOException {
        if (isExistTable(tableName)) {
            Table table = conn.getTable(TableName.valueOf(tableName));
            Get get = new Get(Bytes.toBytes(rowKey));
            get.addFamily(Bytes.toBytes(cf));
            Result result = table.get(get);

            // 遍历result
            CellScanner cellScanner = result.cellScanner();
            while (cellScanner.advance()) {
                Cell cell = cellScanner.current();
                System.out.println("行键:" + Bytes.toString(CellUtil.copyRow(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)));
                System.out.println();
            }
            table.close();
        } else {
            System.out.println("表不存在");
        }
    }

    /**
     * 查询全部数据 一个reuslt代表一个列族的全部数据
     * 
     * @param tableName
     * @throws IOException
     */
    public static void scanTable(String tableName) throws IOException {
        if (isExistTable(tableName)) {
            Table table = conn.getTable(TableName.valueOf(tableName));

            Scan scan = new Scan();
            ResultScanner scanner = table.getScanner(scan);
            // 遍历scanner
            Iterator<Result> iterator = scanner.iterator();
            while (iterator.hasNext()) {
                Result result = iterator.next();
                // 遍历result
                CellScanner cellScanner = result.cellScanner();
                while (cellScanner.advance()) {
                    Cell cell = cellScanner.current();
                    System.out.println("行键:" + Bytes.toString(CellUtil.copyRow(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)));
                }
                System.out.println();
            }

            table.close();
        } else {
            System.out.println("表不存在");
        }

    }

    /**
     * 从指定行scan表
     * 
     * @param tableName
     * @param startRow
     * @throws IOException
     */
    public static void scanTableByRow(String tableName, String startRow) throws IOException {
        if (isExistTable(tableName)) {
            Table table = conn.getTable(TableName.valueOf(tableName));

            Scan scan = new Scan();
            // scan.setStartRow(Bytes.toBytes(startRow));
            scan.withStartRow(Bytes.toBytes(startRow));
            ResultScanner scanner = table.getScanner(scan);
            // 遍历scanner
            Iterator<Result> iterator = scanner.iterator();
            while (iterator.hasNext()) {
                Result result = iterator.next();
                // 遍历result
                CellScanner cellScanner = result.cellScanner();
                while (cellScanner.advance()) {
                    Cell cell = cellScanner.current();
                    System.out.println("行键:" + Bytes.toString(CellUtil.copyRow(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)));
                }
                System.out.println();
            }

            table.close();
        } else {
            System.out.println("表不存在");
        }

    }

    public static void main(String[] args) throws IOException {
//        createTable("yeye","info","hobby");
//        dropTable("yeye");
//        addRow("yeye","1","info","name","tele");
//        deleteRow("yeye","1","info","name");
//        deleteMultiRow("yeye","1","info");

//        getRow("yeye","1","info","name");
//        getMultiRows("yeye","1","info");

//        scanTable("yeye");

//        scanTableByRow("yeye","2");

        // 创建多版本的表
        // createTableMultiVersion("staff","3","info","sex");

        /*
         * addRow("staff","1","info","name","wyc");
         * addRow("staff","1","info","name","baba");
         * addRow("staff","1","info","name","yeye");
         */

        // 查询多版本
        getRowMultiVersion("staff", "1", "info", "name");

    }

}