eventsqldb

Documentation

Index

• Constants
• type ContractEventSqlDB
  • func NewContractEventDB(dbName string, db protocol.SqlDBHandle, logger protocol.Logger) (*ContractEventSqlDB, error)
  • func (c *ContractEventSqlDB) Close()
  • func (c *ContractEventSqlDB) CommitBlock(blockInfo *serialization.BlockWithSerializedInfo, IsCache bool) error
  • func (c *ContractEventSqlDB) GetLastSavepoint() (uint64, error)
  • func (c *ContractEventSqlDB) InitGenesis(genesisBlock *serialization.BlockWithSerializedInfo) error

Constants

const (
	CreateBlockHeightWithTopicTableDdl string = `` /* 289-byte string literal not displayed */
	BlockHeightWithTopicTableName      string = `block_height_topic_table_index`
	CreateBlockHeightIndexTableDdl     string = `` /* 165-byte string literal not displayed */
	InitBlockHeightIndexTableDdl       string = `INSERT IGNORE INTO block_height_index (id,block_height) VALUES('1','0')`
	BlockHeightIndexTableName          string = `block_height_index`
)

Types

type ContractEventSqlDB

type ContractEventSqlDB struct {
	Logger protocol.Logger
	// contains filtered or unexported fields
}

BlockMysqlDB provider a implementation of `contracteventdb.ContractEventDB` This implementation provides a mysql based data model

func NewContractEventDB

func NewContractEventDB(dbName string, db protocol.SqlDBHandle, logger protocol.Logger) (*ContractEventSqlDB, error)

NewContractEventMysqlDB construct a new `ContractEventDB` for given chainId

func NewContractEventMysqlDB(chainId string, db protocol.SqlDBHandle, logger protocol.Logger) (*ContractEventSqlDB, error) {
	dbName := getDbName(sqlDbConfig, chainId)
	db := rawsqlprovider.NewSqlDBHandle(dbName, sqlDbConfig, logger)
	return newContractEventDB(dbName, db, logger)
}

创建一个 ContractDB

func (*ContractEventSqlDB) Close

func (c *ContractEventSqlDB) Close()

Close is used to close database, there is no need for gorm to close db

func (*ContractEventSqlDB) CommitBlock

func (c *ContractEventSqlDB) CommitBlock(blockInfo *serialization.BlockWithSerializedInfo, IsCache bool) error

CommitBlock commits the event in an atomic operation

func (*ContractEventSqlDB) GetLastSavepoint

func (c *ContractEventSqlDB) GetLastSavepoint() (uint64, error)

GetLastSavepoint returns the last block height

func (*ContractEventSqlDB) InitGenesis

func (c *ContractEventSqlDB) InitGenesis(genesisBlock *serialization.BlockWithSerializedInfo) error

完成创世区块的写入