与 HBase 的兼容性

public class HBaseInsertDemo {
    public static void main(String[] args) throws Exception {
        // 配置HBase
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", "your_zookeeper_quorum"); // 设置ZooKeeper地址
        conf.set("hbase.zookeeper.property.clientPort", "2181"); // 设置ZooKeeper端口
        // 拿到Table句柄
        TableName tableName = TableName.valueOf("your_table_name"); 
        HTable table =new HTable(tableName, conf);
        // 准备插入数据
        Put put = new Put(Bytes.toBytes("row_key"));
        put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("qualifier"), Bytes.toBytes("value")); // 列族，列标识符，值
        table.put(put);
        // 关闭资源
        table.close();
        System.out.println("数据插入成功！");
    }
}

public class OBHBaseInsertDemo {
    public static void main(String[] args) throws Exception {
        // 配置HBase
        Configuration conf = new Configuration();
        conf.set(HBASE_OCEANBASE_FULL_USER_NAME, "");
        conf.set(HBASE_OCEANBASE_PASSWORD, "");
        conf.set(HBASE_OCEANBASE_PARAM_URL, "");
        conf.set(HBASE_OCEANBASE_SYS_USER_NAME, "");
        conf.set(HBASE_OCEANBASE_SYS_PASSWORD, "");
        // 拿到Table句柄
        TableName tableName = TableName.valueOf("your_table_name"); 
        OHTableClient table = new OHTableClient(tableName, conf); // 创建 htable对象

        // 准备插入数据
        Put put = new Put(Bytes.toBytes("row_key"));
        put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("qualifier"), Bytes.toBytes("value")); // 列族，列标识符，值
        table.put(put);
        // 关闭资源
        table.close();
        System.out.println("数据插入成功！");
    }
}