Versions in this module Expand all Collapse all v3 v3.0.1 Dec 28, 2023 v3.0.0 Dec 23, 2022 Changes in this version + var DbType_Mysql = "mysql" + var DbType_Sqlite = "sqlite" + 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(dbType string) (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(dbType string) (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(dbType string) (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) GetContractByName(name string) (*commonPb.Contract, error) + func (s *StateSqlDB) GetContractBytecode(name string) ([]byte, 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) GetSnapshotIterator() ([]protocol.Iterator, error) + func (s *StateSqlDB) ImportSetSavePoint(height uint64) error + func (s *StateSqlDB) ImportSnapshot(key, value []byte) 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) ReadObjects(contractName string, keys [][]byte) ([][]byte, error) + func (s *StateSqlDB) RollbackDbTransaction(txName string) error + func (s *StateSqlDB) SelectObject(contractName string, startKey []byte, limit []byte) (protocol.StateIterator, error)