database

Documentation

Index

• Constants
• func NewPostgresDB(psqlconn string) *sql.DB
• type DBType
• type Database
  • func New(DatabaseType DBType, params ...string) *Database
  • func (db *Database) BatchInsert(table string, bulkFields ...RowType) (ExecResult, error)
  • func (db *Database) Close()
  • func (db *Database) Delete(table string, conditions RowType) (ExecResult, error)
  • func (db *Database) Exec(query string, params QueryParams) (ExecResult, error)
  • func (db *Database) Insert(table string, fields RowType) (ExecResult, error)
  • func (db *Database) IsErrDuplicate(err error) bool
  • func (db *Database) IsErrNotFound(err error) bool
  • func (db *Database) Load(table string, searchOnFields RowType) (QueryResult, error)
  • func (db *Database) PostgresBatchInsert(table string, fieldNames []string, bulkFields [][]interface{}) (ExecResult, error)
  • func (db *Database) PostgresClose()
  • func (db *Database) PostgresDelete(table string, conditions RowType) (ExecResult, error)
  • func (db *Database) PostgresExec(query string, params ...interface{}) (ExecResult, error)
  • func (db *Database) PostgresInit() error
  • func (db *Database) PostgresInsert(table string, fields RowType) (ExecResult, error)
  • func (db *Database) PostgresLoad(table string, searchOnFields RowType) (QueryResult, error)
  • func (db *Database) PostgresQuery(query string, params QueryParams) (QueryResult, error)
  • func (db *Database) PostgresUpdate(table string, fields RowType, conditions RowType) (ExecResult, error)
  • func (db *Database) Query(query string, params QueryParams) (QueryResult, error)
  • func (db *Database) Update(table string, fields RowType, conditions RowType) (ExecResult, error)
• type ExecResult
• type InsertQueue
  • func NewInsertQueue(db *Database) *InsertQueue
  • func (i *InsertQueue) Add(table string, row ...RowType)
  • func (i *InsertQueue) GetQueueLen() int
  • func (i *InsertQueue) Start() error
  • func (i *InsertQueue) Stop()
• type InsertQueueItem
• type QueryParams
• type QueryResult
• type RowType

Constants

const (
	FIELD_TX_EVENTS_TX_HASH      = "txHash"
	FIELD_TX_EVENTS_HEIGHT       = "height"
	FIELD_TX_EVENTS_MODULE       = "module"
	FIELD_TX_EVENTS_SENDER       = "sender"
	FIELD_TX_EVENTS_RECEIVER     = "receiver"
	FIELD_TX_EVENTS_VALIDATOR    = "validator"
	FIELD_TX_EVENTS_ACTION       = "action"
	FIELD_TX_EVENTS_AMOUNT       = "amount"
	FIELD_TX_EVENTS_TX_ACCSEQ    = "txAccSeq"
	FIELD_TX_EVENTS_TX_SIGNATURE = "txSignature"
	FIELD_TX_EVENTS_PROPOSAL_ID  = "proposalId"
	FIELD_TX_EVENTS_TX_MEMO      = "txMemo"
	FIELD_TX_EVENTS_JSON         = "json"
	FIELD_TX_EVENTS_LOG_TIME     = "logTime"
)

const (
	FIELD_BLOCKS_BLOCK_HASH = "blockHash"
	FIELD_BLOCKS_HEIGHT     = "height"
	FIELD_BLOCKS_NUM_OF_TXS = "numOfTxs"
	FIELD_BLOCKS_TIME       = "time"
)

const (
	FIELD_BLOCK_SIGNERS_BLOCK_HEIGHT  = "blockHeight"
	FIELD_BLOCK_SIGNERS_VAL_CONS_ADDR = "valConsAddr"
	FIELD_BLOCK_SIGNERS_TIME          = "time"
	FIELD_BLOCK_SIGNERS_SIGNATURE     = "signature"
)

const (
	FIELD_VALIDATORS_CONS_ADDR    = "consAddr"
	FIELD_VALIDATORS_OPR_ADDR     = "oprAddr"
	FIELD_VALIDATORS_ACCOUNT_ADDR = "accountAddr"
	FIELD_VALIDATORS_MONIKER      = "moniker"
)

const (
	FIELD_PARTICIPANTS_EMAIL_ADDRESS   = "emailAddress"
	FIELD_PARTICIPANTS_FULL_LEGAL_NAME = "fullLegalName"
	FIELD_PARTICIPANTS_COUNTRY         = "country"
	FIELD_PARTICIPANTS_ACCOUNT_ADDRESS = "accountAddress"
	FIELD_PARTICIPANTS_GITHUB_HANDLE   = "githubHandle"
	FIELD_PARTICIPANTS_PUBKEY          = "pubkey"
	FIELD_PARTICIPANTS_KYC_SESSION_ID  = "kycSessionId"
	FIELD_PARTICIPANTS_KYC_VERIFIED    = "kycVerified"
)

const (
	FIELD_CONTRACTS_CONTRACT_ADDRESS           = "contractAddress"
	FIELD_CONTRACTS_REWARD_ADDRESS             = "rewardAddress"
	FIELD_CONTRACTS_DEVELOPER_ADDRESS          = "developerAddress"
	FIELD_CONTRACTS_BLOCK_HEIGHT               = "blockHeight"
	FIELD_CONTRACTS_GAS_CONSUMED_STR           = "gasConsumedStr" //Let's keep it for the moment, just to verify if the number is big enough
	FIELD_CONTRACTS_GAS_CONSUMED               = "gasConsumed"
	FIELD_CONTRACTS_REWARDS_DENOM              = "rewardsDenom"
	FIELD_CONTRACTS_CONTRACT_REWARDS_AMOUNT    = "contractRewardsAmount"
	FIELD_CONTRACTS_INFLATION_REWARDS_AMOUNT   = "inflationRewardsAmount"
	FIELD_CONTRACTS_LEFTOVER_REWARDS_AMOUNT    = "leftoverRewardsAmount"
	FIELD_CONTRACTS_COLLECT_PREMIUM            = "collectPremium"
	FIELD_CONTRACTS_GAS_REBATE_TO_USER         = "gasRebateToUser"
	FIELD_CONTRACTS_PREMIUM_PERCENTAGE_CHARGED = "premiumPercentageCharged"
	FIELD_CONTRACTS_METADATA_JSON              = "metadataJson"
	FIELD_CONTRACTS_INC_ID                     = "incId"
)

const TABLE_BLOCKS = "blocks"

const TABLE_BLOCK_SIGNERS = "block_signers"

const TABLE_CONTRACTS = "contracts"

const TABLE_PARTICIPANTS = "participants"

const TABLE_TX_EVENTS = "tx_events"

const TABLE_VALIDATORS = "validators"

Functions

func NewPostgresDB

func NewPostgresDB(psqlconn string) *sql.DB

Types

type DBType

type DBType int

const (
	Postgres DBType = iota
)

type Database

type Database struct {
	Type    DBType // influx, mysql, sqlite,...
	SQLConn *sql.DB
}

var DB *Database

func New

func New(DatabaseType DBType, params ...string) *Database

func (*Database) BatchInsert

func (db *Database) BatchInsert(table string, bulkFields ...RowType) (ExecResult, error)

func (*Database) Close

func (db *Database) Close()

func (*Database) Delete

func (db *Database) Delete(table string, conditions RowType) (ExecResult, error)

func (*Database) Exec

func (db *Database) Exec(query string, params QueryParams) (ExecResult, error)

func (*Database) Insert

func (db *Database) Insert(table string, fields RowType) (ExecResult, error)

func (*Database) IsErrDuplicate

func (db *Database) IsErrDuplicate(err error) bool

func (*Database) IsErrNotFound

func (db *Database) IsErrNotFound(err error) bool

func (*Database) Load

func (db *Database) Load(table string, searchOnFields RowType) (QueryResult, error)

func (*Database) PostgresBatchInsert

func (db *Database) PostgresBatchInsert(table string, fieldNames []string, bulkFields [][]interface{}) (ExecResult, error)

func (*Database) PostgresClose

func (db *Database) PostgresClose()

func (*Database) PostgresDelete

func (db *Database) PostgresDelete(table string, conditions RowType) (ExecResult, error)

func (*Database) PostgresExec

func (db *Database) PostgresExec(query string, params ...interface{}) (ExecResult, error)

func (*Database) PostgresInit

func (db *Database) PostgresInit() error

func (*Database) PostgresInsert

func (db *Database) PostgresInsert(table string, fields RowType) (ExecResult, error)

func (*Database) PostgresLoad

func (db *Database) PostgresLoad(table string, searchOnFields RowType) (QueryResult, error)

func (*Database) PostgresQuery

func (db *Database) PostgresQuery(query string, params QueryParams) (QueryResult, error)

func (*Database) PostgresUpdate

func (db *Database) PostgresUpdate(table string, fields RowType, conditions RowType) (ExecResult, error)

func (*Database) Query

func (db *Database) Query(query string, params QueryParams) (QueryResult, error)

func (*Database) Update

func (db *Database) Update(table string, fields RowType, conditions RowType) (ExecResult, error)

type ExecResult

type ExecResult struct {
	RowsAffected int64
	LastInsertId int64
}

type InsertQueue

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

func NewInsertQueue

func NewInsertQueue(db *Database) *InsertQueue

func (*InsertQueue) Add

func (i *InsertQueue) Add(table string, row ...RowType)

func (*InsertQueue) GetQueueLen

func (i *InsertQueue) GetQueueLen() int

func (*InsertQueue) Start

func (i *InsertQueue) Start() error

func (*InsertQueue) Stop

func (i *InsertQueue) Stop()

type InsertQueueItem

type InsertQueueItem struct {
	Table string
	Rows  []RowType
	DB    *Database
}

type QueryParams

type QueryParams []interface{}

type QueryResult

type QueryResult []RowType

type RowType

type RowType map[string]interface{}