hbase语言的基本语法
时间: 2023-11-27 09:03:03 浏览: 79
HBase是一个分布式、可扩展、面向列的NoSQL数据库系统,它基于Hadoop的HDFS存储数据。HBase的语法主要由Shell命令和Java API组成。
1. Shell命令:
- 启动HBase Shell:在终端中输入命令`hbase shell`。
- 创建表:`create 'table_name', 'column_family'`。例如,`create 'student', 'info'`。
- 插入数据:`put 'table_name', 'row_key', 'column_family:column', 'value'`。例如,`put 'student', '1', 'info:name', 'John'`。
- 获取数据:`get 'table_name', 'row_key'`。例如,`get 'student', '1'`。
- 扫描表:`scan 'table_name'`。例如,`scan 'student'`。
- 删除数据:`delete 'table_name', 'row_key', 'column_family:column'`。例如,`delete 'student', '1', 'info:name'`。
- 删除表:`disable 'table_name'; drop 'table_name'`。例如,`disable 'student'; drop 'student'`。
2. Java API:
HBase提供了Java API来与HBase进行交互。可以使用Java编写应用程序来操作HBase数据库。以下是Java API的基本用法示例:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
public class HBaseExample {
public static void main(String[] args) {
try {
Configuration conf = HBaseConfiguration.create();
Connection connection = ConnectionFactory.createConnection(conf);
TableName tableName = TableName.valueOf("table_name");
Table table = connection.getTable(tableName);
// 插入数据
Put put = new Put(Bytes.toBytes("row_key"));
put.addColumn(Bytes.toBytes("column_family"), Bytes.toBytes("column"), Bytes.toBytes("value"));
table.put(put);
// 获取数据
Get get = new Get(Bytes.toBytes("row_key"));
Result result = table.get(get);
byte[] value = result.getValue(Bytes.toBytes("column_family"), Bytes.toBytes("column"));
System.out.println(Bytes.toString(value));
table.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
```
阅读全文