dbquery

Documentation

Index

• type QueryParsed
  • func (qp QueryParsed) GetKeyValue() string
  • func (qp QueryParsed) IsSelect() bool
  • func (qp QueryParsed) IsUpdate() bool
  • func (qp QueryParsed) IsUpdateOther() bool
  • func (qp QueryParsed) ReferenceID() string
• type QueryProcessorInterface
  • func NewQueryProcessor(DB database.DBManager, Logger *utils.LoggerMan) QueryProcessorInterface
• type SQLUpdateInterface
  • func NewSQLUpdateManager(SQLUpdate structures.SQLUpdate) (SQLUpdateInterface, error)

Types

type QueryParsed

type QueryParsed struct {
	SQL              string
	PubKey           []byte
	Signature        []byte
	TransactionBytes []byte
	KeyCol           string
	KeyVal           string
	RowBeforeQuery   map[string]string
	RowDoesNotExist  bool
	Structure        sqlparser.SQLQueryParserInterface
}

func (QueryParsed) GetKeyValue

func (qp QueryParsed) GetKeyValue() string

func (QueryParsed) IsSelect

func (qp QueryParsed) IsSelect() bool

Info about a parsed query. Check if is select

func (QueryParsed) IsUpdate

func (qp QueryParsed) IsUpdate() bool

Info about a parsed query. Check if is update (insert, update, delete, create table, drop table)

func (QueryParsed) IsUpdateOther

func (qp QueryParsed) IsUpdateOther() bool

func (QueryParsed) ReferenceID

func (qp QueryParsed) ReferenceID() string

type QueryProcessorInterface

type QueryProcessorInterface interface {
	ParseQuery(sqlquery string, flags int) (QueryParsed, error)
	ExecuteQuery(sql string) (*structures.SQLUpdate, error)
	ExecuteParsedQuery(qp QueryParsed) (*structures.SQLUpdate, error)
	ExecuteQueryFromTX(sql structures.SQLUpdate) error
	ExecuteRollbackQueryFromTX(sql structures.SQLUpdate) error
	MakeSQLUpdateStructure(parsed QueryParsed) (structures.SQLUpdate, error)
}

func NewQueryProcessor

func NewQueryProcessor(DB database.DBManager, Logger *utils.LoggerMan) QueryProcessorInterface

type SQLUpdateInterface

type SQLUpdateInterface interface {
	CheckUpdateCanFollow(sqlUpdPrev *structures.SQLUpdate) error
	CheckAllowsMultipleSubtransactions(sqlUpdPrev *structures.SQLUpdate) (bool, error)
	GetAlternativeRefID() ([]byte, bool, error)
	RequiresBaseTransation() bool
}

func NewSQLUpdateManager

func NewSQLUpdateManager(SQLUpdate structures.SQLUpdate) (SQLUpdateInterface, error)