配置分布式存储

分布式存储支持多种存储引擎，根据业务需求和部署环境灵活选择，可以配置为不同的存储引擎。

区块链的区块、交易等基础数据采用库表结构保存，状态数据的存储方式可配为库表结构或MPT，满足不同场景的需求。

分布式存储的配置项位于群组的配置文件中，各个群组可以使用单独的存储策略，群组配置文件位于区块链节点中名为conf/group.[群组号].genesis的路径下，如group.1.genesis，一旦群组启动，该群组的分布式存储的相关配置不能再改变。

分布式存储配置项示例如下：

[storage]
type=LevelDB：分布式存储的DB引擎类型，支持”LevelDB”和“External”（rc2版本）
[state]
type=storage：state类型，目前支持storage state和MPT state，默认为storage state

推荐使用 storage state ，除非必须使用MPT来追溯全局历史状态，不建议使用MPT State。

使用CRUD智能合约开发

分布式存储提供了专用的CRUD接口，支持合约直接访问底层的存储表。

访问CRUD需要引用分布式存储专用的智能合约Table.sol接口，该接口是数据库合约，可以创建表，并对表进行增删改查操作。

引用Table.sol
import “./Table.sol”;

Table.sol的接口包括：

createTable //创建表
select(string, Condition) //查询数据
insert(string, Entry) //插入数据
update(string, Entry, Condition) //更新数据
remove(string, Condition) //删除数据

每个接口的用法如下：

创建表
// TableFactory的地址固定为0x1001
TableFactory tf = TableFactory(0x1001);

// 创建t_test表，表的key_field为name，value_field为item_id,item_name
// key_field表示分布式存储主key value_field表示表中的列，可以有多列，以逗号分隔
int count = tf.createTable(“t_test”, “name”, “item_id,item_name”);

查询数据

TableFactory tf = TableFactory(0x1001);
Table table = tf.openTable("t_test");
        
// 条件为空表示不筛选 也可以根据需要使用条件筛选
Condition condition = table.newCondition();

Entries entries = table.select(name, condition);

插入数据

TableFactory tf = TableFactory(0x1001);
Table table = tf.openTable("t_test");
        
Entry entry = table.newEntry();
entry.set("name", name);
entry.set("item_id", item_id);
entry.set("item_name", item_name);
        
int count = table.insert(name, entry);

更新数据

TableFactory tf = TableFactory(0x1001);
Table table = tf.openTable("t_test");
        
Entry entry = table.newEntry();
entry.set("item_name", item_name);
        
Condition condition = table.newCondition();
condition.EQ("name", name);
condition.EQ("item_id", item_id);
        
int count = table.update(name, entry, condition);

删除数据

TableFactory tf = TableFactory(0x1001);
Table table = tf.openTable("t_test");
        
Condition condition = table.newCondition();
condition.EQ("name", name);
condition.EQ("item_id", item_id);
        
int count = table.remove(name, condition);

本文转载自FISCO金链盟公众号。

原文链接：https://mp.weixin.qq.com/s/08MLbE9CohjCZDagpBOk9Q

创作场景

FISCO BCOS 2.0 使用教程：分布式存储体验