sqlutil

Documentation

Index

• func BuildPushQuery(params PushQueryParams, queryTemplate string) (string, error)
• func CreateTable(ctx context.Context, dbOpt dbutil.DBOpt, opt online.CreateTableOpt) error
• func Get(ctx context.Context, db *sqlx.DB, opt online.GetOpt, backend types.BackendType) (dbutil.RowMap, error)
• func Import(ctx context.Context, db *sqlx.DB, opt online.ImportOpt, ...) error
• func MultiGet(ctx context.Context, db *sqlx.DB, opt online.MultiGetOpt, ...) (map[string]dbutil.RowMap, error)
• func Purge(ctx context.Context, db *sqlx.DB, revisionID int, backend types.BackendType) error
• func PurgeTx(ctx context.Context, tx *sqlx.Tx, tableName string, backend types.BackendType) error
• type PushQueryParams
  • func BuildPushQueryParams(opt online.PushOpt, backend types.BackendType) PushQueryParams

Functions

func BuildPushQuery

func BuildPushQuery(params PushQueryParams, queryTemplate string) (string, error)

func CreateTable

func CreateTable(ctx context.Context, dbOpt dbutil.DBOpt, opt online.CreateTableOpt) error

func Get

func Get(ctx context.Context, db *sqlx.DB, opt online.GetOpt, backend types.BackendType) (dbutil.RowMap, error)

func Import

func Import(ctx context.Context, db *sqlx.DB, opt online.ImportOpt, backend types.BackendType) error

func MultiGet

func MultiGet(ctx context.Context, db *sqlx.DB, opt online.MultiGetOpt, backend types.BackendType) (map[string]dbutil.RowMap, error)

response: map[entity_key]map[feature_name]feature_value

func Purge

func Purge(ctx context.Context, db *sqlx.DB, revisionID int, backend types.BackendType) error

func PurgeTx

func PurgeTx(ctx context.Context, tx *sqlx.Tx, tableName string, backend types.BackendType) error

Types

type PushQueryParams

type PushQueryParams struct {
	TableName          string
	EntityName         string
	Fields             string
	InsertPlaceholders string
	UpdatePlaceholders string
	InsertValues       []interface{}
	UpdateValues       []interface{}
	Backend            types.BackendType
}

func BuildPushQueryParams

func BuildPushQueryParams(opt online.PushOpt, backend types.BackendType) PushQueryParams