db

package
v0.0.0-...-4027801 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 8, 2018 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TExec     int64
	TQuery    int64
	TCommit   int64
	TRollback int64
)

Functions

func Init 

func Init()

func MustQuery 

func MustQuery(sql DBSqlT, params DBParamsT, rcvr Receiver)

func TReset 

func TReset()

func TakeConnectionFromPool_sync 

func TakeConnectionFromPool_sync() refDBConnT

Types

type AddFromIteratorFunctorT 

type AddFromIteratorFunctorT func(params_ ...interface{})

type AddFromIteratorT 

type AddFromIteratorT func(iterFn AddFromIteratorFunctorT) (int, string)

type AddUnitIteratorFunctorT 

type AddUnitIteratorFunctorT func(unit types.UnitT)

type AddUnitIteratorT 

type AddUnitIteratorT func(iterFn AddUnitIteratorFunctorT) int

type AddressDelayRow 

type AddressDelayRow struct {
	Address types.AddressT
	Delay   types.DelayT
}

type AddressDelaysReceiver 

type AddressDelaysReceiver struct {
	Rows []AddressDelayRow
}

func (*AddressDelaysReceiver) Scan 

func (rcvr *AddressDelaysReceiver) Scan(sqlRows *sql.Rows) error

type AddressDenominationAssetRow 

type AddressDenominationAssetRow struct {
	Address      types.AddressT
	Denomination types.DenominationT
	Asset        types.AssetT
}

type AddressDenominationAssetsReceiver 

type AddressDenominationAssetsReceiver struct {
	Rows []AddressDenominationAssetRow
}

func (*AddressDenominationAssetsReceiver) Scan 

func (rcvr *AddressDenominationAssetsReceiver) Scan(sqlRows *sql.Rows) error

type AddressRow 

type AddressRow struct{ Address types.AddressT }

type AddressesReceiver 

type AddressesReceiver struct {
	Rows []AddressRow
}

func (*AddressesReceiver) Scan 

func (rcvr *AddressesReceiver) Scan(sqlRows *sql.Rows) error

type BallRow 

type BallRow struct {
	Ball types.BallT
}

type BallsReceiver 

type BallsReceiver struct {
	Rows []BallRow
}

func (*BallsReceiver) Scan 

func (rcvr *BallsReceiver) Scan(sqlRows *sql.Rows) error

type BestParentUnitCountRow 

type BestParentUnitCountRow struct {
	Best_parent_unit types.UnitT
	Witnessed_level  types.LevelT
	Count            int
}

type BestParentUnitCountsReceiver 

type BestParentUnitCountsReceiver struct {
	Rows []BestParentUnitCountRow
}

func (*BestParentUnitCountsReceiver) Scan 

func (rcvr *BestParentUnitCountsReceiver) Scan(sqlRows *sql.Rows) error

type BestParentUnitRow 

type BestParentUnitRow struct {
	Best_parent_unit types.UnitT
	Witnessed_level  types.LevelT
}

type BestParentUnitsReceiver 

type BestParentUnitsReceiver struct {
	Rows []BestParentUnitRow
}

func (*BestParentUnitsReceiver) Scan 

func (rcvr *BestParentUnitsReceiver) Scan(sqlRows *sql.Rows) error

type CountOnStableMCRow 

type CountOnStableMCRow struct {
	Count              int
	Count_on_stable_mc int
}

type CountOnStableMCsReceiver 

type CountOnStableMCsReceiver struct {
	Rows []CountOnStableMCRow
}

func (*CountOnStableMCsReceiver) Scan 

func (rcvr *CountOnStableMCsReceiver) Scan(sqlRows *sql.Rows) error

type CountRow 

type CountRow struct{ Count int }

type CountsReceiver 

type CountsReceiver struct {
	Rows []CountRow
}

func (*CountsReceiver) Scan 

func (rcvr *CountsReceiver) Scan(sqlRows *sql.Rows) error

type DBConnPoolT 

type DBConnPoolT struct {
	// contains filtered or unexported fields
}

func (*DBConnPoolT) Get 

func (pool *DBConnPoolT) Get() refDBConnT

func (*DBConnPoolT) Put 

func (pool *DBConnPoolT) Put(item refDBConnT)

type DBConnT 

type DBConnT struct {
	// contains filtered or unexported fields
}

func (*DBConnT) AddQuery 

func (conn *DBConnT) AddQuery(sql DBSqlT, params DBParamsT)

func (*DBConnT) AddQueryCb 

func (conn *DBConnT) AddQueryCb(sql DBSqlT, params DBParamsT, cb DBQueryCbT)

func (*DBConnT) BeginTransaction 

func (conn *DBConnT) BeginTransaction()

func (*DBConnT) Commit 

func (conn *DBConnT) Commit()

func (*DBConnT) DropTemporaryTable 

func (conn *DBConnT) DropTemporaryTable(table string) string

func (*DBConnT) Exec 

func (conn *DBConnT) Exec(prep refDBPreparedT, params []interface{}) (error, *DBQueryResultT)

func (*DBConnT) ExecPrepared 

func (conn *DBConnT) ExecPrepared(prep refDBPreparedT, params []interface{}) (sql.Result, error)

func (*DBConnT) ExecuteAddedQuerys 

func (conn *DBConnT) ExecuteAddedQuerys() error

func (*DBConnT) ForceIndex 

func (conn *DBConnT) ForceIndex(index string) string

func (*DBConnT) GetFromUnixTime 

func (conn *DBConnT) GetFromUnixTime(ts string) string

func (*DBConnT) GetIgnore 

func (conn *DBConnT) GetIgnore() string

func (*DBConnT) MustExec 

func (conn *DBConnT) MustExec(sql DBSqlT, params DBParamsT) *DBQueryResultT

func (*DBConnT) MustQuery 

func (conn *DBConnT) MustQuery(sql DBSqlT, params DBParamsT, rcvr Receiver)

func (*DBConnT) Query 

func (conn *DBConnT) Query(prep refDBPreparedT, params []interface{}, rcvr Receiver) error

func (*DBConnT) QueryPrepared 

func (conn *DBConnT) QueryPrepared(prep refDBPreparedT, params []interface{}) (*sql.Rows, error)

func (*DBConnT) Release 

func (conn *DBConnT) Release()

func (*DBConnT) ResetAddedQueries 

func (conn *DBConnT) ResetAddedQueries()

func (*DBConnT) Rollback 

func (conn *DBConnT) Rollback()

func (*DBConnT) ShowPrepared 

func (conn *DBConnT) ShowPrepared()

type DBParamT 

type DBParamT = interface{}

DBParamT interface{}

type DBParamsT 

type DBParamsT []DBParamT

DBParamsT = []DBParamT

func (*DBParamsT) AddAddresses 

func (params *DBParamsT) AddAddresses(addresses types.AddressesT) DBSqlT

func (*DBParamsT) AddContributions 

func (params *DBParamsT) AddContributions(cbns types.ContributionsT) DBSqlT

func (*DBParamsT) AddFromIterator 

func (params *DBParamsT) AddFromIterator(iter AddFromIteratorT) DBSqlT

func (*DBParamsT) AddMCIndexes 

func (params *DBParamsT) AddMCIndexes(mcindexes types.MCIndexesT) DBSqlT

func (*DBParamsT) AddPaidWitnessEvents 

func (params *DBParamsT) AddPaidWitnessEvents(pwes types.PaidWitnessEventsT) DBSqlT

func (*DBParamsT) AddUnits 

func (params *DBParamsT) AddUnits(units types.UnitsT) DBSqlT

func (*DBParamsT) AddUnitsFromIterator 

func (params *DBParamsT) AddUnitsFromIterator(iter AddUnitIteratorT) DBSqlT

type DBPreparedByTagT 

type DBPreparedByTagT = map[DBPreparedTagT]refDBPreparedT

type DBPreparedT 

type DBPreparedT struct {
	Sql          string
	Tag          string
	Hash         uint16
	LengthTag    int
	LengthSql    int
	LengthParams int
	Count        int
	TotalTime    int64

	CoStmtCount     int
	CoStmtTime      int64
	CoStmtExecCount int
	// contains filtered or unexported fields
}

func (*DBPreparedT) Sample 

func (prep *DBPreparedT) Sample(t int64)

type DBPreparedTagT 

type DBPreparedTagT uint16

type DBQueryCbT 

type DBQueryCbT func(*DBQueryResultT)

type DBQueryResultT 

type DBQueryResultT struct {
	AffectedRows int64
}

func MustExec 

func MustExec(sql DBSqlT, params DBParamsT) *DBQueryResultT

type DBQueryT 

type DBQueryT struct {
	Sql    DBSqlT
	Params DBParamsT
	Cb     DBQueryCbT
}

type DBQuerysT 

type DBQuerysT = []DBQueryT

type DBRowT 

type DBRowT struct {
	Kv map[string]interface{}
}

type DBRowsReceiver 

type DBRowsReceiver struct {
	// contains filtered or unexported fields
}

func (*DBRowsReceiver) Scan 

func (rcvr *DBRowsReceiver) Scan(sqlRows *sql.Rows) error

type DBRowsT 

type DBRowsT = []DBRowT

DBRowT interface{}

type DBSqlT 

type DBSqlT = string

type Database 

type Database struct {
	// contains filtered or unexported fields
}

func Instance 

func Instance() *Database

func (*Database) Exec 

func (database *Database) Exec(sql string, params []interface{}) (error, *DBQueryResultT)

func (*Database) Select 

func (database *Database) Select(sql string, params []interface{}, rcvr Receiver) error

type LevelRow 

type LevelRow struct{ Level types.LevelT }

type LevelsReceiver 

type LevelsReceiver struct {
	Rows []LevelRow
}

func (*LevelsReceiver) Scan 

func (rcvr *LevelsReceiver) Scan(sqlRows *sql.Rows) error

type MCIOnMCRow 

type MCIOnMCRow struct {
	Main_chain_index types.MCIndexT
	Is_on_main_chain int
}

type MCIOnMCsReceiver 

type MCIOnMCsReceiver struct {
	Rows []MCIOnMCRow
}

func (*MCIOnMCsReceiver) Scan 

func (rcvr *MCIOnMCsReceiver) Scan(sqlRows *sql.Rows) error

type MaxAltLevelRow 

type MaxAltLevelRow struct{ Max_alt_level types.LevelT }

type MaxAltLevelsReceiver 

type MaxAltLevelsReceiver struct {
	Rows []MaxAltLevelRow
}

func (*MaxAltLevelsReceiver) Scan 

func (rcvr *MaxAltLevelsReceiver) Scan(sqlRows *sql.Rows) error

type MaxLevelRow 

type MaxLevelRow struct{ Max_level types.LevelT }

type MaxLevelsReceiver 

type MaxLevelsReceiver struct {
	Rows []MaxLevelRow
}

func (*MaxLevelsReceiver) Scan 

func (rcvr *MaxLevelsReceiver) Scan(sqlRows *sql.Rows) error

type MaxSpendableMCIRow 

type MaxSpendableMCIRow struct {
	Max_spendable_mci types.MCIndexT
}

type MaxSpendableMCIsReceiver 

type MaxSpendableMCIsReceiver struct {
	Rows []MaxSpendableMCIRow
}

func (*MaxSpendableMCIsReceiver) Scan 

func (rcvr *MaxSpendableMCIsReceiver) Scan(sqlRows *sql.Rows) error

type MinMCIndexRow 

type MinMCIndexRow struct {
	Min_main_chain_index types.MCIndexT
}

type MinMCIndexsReceiver 

type MinMCIndexsReceiver struct {
	Rows []MinMCIndexRow
}

func (*MinMCIndexsReceiver) Scan 

func (rcvr *MinMCIndexsReceiver) Scan(sqlRows *sql.Rows) error

type MinMCWLRow 

type MinMCWLRow struct{ Min_mc_wl types.LevelT }

type MinMCWLsReceiver 

type MinMCWLsReceiver struct {
	Rows []MinMCWLRow
}

func (*MinMCWLsReceiver) Scan 

func (rcvr *MinMCWLsReceiver) Scan(sqlRows *sql.Rows) error

type MinRetrievableMCIRow 

type MinRetrievableMCIRow struct {
	Min_retrievable_mci types.MCIndexT
}

type MinRetrievableMCIsReceiver 

type MinRetrievableMCIsReceiver struct {
	Rows []MinRetrievableMCIRow
}

func (*MinRetrievableMCIsReceiver) Scan 

func (rcvr *MinRetrievableMCIsReceiver) Scan(sqlRows *sql.Rows) error

type ParentChildUnitRow 

type ParentChildUnitRow struct {
	Parent_unit types.UnitT
	Child_unit  types.UnitT
}

type ParentChildUnitsReceiver 

type ParentChildUnitsReceiver struct {
	Rows []ParentChildUnitRow
}

func (*ParentChildUnitsReceiver) Scan 

func (rcvr *ParentChildUnitsReceiver) Scan(sqlRows *sql.Rows) error

type PaymentInfoRow 

type PaymentInfoRow struct {
	Child_unit         types.UnitT
	Headers_commission types.AmountT
	Next_mc_unit       types.UnitT
	Payer_unit         types.UnitT
}

type PaymentInfosReceiver 

type PaymentInfosReceiver struct {
	Rows []PaymentInfoRow
}

func (*PaymentInfosReceiver) Scan 

func (rcvr *PaymentInfosReceiver) Scan(sqlRows *sql.Rows) error

type PropsReceiver 

type PropsReceiver struct {
	Rows []types.PropsT
}

func (*PropsReceiver) Scan 

func (rcvr *PropsReceiver) Scan(sqlRows *sql.Rows) error

type RUPUnitPropsReceiver 

type RUPUnitPropsReceiver struct {
	Rows []UnitContentRow
}

func (*RUPUnitPropsReceiver) Scan 

func (rcvr *RUPUnitPropsReceiver) Scan(sqlRows *sql.Rows) error

type Receiver 

type Receiver interface {
	Scan(*sql.Rows) error
}

type UnitAddressRow 

type UnitAddressRow struct {
	Unit    types.UnitT
	Address types.AddressT
}

type UnitAddressesReceiver 

type UnitAddressesReceiver struct {
	Rows []UnitAddressRow
}

func (*UnitAddressesReceiver) Scan 

func (rcvr *UnitAddressesReceiver) Scan(sqlRows *sql.Rows) error

type UnitAuthorShareRow 

type UnitAuthorShareRow struct {
	Unit                            types.UnitT
	Address                         types.AddressT
	Earned_headers_commission_share types.ShareT
}

type UnitAuthorSharesReceiver 

type UnitAuthorSharesReceiver struct {
	Rows []UnitAuthorShareRow
}

func (*UnitAuthorSharesReceiver) Scan 

func (rcvr *UnitAuthorSharesReceiver) Scan(sqlRows *sql.Rows) error

type UnitBallRow 

type UnitBallRow struct {
	Unit types.UnitT
	Ball types.BallT
}

type UnitBallsReceiver 

type UnitBallsReceiver struct {
	Rows []UnitBallRow
}

func (*UnitBallsReceiver) Scan 

func (rcvr *UnitBallsReceiver) Scan(sqlRows *sql.Rows) error

type UnitContentBallRow 

type UnitContentBallRow = types.UnitPropsBallT

* 

type UnitContentBallRow struct{
	UnitContentRow
	Ball		types.BallT
}

*

type UnitContentBallsReceiver 

type UnitContentBallsReceiver struct {
	Rows []UnitContentBallRow
}

func (*UnitContentBallsReceiver) Scan 

func (rcvr *UnitContentBallsReceiver) Scan(sqlRows *sql.Rows) error

type UnitContentHashRow 

type UnitContentHashRow struct {
	Unit         types.UnitT
	Content_hash types.ContentHashT
}

type UnitContentHashsReceiver 

type UnitContentHashsReceiver struct {
	Rows []UnitContentHashRow
}

func (*UnitContentHashsReceiver) Scan 

func (rcvr *UnitContentHashsReceiver) Scan(sqlRows *sql.Rows) error

type UnitContentRow 

type UnitContentRow = types.UnitPropsT

* 

type UnitContentRow struct{
	Unit		types.UnitT
	types.PropsT
}

*

type UnitContentsReceiver 

type UnitContentsReceiver struct {
	Rows []UnitContentRow
}

func (*UnitContentsReceiver) Scan 

func (rcvr *UnitContentsReceiver) Scan(sqlRows *sql.Rows) error

type UnitIsFreesReceiver 

type UnitIsFreesReceiver struct {
	Rows []UnitPropsRow
}

func (*UnitIsFreesReceiver) Scan 

func (rcvr *UnitIsFreesReceiver) Scan(sqlRows *sql.Rows) error

type UnitLIMCIRow 

type UnitLIMCIRow struct {
	Unit                     types.UnitT
	Latest_included_mc_index types.MCIndexT
}

type UnitLIMCIsReceiver 

type UnitLIMCIsReceiver struct {
	Rows []UnitLIMCIRow
}

func (*UnitLIMCIsReceiver) Scan 

func (rcvr *UnitLIMCIsReceiver) Scan(sqlRows *sql.Rows) error

type UnitMCIRow 

type UnitMCIRow struct {
	Unit             types.UnitT
	Main_chain_index types.MCIndexT
}

type UnitMCISequenceAddressRow 

type UnitMCISequenceAddressRow struct {
	Unit             types.UnitT
	Main_chain_index types.MCIndexT
	Good             bool
	Address          types.AddressT
	X_skip           bool
}

type UnitMCISequenceAddressesReceiver 

type UnitMCISequenceAddressesReceiver struct {
	Rows []UnitMCISequenceAddressRow
}

func (*UnitMCISequenceAddressesReceiver) Scan 

func (rcvr *UnitMCISequenceAddressesReceiver) Scan(sqlRows *sql.Rows) error

type UnitMCIsReceiver 

type UnitMCIsReceiver struct {
	Rows []UnitMCIRow
}

func (*UnitMCIsReceiver) Scan 

func (rcvr *UnitMCIsReceiver) Scan(sqlRows *sql.Rows) error

type UnitMCPropsReceiver 

type UnitMCPropsReceiver struct {
	Rows []UnitMCPropsRow
}

func (*UnitMCPropsReceiver) Scan 

func (rcvr *UnitMCPropsReceiver) Scan(sqlRows *sql.Rows) error

type UnitMCPropsRow 

type UnitMCPropsRow struct {
	Unit                     types.UnitT
	Level                    types.LevelT
	Latest_included_mc_index types.MCIndexT
	Main_chain_index         types.MCIndexT
	Is_on_main_chain         int
}

type UnitPropsReceiver 

type UnitPropsReceiver struct {
	Rows []UnitPropsRow
}

func (*UnitPropsReceiver) Scan 

func (rcvr *UnitPropsReceiver) Scan(sqlRows *sql.Rows) error

type UnitPropsRow 

type UnitPropsRow struct {
	Unit             types.UnitT
	Is_on_main_chain int
	Main_chain_index types.MCIndexT
	Level            types.LevelT
	Is_free          int
}

type UnitRow 

type UnitRow struct{ Unit types.UnitT }

type UnitsReceiver 

type UnitsReceiver struct {
	Rows []UnitRow
}

func (*UnitsReceiver) Scan 

func (rcvr *UnitsReceiver) Scan(sqlRows *sql.Rows) error

type WitnessListUnitAndUnitRow 

type WitnessListUnitAndUnitRow struct {
	Witness_list_unit types.UnitT
	Unit              types.UnitT
}

type WitnessListUnitAndUnitsReceiver 

type WitnessListUnitAndUnitsReceiver struct {
	Rows []WitnessListUnitAndUnitRow
}

func (*WitnessListUnitAndUnitsReceiver) Scan 

func (rcvr *WitnessListUnitAndUnitsReceiver) Scan(sqlRows *sql.Rows) error

type WitnessListUnitRow 

type WitnessListUnitRow struct {
	Witness_list_unit types.UnitT
}

type WitnessListUnitsReceiver 

type WitnessListUnitsReceiver struct {
	Rows []WitnessListUnitRow
}

func (*WitnessListUnitsReceiver) Scan 

func (rcvr *WitnessListUnitsReceiver) Scan(sqlRows *sql.Rows) error

type WitnessedLevelRow 

type WitnessedLevelRow struct{ Witnessed_level types.LevelT }

type WitnessedLevelsReceiver 

type WitnessedLevelsReceiver struct {
	Rows []WitnessedLevelRow
}

func (*WitnessedLevelsReceiver) Scan 

func (rcvr *WitnessedLevelsReceiver) Scan(sqlRows *sql.Rows) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.