FISCO BCOS 2.0使用教程：分布式存储体验_文化 & 方法_FISCO金链盟_InfoQ精选文章



 写点什么

登录/注册

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

配置分布式存储

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

区块链的区块、交易等基础数据采用库表结构保存，状态数据的存储方式可配为库表结构或 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

评论

发布

暂无评论

代理模式

设计模式代理模式七日更

重磅！四部门联合约谈蚂蚁集团！刚刚，约谈的主要内容曝光……

区块链的核心技术是什么？

安全架构：反垃圾与风控

ARROW阿罗AOW币APP系统软件开发

Week10作业

是的，我又换工作了

架构师训练营大作业（二）

极客大学架构师训练营

Week10总结

七周七并发模型

第五周技术选型作业

第五章学习总结

第十周总结

Code Review实践

Code Review 七日更

架构师训练营第五周作业

数据仓库的前世今生

数据仓库七日更

框架VS架构，看两者异同

Spring 源码学习 10：prepareBeanFactory 和 postProcessBeanFactory

程序员小航

spring 源码源码阅读

从场景出发，日志聚类还可以这么玩

信仰圣光吧丶

AIOPS 日志聚类日志治理

pagerank算法

橘子皮嚼着不脆

架构师训练营第十周笔记

学习微服务 DDD

区块链链什么？

区块链分布式

我家有猫

生活方式七日更我家有猫

Flink比Spark好在哪？

flink spark 七日更

日本准备推行AI婚配，年轻人会为“爱情算法”买单吗？

Java并发底层知识，锁获取超时机制知多少？

Java java 并发

安全架构：加密与解密

wildfly 21中应用程序的部署

程序那些事

程序那些事 wildfly wildfly21 应用程序部署应用程序配置

第十周作业

用领域驱动设计驱动系统的重构

架构师训练营大作业（一）

极客大学架构师训练营