statesqldb

Sep 2, 2022

Changes in this version

type StateInfo

+ func (b *StateInfo) GetSaveSql(_ string) (string, []interface{})

type StateSqlDB

+ func (s *StateSqlDB) ReadObjects(contractName string, keys [][]byte) ([][]byte, error)

Mar 16, 2022

Changes in this version

+ var DbType_Mysql = "mysql"

+ var DbType_Sqlite = "sqlite"

Dec 21, 2021

Changes in this version

type StateSqlDB

+ func (s *StateSqlDB) GetContractByName(name string) (*commonPb.Contract, error)

+ func (s *StateSqlDB) GetContractBytecode(name string) ([]byte, error)

Nov 5, 2021

Changes in this version

+ type MemberExtraInfo struct

+ MemberHash []byte

+ MemberInfo []byte

+ MemberType int

+ OrgId string

+ Seq uint64

+ func NewMemberExtraInfo(member *accesscontrol.Member, extra *accesscontrol.MemberExtraData) *MemberExtraInfo

+ func (b *MemberExtraInfo) GetCountSql() (string, []interface{})

+ func (b *MemberExtraInfo) GetCreateTableSql(dbType string) string

+ func (b *MemberExtraInfo) GetExtraData() *accesscontrol.MemberExtraData

+ func (b *MemberExtraInfo) GetInsertSql() (string, []interface{})

+ func (b *MemberExtraInfo) GetSaveSql() (string, []interface{})

+ func (b *MemberExtraInfo) GetTableName() string

+ func (b *MemberExtraInfo) GetUpdateSql() (string, []interface{})

+ func (b *MemberExtraInfo) ScanObject(scan func(dest ...interface{}) error) error

+ type NewDbHandleFunc func(dbName string) (protocol.SqlDBHandle, error)

+ type StateInfo struct

+ BlockHeight uint64

+ ContractName string

+ ObjectKey []byte

+ ObjectValue []byte

+ UpdatedAt time.Time

+ func NewStateInfo(contractName string, objectKey []byte, objectValue []byte, blockHeight uint64, ...) *StateInfo

+ func (b *StateInfo) GetCountSql() (string, []interface{})

+ func (b *StateInfo) GetCreateTableSql(dbType string) string

+ func (b *StateInfo) GetInsertSql() (string, []interface{})

+ func (b *StateInfo) GetTableName() string

+ func (b *StateInfo) GetUpdateSql() (string, []interface{})

+ func (b *StateInfo) ScanObject(scan func(dest ...interface{}) error) error

+ type StateRecordSql struct

+ ContractName string

+ Id string

+ SqlString string

+ SqlType int

+ Status int

+ UpdatedAt time.Time

+ Version string

+ func NewStateRecordSql(contractName string, sql string, sqlType protocol.SqlType, version string, ...) *StateRecordSql

+ func (b *StateRecordSql) GetCountSql() (string, interface{})

+ func (b *StateRecordSql) GetCreateTableSql(dbType string) string

+ func (b *StateRecordSql) GetInsertSql() (string, []interface{})

+ func (b *StateRecordSql) GetQueryStatusSql() (string, interface{})

+ func (b *StateRecordSql) GetTableName() string

+ func (b *StateRecordSql) GetUpdateSql() (string, []interface{})

+ type StateSqlDB struct

+ func NewStateSqlDB(dbPrefix, chainId string, db protocol.SqlDBHandle, newDbHandle NewDbHandleFunc, ...) (*StateSqlDB, error)

+ func (s *StateSqlDB) BeginDbTransaction(txName string) (protocol.SqlDBTransaction, error)

+ func (s *StateSqlDB) Close()

+ func (s *StateSqlDB) CommitBlock(blockWithRWSet *serialization.BlockWithSerializedInfo, isCache bool) error

+ func (s *StateSqlDB) CommitDbTransaction(txName string) error

+ func (s *StateSqlDB) CreateDatabase(contractName string) error

+ func (s *StateSqlDB) DropDatabase(contractName string) error

+ func (s *StateSqlDB) ExecDdlSql(contractName, sql, version string) error

+ func (s *StateSqlDB) GetChainConfig() (*configPb.ChainConfig, error)

+ func (s *StateSqlDB) GetContractDbName(contractName string) string

+ func (s *StateSqlDB) GetDbTransaction(txName string) (protocol.SqlDBTransaction, error)

+ func (s *StateSqlDB) GetLastSavepoint() (uint64, error)

+ func (s *StateSqlDB) GetMemberExtraData(member *accesscontrol.Member) (*accesscontrol.MemberExtraData, error)

+ func (s *StateSqlDB) InitGenesis(genesisBlock *serialization.BlockWithSerializedInfo) error

+ func (s *StateSqlDB) QueryMulti(contractName, sql string, values ...interface{}) (protocol.SqlRows, error)

+ func (s *StateSqlDB) QuerySingle(contractName, sql string, values ...interface{}) (protocol.SqlRow, error)

+ func (s *StateSqlDB) ReadObject(contractName string, key []byte) ([]byte, error)

+ func (s *StateSqlDB) RollbackDbTransaction(txName string) error

+ func (s *StateSqlDB) SelectObject(contractName string, startKey []byte, limit []byte) (protocol.StateIterator, error)