sql

Documentation

Index

• func ParseSQLRows(rows *sql.Rows, schema interface{}) ([]interface{}, error)
• func TestStorePutGet(sqlStore Store, t *testing.T)
• func TestStoreTransaction(sqlStore Store, t *testing.T)
• type ActionHistory
• type Store
  • func NewAwsRDS(cfg config.RDS) Store
  • func NewMySQL(connectStr string, dbName string) Store

Functions

func ParseSQLRows

func ParseSQLRows(rows *sql.Rows, schema interface{}) ([]interface{}, error)

ParseSQLRows will parse the row

func TestStorePutGet

func TestStorePutGet(sqlStore Store, t *testing.T)

TestStorePutGet define the common test cases for put and get

func TestStoreTransaction

func TestStoreTransaction(sqlStore Store, t *testing.T)

TestStoreTransaction define the common test cases for transaction

Types

type ActionHistory

type ActionHistory struct {
	NodeAddress string
	UserAddress string
	ActionHash  string
}

ActionHistory define the schema for action history

type Store

type Store interface {
	lifecycle.StartStopper

	// Get DB instance
	GetDB() *sql.DB

	// Transact wrap the transaction
	Transact(txFunc func(*sql.Tx) error) (err error)
}

Store is the interface of KV store.

func NewAwsRDS

func NewAwsRDS(cfg config.RDS) Store

NewAwsRDS instantiates an aws rds

func NewMySQL

func NewMySQL(connectStr string, dbName string) Store

NewMySQL instantiates a mysql