sqlutil

Documentation

Index

• func CreateStreamTableSchema(ctx context.Context, tableName string, entity *types.Entity, ...) (string, 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 OnlineBatchTableName(revisionID int) string
• func OnlineStreamTableName(groupID int) string
• func Purge(ctx context.Context, db *sqlx.DB, revisionID int, backend types.BackendType) error
• func SqlxPrapareStreamTable(ctx context.Context, db *sqlx.DB, opt online.PrepareStreamTableOpt, ...) error
• type PushCondition
  • func BuildPushCondition(opt online.PushOpt, backend types.BackendType) *PushCondition

Functions

func CreateStreamTableSchema

func CreateStreamTableSchema(ctx context.Context, tableName string, entity *types.Entity, backend types.BackendType) (string, 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 OnlineBatchTableName

func OnlineBatchTableName(revisionID int) string

func OnlineStreamTableName

func OnlineStreamTableName(groupID int) string

func Purge

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

func SqlxPrapareStreamTable

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

Types

type PushCondition

type PushCondition struct {
	Inserts            string
	InsertPlaceholders string
	InsertValues       []interface{}
	UpdateValues       []interface{}
	UpdatePlaceholders string
}

func BuildPushCondition

func BuildPushCondition(opt online.PushOpt, backend types.BackendType) *PushCondition