db

Documentation

Index

• Constants
• type Column
• type DB
• type DBSQL
  • func NewSQLDB(cfg *config.Config) (*DBSQL, error)
  • func (s *DBSQL) BatchCreate(table TableName, cols []Column, vals [][]interface{}) error
  • func (s *DBSQL) Close() error
  • func (s *DBSQL) Count(table TableName, dest interface{}) error
  • func (s *DBSQL) Create(table TableName, condition map[Column]interface{}) error
  • func (s *DBSQL) Delete(table TableName, condition map[Column]interface{}) error
  • func (s *DBSQL) Group(table TableName, column Column, dest interface{}) error
  • func (s *DBSQL) NewTransaction() *sqlx.Tx
  • func (s *DBSQL) Read(table TableName, condition map[Column]interface{}, offset int, limit int, ...) error
  • func (s *DBSQL) Update(table TableName, condition map[Column]interface{}) error
• type DbStore
• type TableName

Constants

const LikeSign = "_like_"

Types

type Column

type Column string

const (
	ColumnHash      Column = "hash"
	ColumnType      Column = "type"
	ColumnAddress   Column = "address"
	ColumnSender    Column = "sender"
	ColumnReceiver  Column = "receiver"
	ColumnMessage   Column = "message"
	ColumnTimestamp Column = "timestamp"
)

type DB

type DB interface {
	Create()
}

type DBSQL

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

func NewSQLDB

func NewSQLDB(cfg *config.Config) (*DBSQL, error)

func (*DBSQL) BatchCreate

func (s *DBSQL) BatchCreate(table TableName, cols []Column, vals [][]interface{}) error

func (*DBSQL) Close

func (s *DBSQL) Close() error

func (*DBSQL) Count

func (s *DBSQL) Count(table TableName, dest interface{}) error

func (*DBSQL) Create

func (s *DBSQL) Create(table TableName, condition map[Column]interface{}) error

func (*DBSQL) Delete

func (s *DBSQL) Delete(table TableName, condition map[Column]interface{}) error

func (*DBSQL) Group

func (s *DBSQL) Group(table TableName, column Column, dest interface{}) error

func (*DBSQL) NewTransaction

func (s *DBSQL) NewTransaction() *sqlx.Tx

func (*DBSQL) Read

func (s *DBSQL) Read(table TableName, condition map[Column]interface{}, offset int, limit int, order map[Column]bool, dest interface{}) error

func (*DBSQL) Update

func (s *DBSQL) Update(table TableName, condition map[Column]interface{}) error

type DbStore

type DbStore interface {
	io.Closer
	NewTransaction() *sqlx.Tx
	Create(table TableName, condition map[Column]interface{}) error
	BatchCreate(table TableName, cols []Column, vals [][]interface{}) error
	Read(table TableName, condition map[Column]interface{}, offset int, limit int, order map[Column]bool, dest interface{}) error
	Update(table TableName, condition map[Column]interface{}) error
	Delete(table TableName, condition map[Column]interface{}) error
	Count(table TableName, dest interface{}) error
	Group(table TableName, column Column, dest interface{}) error
}

type TableName

type TableName string

const (
	TableBlockHash    TableName = "blockhash"
	TableBlockMessage TableName = "blockmessage"
)