mysqlPersistentStorage

Documentation

Index

• func NewMySQLDb(updateStampGetter UpdateStampGetter, credentials credentials.CredentialsGetter, ...) PersistentStorage
• func NewMySQLDbNoExtraDeps(credentials credentials.CredentialsGetter, config configuration.Config) PersistentStorage
• type MySQLDb
  • func (repo MySQLDb) Delete(c context.Context, model interface{}, params interface{}) error
  • func (repo MySQLDb) Exec(c context.Context, queryGetter QueryGetter, params map[string]interface{}) error
  • func (repo MySQLDb) GetMany(c context.Context, target interface{}, params interface{}) error
  • func (repo MySQLDb) GetOne(c context.Context, target interface{}, params interface{}) error
  • func (repo MySQLDb) Insert(c context.Context, target interface{}) error
  • func (repo MySQLDb) IsRecordNotFoundError(err error) bool
  • func (repo MySQLDb) QueryInt(c context.Context, query QueryGetter, params map[string]interface{}) (int64, error)
  • func (repo MySQLDb) QueryMany(c context.Context, target QueryGetter, params map[string]interface{}) error
  • func (repo MySQLDb) QueryOne(c context.Context, target QueryGetter, params map[string]interface{}) error
  • func (repo MySQLDb) QueryString(c context.Context, query QueryGetter, params map[string]interface{}) (string, error)
  • func (repo MySQLDb) Update(c context.Context, update interface{}, query interface{}) error

Functions

func NewMySQLDb

func NewMySQLDb(updateStampGetter UpdateStampGetter, credentials credentials.CredentialsGetter,
	config configuration.Config, ctxResolver contextData.ContextDataResolver) PersistentStorage

func NewMySQLDbNoExtraDeps

func NewMySQLDbNoExtraDeps(credentials credentials.CredentialsGetter,
	config configuration.Config) PersistentStorage

Types

type MySQLDb

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

func (MySQLDb) Delete

func (repo MySQLDb) Delete(c context.Context, model interface{}, params interface{}) error

func (MySQLDb) Exec

func (repo MySQLDb) Exec(c context.Context, queryGetter QueryGetter, params map[string]interface{}) error

func (MySQLDb) GetMany

func (repo MySQLDb) GetMany(c context.Context, target interface{}, params interface{}) error

func (MySQLDb) GetOne

func (repo MySQLDb) GetOne(c context.Context, target interface{}, params interface{}) error

func (MySQLDb) Insert

func (repo MySQLDb) Insert(c context.Context, target interface{}) error

func (MySQLDb) IsRecordNotFoundError

func (repo MySQLDb) IsRecordNotFoundError(err error) bool

func (MySQLDb) QueryInt

func (repo MySQLDb) QueryInt(c context.Context, query QueryGetter, params map[string]interface{}) (int64, error)

func (MySQLDb) QueryMany

func (repo MySQLDb) QueryMany(c context.Context, target QueryGetter, params map[string]interface{}) error

func (MySQLDb) QueryOne

func (repo MySQLDb) QueryOne(c context.Context, target QueryGetter, params map[string]interface{}) error

func (MySQLDb) QueryString

func (repo MySQLDb) QueryString(c context.Context, query QueryGetter, params map[string]interface{}) (string, error)

func (MySQLDb) Update

func (repo MySQLDb) Update(c context.Context, update interface{}, query interface{}) error