Java_Habse_add

import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
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.Put;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Table;


public class HBaseTest2 {
    public static Configuration configuration;
    public static Connection connection;
    public static Admin admin;

    public static void main(String[] args) {
        configuration=HBaseConfiguration.create();
        configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");
        
        /*
        try {
            connection=ConnectionFactory.createConnection(configuration);
            admin=connection.getAdmin();
            insertRow("Student","scofield","score","English","45");
            insertRow("Student","scofield","score","Math","89");
            insertRow("Student","scofield","score","Computer","100");
            System.out.println("插入成功！---李运辰");
        } catch (IOException e) {
            e.printStackTrace();
        }
      */
        configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");
        try {
            connection=ConnectionFactory.createConnection(configuration);
            admin=connection.getAdmin();
            getData("Student","scofield","score","English");
            System.out.println("输出完成！---李运辰");
        } catch (IOException e) {
            e.printStackTrace();
        }
        
        
        
        
        close();
    }

    public static void insertRow(String tableName, String rowKey, String colFamily, String col, String val) {
        try {
            Table table = connection.getTable(TableName.valueOf(tableName));
            Put put = new Put(rowKey.getBytes());
            put.addColumn(colFamily.getBytes(), col.getBytes(), val.getBytes());
            table.put(put);
            table.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }


    public static void getData(String tableName, String rowKey, String colFamily, String col) {
        try {
            Table table = connection.getTable(TableName.valueOf(tableName));
            Get get=new Get(rowKey.getBytes());
            get.addColumn(colFamily.getBytes(), col.getBytes());
            Result result=table.get(get);
            showCell(result);
            table.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

    private static void showCell(Result result) {
        Cell[] cells=result.rawCells();
        for(Cell cell:cells) {
            System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+"     ");
            System.out.println("Timetamp:"+cell.getTimestamp()+"     ");
            System.out.println("column Family"+new String(CellUtil.cloneFamily(cell))+"     ");
            System.out.println("row Name:"+new String(CellUtil.cloneValue(cell))+"     ");
            System.out.println("value"+new String(CellUtil.cloneValue(cell))+"     ");
            
        }
        
    }
    public static void close() {

        try {
            if (admin != null) {
                admin.close();
            }
            if(null!=connection) {
                connection.close();
            }    
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}