starbase 0.3.3

创建新表

假设数据库中尚未存在名为table3的表，创建一个名为table3的表，具有列（列族）column1、column2、column3（这是表实际创建的点）。在下面的示例中，column1、column2和column3是列族（简称列）。列在表模式中声明。

t.create('column1', 'column2', 'column3')

输出。

201

检查表是否存在

t.exists()

输出。

True

显示表列（列族）

t.columns()

输出。

['column1', 'column2', 'column3']

向表中添加列

添加给定的列（column4、column5、column6、column7）。

t.add_columns('column4', 'column5', 'column6', 'column7')

输出。

200

从表中删除列

删除给定的列（column6、column7）。

t.drop_columns('column6', 'column7')

输出。

201

删除整个表模式

t.drop()

输出。

200

向单行插入数据

HBase是一个键/值存储。在HBase中，列（也称为列族）是声明表模式的一部分，并且在创建表时必须定义。列有限定符，这些限定符不在表模式中声明。列限定符的数量不受限制。

在单行内，一个值通过列族和限定符（从键/值存储的概念）映射。值可以是任何可转换为字符串的类型（JSON对象、数据结构、XML等）。

在下面的示例中，key11、key12、key21等。是限定符。显然，column1、column2和column3是列族。

列族必须由可打印字符组成。限定符可以是任意任意字节。

表行通过行键（唯一标识符，UID或称为主键）进行标识。在下面的示例中，my-key-1 是行键（UID）。

总结上面所说，HBase 将（行键、列族、列限定符和时间戳）映射到一个值。

t.insert(
    'my-key-1',
    {
        'column1': {'key11': 'value 11', 'key12': 'value 12',
                    'key13': 'value 13'},
        'column2': {'key21': 'value 21', 'key22': 'value 22'},
        'column3': {'key32': 'value 31', 'key32': 'value 32'}
    }
    )

输出。

200

注意，您还可以使用 native 方式命名列和单元格（限定符）。以下结果与上一个示例的结果相同。

t.insert(
    'my-key-1',
    {
        'column1:key11': 'value 11', 'column1:key12': 'value 12',
        'column1:key13': 'value 13',
        'column2:key21': 'value 21', 'column2:key22': 'value 22',
        'column3:key32': 'value 31', 'column3:key32': 'value 32'
    }
    )

输出。

200

更新行数据

t.update(
    'my-key-1',
    {'column4': {'key41': 'value 41', 'key42': 'value 42'}}
    )

输出。

200

删除行、行列或行单元格数据

删除行单元格（限定符）数据。在下面的示例中，my-key-1 是表行UID，column4 是列族，key41 是限定符。注意，仅删除给定行的限定符数据。列 column4 的所有其他可能的限定符将保持不变。

t.remove('my-key-1', 'column4', 'key41')

输出。

200

删除行列（列族）数据。注意，在这种情况下，整个列数据（给定行的所有限定符的数据）将被删除。

t.remove('my-key-1', 'column4')

输出。

200

删除整个行数据。注意，在这种情况下，整个行数据，包括给定行的所有列和限定符，将被删除。

t.remove('my-key-1')

输出。

200

获取表数据

获取包含所有列和限定符的单个行数据。

t.fetch('my-key-1')

输出。

{
    'column1': {'key11': 'value 11', 'key12': 'value 12', 'key13': 'value 13'},
    'column2': {'key21': 'value 21', 'key22': 'value 22'},
    'column3': {'key32': 'value 31', 'key32': 'value 32'}
}

获取包含选定列的单个行数据（限制为 column1 和 column2 列及其所有限定符）。

t.fetch('my-key-1', ['column1', 'column2'])

输出。

{
    'column1': {'key11': 'value 11', 'key12': 'value 12', 'key13': 'value 13'},
    'column2': {'key21': 'value 21', 'key22': 'value 22'},
}

进一步缩小结果集（限制为 column1 的限定符 key1 和 key2 以及 column3 的限定符 key32）。

t.fetch('my-key-1', {'column1': ['key11', 'key13'], 'column3': ['key32']})

输出。

{
    'column1': {'key11': 'value 11', 'key13': 'value 13'},
    'column3': {'key32': 'value 32'}
}

注意，您还可以使用 native 方式命名列和单元格（限定符）。下面的示例与上面的示例完全相同。

t.fetch('my-key-1', ['column1:key11', 'column1:key13', 'column3:key32'])

输出。

{
    'column1': {'key11': 'value 11', 'key13': 'value 13'},
    'column3': {'key32': 'value 32'}
}

如果您将 perfect_dict 参数设置为 False，您将获得 native 数据结构。

t.fetch(
    'my-key-1',
    ['column1:key11', 'column1:key13', 'column3:key32'],
    perfect_dict=False
    )

输出。

{
    'column1:key11': 'value 11',
    'column1:key13': 'value 13',
    'column3:key32': 'value 32'
}

批量插入

在下面的示例中，我们将批量插入 5000 条记录。

data = {
    'column1': {'key11': 'value 11', 'key12': 'value 12', 'key13': 'value 13'},
    'column2': {'key21': 'value 21', 'key22': 'value 22'},
}
b = t.batch()
if b:
    for i in range(0, 5000):
        b.insert('my-key-%s' % i, data)
    b.commit(finalize=True)

输出。

{'method': 'PUT', 'response': [200], 'url': 'table3/bXkta2V5LTA='}

批量更新

在下面的示例中，我们将批量更新 5000 条记录。

data = {
    'column3': {'key31': 'value 31', 'key32': 'value 32'},
}
b = t.batch()
if b:
    for i in range(0, 5000):
        b.update('my-key-%s' % i, data)
    b.commit(finalize=True)

输出。

{'method': 'POST', 'response': [200], 'url': 'table3/bXkta2V5LTA='}

注意：表的 batch 方法接受一个可选的 size 参数（整数）。如果设置，每次堆满时将触发自动提交。

获取所有行

t.fetch_all_rows()

输出。

<generator object results at 0x28e9190>

获取给定过滤器的行

rf = '{"type": "RowFilter", "op": "EQUAL", "comparator": {"type": "RegexStringComparator", "value": "^row_1.+"}}'
t.fetch_all_rows(with_row_id=True, filter_string=rf)

输出。

<generator object results at 0x28e9190>