1. Hi区块链首页
  2. 资讯
  3. 技术指南

区块链研究实验室 | 使用MySQL存储以太坊事件

在本文中,我将演示一种缓存以太坊事件的简单方法。我只想说,通常我们将事务用于链下操作,例如跟踪令牌的传输或检索特定事务的筛选列表,就像一个SQL查询一样。

在本文中,我将演示一种缓存以太坊事件的简单方法。我只想说,通常我们将事务用于链下操作,例如跟踪令牌的传输或检索特定事务的筛选列表,就像一个SQL查询一样。

假设我们想要创建一个跟踪令牌传输的网站,Etherscan。我们只需要一波简单的操作,比如:

  1. 取得所有令牌转移信息

  2. 取得以太坊转账来源地址

  3. 取得以太坊转账目标地址

  4. 获得特定金额的转账信息

  5. 在特定时间范围内获得转移信息

在web3中是有getPastEvents方法,其示例用法是:

2019080715595212463.png

这种方法的主要问题是,随着区块链的增长,速度可能会变慢,尤其是如果您不运行自己的以太坊节点,并且使用像infura或MyEtherApi这样的公共提供者。

接下来,几乎不可能实现一些比较复杂的查询,因为筛选对象的功能非常有限。

此外,已经写入区块链的事件无法更改,只能随时间添加新记录。 这个和其他事实使事件成为缓存的完美目标。

数据库选择

在这个例子中,我们将使用mysql作为保存事件记录的数据库。MySQL有能力存储原始JSON,然后使用JSON对象的属性编写查询,就好像它们是普通的SQL列一样。

我们应该储存什么?

让我们仔细看看getPastEvents方法的结果,以实现我们使用的数据。 我以Binance代币转移为例。 每个事件对象都具有以下结构:

2019080716002881428.png

如您所见,事件参数存储在returnValues属性中。 blockNumber,transactionHash,logIndex也可能有用,我稍后会告诉你。

我们的目标是将这些JSON对象编写到数据库中,并实现可以无缝替换标准web3的getPastEvents方法的简单访问方法。

以下是用于创建Transfer表的SQL脚本。

2019080716005591882.png

需要说明的一些重要事项:

  1. json列创建为JSON类型。 这允许我们使用特殊语法创建自动生成的列。

  2. from,to,value  – 这些是自动生成的列。 这个表达式起初看起来很复杂,但实际上它很简单。 例如,从列值等于存储在json列中的对象的returnValues.from属性。

  3. txHash和logIndex。 这些属性组合在一起可识别每个事件对象 我们需要那些为行创建唯一索引,从而防止偶尔重复事件。

我们还可以选择添加数据库索引来提高性能。 例如,对于to 列

2019080716012790966.png

案例实践

先决条件

  1. Node.js的 我使用的是8.4.0版。

  2. Web3 npm包与区块链进行交互。 我们需要特定版本1.0.0-beta.35。 在尝试检索某些事件时,最新版本beta.36的使用导致“返回值无效,是否运行Out of Gas”错误。

2019080716015135858.png

3.要在JavaScript中使用MySQL数据库,我们应该安装mysql包 

2019080716021565176.png

 4.最后一个 –  MySQL服务器。 值得一提的是,我们将使用MySQL 5.7作为最新的8.0版本似乎与mysql包兼容(它在尝试连接时给了我奇怪的错误ER_NOT_SUPPORTED_AUTH_MODE)。

MySQL交互

我们将利用连接池对此示例进行查询。

2019080716024251352.png

使用promisified版本的查询方法会更方便 

2019080716030599550.png

现在我们可以使用以下代码将记录插入之前创建的传输表中。 

2019080716032953878.png

在这里,我们还检查可能的重复行插入。 现在我们不希望在这种情况下做任何特别的事情,可能我们已经提前写过这些重复事件或类似的事情。 所以我们只考虑处理这种异常。

缓存功能

让我们构造一个智能合约对象来从中检索事件

2019080716035318196.png

 我们只能在abi参数中包含Transfer事件接口,如下所示:

2019080716041753255.png

这是缓存功能的基本版本。 首先,我们获取事件对象,然后逐个将它们写入数据库。 

2019080716043713850.png

定期区块链扫描

现在让我们将其扩展为一个简单的后台脚本,该脚本不断扫描区块链以查找发出的事件。

一些实用功能:

2019080716050332684.png

第一个是setTimeout的简单异步/等待实现。 第二个用于fn的无限周期调用 – 工作函数。

有了这些辅助功能,我们的后台扫描仪看起来非常简单

2019080716053258519.png

让我解释’latestEthBlock + 1’的事情。 Web3的getPastEvents(fromBlock,toBlock)返回在[from,to]范围内写入的事件,包括边界。 因此,如果没有这个递增,下一个cacheEvents调用将再次将写入latestEthBlock的事件作为结果的一部分返回。

虽然由于实现了唯一索引,重复事件不会插入到数据库中,但我们仍然不希望完成这些多余的工作。

对于简单的后台扫描程序,此实现应该足够了。 但是,总有改进的余地。 稍后我们会回到它。 现在让我们快速了解一下我们现在可以利用这些数据做些什么。

事件检索

以下是选择从特定地址进行的转移的功能示例:

2019080716055752165.png

我们使用生成的列查询数据库。 这里最值得注意的部分是函数的结果看起来就像web3的getPastEvents的结果。 它使得重构当前代码变得更加容易。

进一步改进

事件对象包含许多可能对您的应用程序完全无用的属性。 在写入数据库之前删除多余部分会更好。 这样我们就节省了很多空间。

2019080716062672330.png

您可能还注意到,当前版本的扫描程序在每次重新启动时都以区块#0开始。 在一直扫描到当前块时,它会尝试将重复记录插入数据库。 我们可以通过查询数据库中的最新缓存块来消除那些多余的工作。

不是从块#0开始扫描也是很好的,但至少从部署合同时的块开始扫描。 为简单起见,您可以使用etherscan.io获取此信息。

2019080716064850608.png

这里我们再次使用MySQL json函数来获取事件对象的blockNumber属性。

然后更换旧的扫描功能

2019080716070910203.png

新的扫描功能 

2019080716072970759.png

 结论

最后,我们创建了一个简单但有效的事件扫描程序,可以将事件连续缓存到MySQL数据库中。

本文转载公众号:区块链研究实验室,专注区块链技术,产品社群,经济模型等全方位的知识体系输出,为大家带来不一样的社群学习体验。欢迎联系作者微信加入社群:csschan1120    

声明:登载此文出于传递更多信息之目的,观点仅代表作者本人,绝不代表Hi区块链赞同其观点或证实其描述。
提示:投资有风险,入市须谨慎。本资讯不作为投资理财建议。