package test2;import java.util.ArrayList;import java.util.List;import org.apache.hadoop.fs.Path;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.Cell;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.Delete;import org.apache.hadoop.hbase.client.Get;import org.apache.hadoop.hbase.client.HBaseAdmin;import org.apache.hadoop.hbase.client.HConnection;import org.apache.hadoop.hbase.client.HConnectionManager;import org.apache.hadoop.hbase.client.HTable;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;public class TestHBase {        private HBaseAdmin admin = null;    private Configuration conf = null;        public TestHBase() throws Exception    {        conf = HBaseConfiguration.create();       conf.addResource(new Path("/home/work/hbase_dev/test2/lib/hbase-site.xml"));        //conf.set("hbase.zookeeper.quorum", "10.57.90.19");        //conf.set("hbase.zookeeper.property.clientPort", "2181");        admin = new HBaseAdmin(conf);    }        public void createTable (String tableName , String[] columnFamily) throws Exception    {        if (admin.tableExists(tableName))        {            System.out.println(tableName + "已存在");            return ;            //System.exit(0);        }                HTableDescriptor tableDescriptor = new HTableDescriptor(TableName.valueOf(tableName));                for (String colunm : columnFamily)        {            tableDescriptor.addFamily(new HColumnDescriptor(colunm));        }                admin.createTable(tableDescriptor);        System.out.println("Create table successfully..");    }        public boolean deleteTable (String tableName)    {        try {            if(admin.tableExists(tableName))            {                admin.disableTable(tableName);                admin.deleteTable(tableName);                System.out.println("drop table " + tableName);            }            return true;        } catch (Exception e) {            System.out.println("删除" + tableName + "失败");            return false;        }    }        public List getAllTables()    {        List<String> tables = null;        if (admin != null)        {            try{                HTableDescriptor[] allTables = admin.listTables();                if(allTables.length > 0)                {                    tables = new ArrayList<String>();                }                                for (HTableDescriptor tableDesc : allTables)                {                    tables.add(tableDesc.getNameAsString());                    System.out.println(tableDesc.getNameAsString());                }            }catch(Exception ex)            {                ex.printStackTrace();            }        }                return tables;    }        public boolean addOneRecord (String tableName , String key , String family , String column             , byte[] dataIn) throws Exception    {        HConnection connection = HConnectionManager.createConnection(conf);        //HTable table = new HTable(hbaseConf, tableName);        HTable table = (HTable)connection.getTable(tableName);        Put put = new Put(key.getBytes());        put.add(family.getBytes(), column.getBytes(), dataIn);        try {            table.put(put);            System.out.println("插入数据条 " + key + "成功");            return true;        } catch (Exception e) {            // TODO: handle exception            System.out.println("插入数据条 " + key + "失败");            return false;        }    }        public void getValueFromKey (String tableName , String key)    {        try{            HConnection conn = HConnectionManager.createConnection(conf);            HTable table = (HTable) conn.getTable(tableName);            Get get = new Get(key.getBytes());            Result rs = table.get(get);            if (rs.rawCells().length == 0)            {                System.out.println("不存在关键字为" + key + "的行...");            }            else            {                for (Cell cell : rs.rawCells())                {                    System.out.println(new String(CellUtil.cloneFamily(cell)) +                             "  " + new String(CellUtil.cloneQualifier(cell)) + "  " + new String(CellUtil.cloneValue(cell)));                }            }        }        catch(Exception ex)        {            System.out.println("查询失败");            ex.printStackTrace();        }    }                public void getAllData(String tableName) throws Exception    {        HConnection conn = HConnectionManager.createConnection(conf);        HTable table = (HTable) conn.getTable(tableName);        Scan scan = new Scan();        ResultScanner rs = table.getScanner(scan);        for (Result result : rs)        {            for (Cell cell : result.rawCells())            {                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.cloneQualifier(cell)) + " ");                System.out.println("value: " + new String(CellUtil.cloneValue(cell)) + " ");            }        }    }        public void deleteRecord(String tableName , String key)    {        try        {            HConnection conn = HConnectionManager.createConnection(conf);            HTable table = (HTable)conn.getTable(tableName);            Delete delete = new Delete(key.getBytes());                        table.delete(delete);            System.out.println("删除" + key +"成功...");        }        catch(Exception ex)        {            System.out.println("删除数据失败...");            ex.printStackTrace();        }    }        public static void main(String[] args) throws Exception{        // TODO Auto-generated method stub        String[] column = {"family1" , "family2"};        try {            TestHBase hbase = new TestHBase();            hbase.deleteTable("students");            hbase.createTable("students", column);            //hbase.getAllData("scores");            hbase.addOneRecord("students", "id1", "family1", "name", "Jack".getBytes());            hbase.addOneRecord("students", "id1", "family1", "grade", "gaosan".getBytes());            //hbase.getAllTables();            //hbase.getAllData("students");            hbase.getValueFromKey("students", "id1");            hbase.deleteRecord("students", "id1");            hbase.addOneRecord("students", "id2", "family1", "name", "Holen".getBytes());            hbase.getValueFromKey("students", "id2");        } catch (Exception e) {            // TODO: handle exception            e.printStackTrace();        }                            }}

<?xml version="1.0"?>  <project name="HBaseProject" default="run" basedir=".">      <property name="src.dir" value="src" />      <property name="report.dir" value="report" />      <property name="classes.dir" value="classes" />      <property name="lib.dir" value="lib" />      <property name="dist.dir" value="dist" />      <property name="doc.dir" value="doc"/>      <path id="master-classpath">          <fileset file="${lib.dir}/*.jar" />          <pathelement path="${classes.dir}"/>      </path>      <path id="run.path">          <path path="${classes.dir}"/>        <path refid="master-classpath" />    </path>     <target name="init" depends="clean">        <mkdir dir="${classes.dir}"/>        <mkdir dir="${dist.dir}"/>    </target>      <target name="compile" depends="init" description="compile the source files">          <javac srcdir="${src.dir}" destdir="${classes.dir}" target="1.6" includeantruntime="false">              <classpath refid="master-classpath"/>          </javac>      </target>      <target name="run" depends="compile">        <java classname="test2.TestHBase" classpathref="run.path" fork="true" >        </java>    </target>    <target name="pack" depends="compile" description="make .jar file">          <mkdir dir="${dist.dir}" />          <jar destfile="${dist.dir}/hbaseproject.jar" basedir="${classes.dir}">              <exclude name="**/*Test.*" />              <exclude name="**/Test*.*" />          </jar>      </target>     <target name="clean" description="clean the project">        <delete dir="${classes.dir}"></delete>        <delete dir="${dist.dir}"></delete>    </target></project>