1、使用 API 在 HBase 中创建 Stu_Class 表并在 Hbase shell 中展示所有的表。2、使用 API 将数据插入到表中3、使用 Shell 命令查询表中所有数据4、使用 Shell 将 1003 行的 cname 改为 网络技术并查询 1003 行修改后的数据5、使用 API 查询选修课程为 3-245 的学生信息操作要求：1、要有代码、命令及结果截图2、步骤清晰有概要说

1、使用 API 在 HBase 中创建 Stu_Class 表，并在 Hbase shell 中展示所有的表。

代码：

import org.apache.hadoop.conf.Configuration;
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;

public class CreateTable {
    public static void main(String[] args) throws Exception {
        Configuration conf = HBaseConfiguration.create();
        Connection conn = ConnectionFactory.createConnection(conf);
        Admin admin = conn.getAdmin();
        
        TableName tableName = TableName.valueOf("Stu_Class");
        if (admin.tableExists(tableName)) {
            System.out.println("Table already exists!");
        } else {
            HTableDescriptor tableDescriptor = new HTableDescriptor(tableName);
            tableDescriptor.addFamily(new HColumnDescriptor("basic_info"));
            tableDescriptor.addFamily(new HColumnDescriptor("course_info"));
            admin.createTable(tableDescriptor);
            System.out.println("Table created successfully!");
        }
        
        admin.close();
        conn.close();
    }
}

命令：

hbase shell
list

结果截图：

2、使用 API 将数据插入到表中

代码：

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
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.client.Table;

public class InsertData {
    public static void main(String[] args) throws Exception {
        Configuration conf = HBaseConfiguration.create();
        Connection conn = ConnectionFactory.createConnection(conf);
        Table table = conn.getTable(TableName.valueOf("Stu_Class"));
        
        List<Put> puts = new ArrayList<>();
        Put put1 = new Put("1001".getBytes());
        put1.addColumn("basic_info".getBytes(), "name".getBytes(), "张三".getBytes());
        put1.addColumn("basic_info".getBytes(), "gender".getBytes(), "男".getBytes());
        put1.addColumn("course_info".getBytes(), "course_id".getBytes(), "3-245".getBytes());
        put1.addColumn("course_info".getBytes(), "score".getBytes(), "90".getBytes());
        puts.add(put1);
        
        Put put2 = new Put("1002".getBytes());
        put2.addColumn("basic_info".getBytes(), "name".getBytes(), "李四".getBytes());
        put2.addColumn("basic_info".getBytes(), "gender".getBytes(), "女".getBytes());
        put2.addColumn("course_info".getBytes(), "course_id".getBytes(), "3-245".getBytes());
        put2.addColumn("course_info".getBytes(), "score".getBytes(), "85".getBytes());
        puts.add(put2);
        
        Put put3 = new Put("1003".getBytes());
        put3.addColumn("basic_info".getBytes(), "name".getBytes(), "王五".getBytes());
        put3.addColumn("basic_info".getBytes(), "gender".getBytes(), "男".getBytes());
        put3.addColumn("course_info".getBytes(), "course_id".getBytes(), "3-246".getBytes());
        put3.addColumn("course_info".getBytes(), "score".getBytes(), "95".getBytes());
        puts.add(put3);
        
        table.put(puts);
        
        table.close();
        conn.close();
        System.out.println("Data inserted successfully!");
    }
}

3、使用 Shell 命令查询表中所有数据

命令：

scan 'Stu_Class'

结果截图：

4、使用 Shell 将 1003 行的 cname 改为 网络技术，并查询 1003 行修改后的数据

命令：

put 'Stu_Class', '1003', 'course_info:course_id', '网络技术'
get 'Stu_Class', '1003'

结果截图：

5、使用 API 查询选修课程为 3-245 的学生信息

代码：

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

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.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import org.apache.hadoop.hbase.util.Bytes;

public class QueryData {
    public static void main(String[] args) throws Exception {
        Configuration conf = HBaseConfiguration.create();
        Connection conn = ConnectionFactory.createConnection(conf);
        Table table = conn.getTable(TableName.valueOf("Stu_Class"));
        
        Scan scan = new Scan();
        SingleColumnValueFilter filter = new SingleColumnValueFilter(Bytes.toBytes("course_info"), Bytes.toBytes("course_id"), CompareOp.EQUAL, Bytes.toBytes("3-245"));
        scan.setFilter(filter);
        ResultScanner resultScanner = table.getScanner(scan);
        for (Result result : resultScanner) {
            CellScanner cellScanner = result.cellScanner();
            while (cellScanner.advance()) {
                Cell cell = cellScanner.current();
                System.out.print(Bytes.toString(CellUtil.cloneRow(cell)) + " ");
                System.out.print(Bytes.toString(CellUtil.cloneFamily(cell)) + ":");
                System.out.print(Bytes.toString(CellUtil.cloneQualifier(cell)) + " ");
                System.out.println(Bytes.toString(CellUtil.cloneValue(cell)));
            }
            System.out.println("--------------------");
        }
        
        table.close();
        conn.close();
    }
}

结果截图：

![image-20211224101123883](https://i.loli.net/2021/12/24/7ruS6HlVbKzL8Jx.png