深圳品牌网站建设公司哪家好,html网站后台模板,wordpress媒体库没有东西,wordpress推荐系统配置目录 一、新建一个maven工程 二、代码实现
2.1、配置hbase信息#xff0c;连接hbase数据库
2.2、创建命名空间
2.3、创建表
2.4、删除表#xff0c;删除之前要设置为禁用状态
2.5、添加数据
2.6、获取命令表空间 / tables列表
2.7、get方法查看表的内容
2.8、scan方法…目录 一、新建一个maven工程 二、代码实现
2.1、配置hbase信息连接hbase数据库
2.2、创建命名空间
2.3、创建表
2.4、删除表删除之前要设置为禁用状态
2.5、添加数据
2.6、获取命令表空间 / tables列表
2.7、get方法查看表的内容
2.8、scan方法查看表的内容 一、新建一个maven工程 添加 pom依赖 dependencygroupIdorg.apache.hbase/groupIdartifactIdhbase-client/artifactIdversion2.3.5/version/dependencydependencygroupIdorg.apache.hbase/groupIdartifactIdhbase-server/artifactIdversion2.3.5/version/dependency 二、代码实现
2.1、配置hbase信息连接hbase数据库
1.、测试类添加Before 和After 便于初始化和关闭资源
2、将对象提到上面变为全局对象 static Configuration config null;private Connection conn null;private Admin admin null;Beforepublic void init() throws IOException {System.out.println(执行init()方法);config HBaseConfiguration.create();config.set(HConstants.HBASE_DIR, hdfs://192.168.91.180:9000/hbase);config.set(HConstants.ZOOKEEPER_QUORUM, 192.168.91.180);config.set(HConstants.CLIENT_PORT_STR, 2181);conn ConnectionFactory.createConnection(config);admin conn.getAdmin();}Afterpublic void close() throws IOException {System.out.println(执行close()方法);if (admin ! null)admin.close();if (conn ! null)conn.close();}
2.2、创建命名空间 Testpublic void createNameSpace() throws IOException {NamespaceDescriptor kb21 NamespaceDescriptor.create(kb21).build();try {admin.createNamespace(kb21);} catch (IOException e) {e.printStackTrace();}}
2.3、创建表 Testpublic void createTable() throws IOException {//创建表的描述类TableName tableName TableName.valueOf(kb21:student);HTableDescriptor desc new HTableDescriptor(tableName);//创建列族的描述类HColumnDescriptor family1 new HColumnDescriptor(info1);HColumnDescriptor family2 new HColumnDescriptor(info2);desc.addFamily(family1);desc.addFamily(family2);admin.createTable(desc);}
2.4、删除表删除之前要设置为禁用状态 Testpublic void deleteTable() throws IOException {admin.disableTable(TableName.valueOf(kb21:student));admin.deleteTable(TableName.valueOf(kb21:student));}
2.5、添加数据 Testpublic void insertData() throws IOException {Table table conn.getTable(TableName.valueOf(kb21:student));Put put new Put(Bytes.toBytes(student1));put.addColumn(info1.getBytes(),name.getBytes(),zs.getBytes());put.addColumn(info2.getBytes(),school.getBytes(),njzb.getBytes());Put put2 new Put(Bytes.toBytes(student2));put2.addColumn(info1.getBytes(),name.getBytes(),zss.getBytes());put2.addColumn(info2.getBytes(),school.getBytes(),njzb.getBytes());Put put3 new Put(Bytes.toBytes(student3));put3.addColumn(info1.getBytes(),name.getBytes(),zsr.getBytes());put3.addColumn(info2.getBytes(),school.getBytes(),njzb.getBytes());ArrayListPut list new ArrayList();list.add(put2);list.add(put3);table.put(list);}
2.6、获取命令表空间 / tables列表 Testpublic void getAllNameSpace() throws IOException {String[] nps admin.listNamespaces();String s Arrays.toString(nps);System.out.println(s);//获得表的列族ListTableDescriptor tableDesc admin.listTableDescriptorsByNamespace(kb21.getBytes());System.out.println(tableDesc.toString());}
2.7、get方法查看表的内容 Testpublic void queryData() throws IOException {Table table conn.getTable(TableName.valueOf(kb21:student));Get get new Get(Bytes.toBytes(student1));Result result table.get(get);byte[] value result.getValue(Bytes.toBytes(info1), Bytes.toBytes(name));System.out.println(姓名 Bytes.toString(value));value result.getValue(Bytes.toBytes(info2), Bytes.toBytes(school));System.out.println(学校 Bytes.toString(value));}
2.8、scan方法查看表的内容 Testpublic void scanData() throws IOException {Table table conn.getTable(TableName.valueOf(kb21:student));Scan scan new Scan();ResultScanner scanner table.getScanner(scan);for (Result result: scanner) {byte[] value result.getValue(Bytes.toBytes(info1), Bytes.toBytes(name));System.out.println(姓名 Bytes.toString(value));value result.getValue(Bytes.toBytes(info2), Bytes.toBytes(school));System.out.println(学校 Bytes.toString(value));System.out.println(Bytes.toString(result.getRow()));}}
