client

package
v1.10.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 6, 2024 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ColumnCreateUserID added in v1.6.1 

func ColumnCreateUserID(tableRow *TableRow) string

func ColumnCreatedTime added in v1.6.1 

func ColumnCreatedTime(tableRow *TableRow) time.Time

func ColumnLastEventTime added in v1.6.1 

func ColumnLastEventTime(tableRow *TableRow) time.Time

func ColumnLastUpdateUserID added in v1.6.1 

func ColumnLastUpdateUserID(tableRow *TableRow) string

func FormatColumnCreatedTime added in v1.6.1 

func FormatColumnCreatedTime(tableRow *TableRow, format string) string

func FormatColumnLastEventTime added in v1.6.1 

func FormatColumnLastEventTime(tableRow *TableRow, format string) string

func IsErrorDBRecordHasExist 

func IsErrorDBRecordHasExist(err error) bool

func IsErrorDBRecordNotExist 

func IsErrorDBRecordNotExist(err error) bool

Types

type AutoMigrateItem 

type AutoMigrateItem struct {
	TablePrefixWithSchema string
	Version               string
	TableModelDescribe    map[string]string
	NoEvent               bool
}

type AutoMigrateRequest 

type AutoMigrateRequest struct {
	Items []AutoMigrateItem
}

type Clause added in v1.6.0 

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

func NewClause added in v1.6.0 

func NewClause() *Clause

func (*Clause) Common added in v1.6.0 

func (clause *Clause) Common(query string, args ...any) *Clause

func (*Clause) Equal added in v1.6.0 

func (clause *Clause) Equal(columnName string, value any) *Clause

func (*Clause) GreaterThan added in v1.6.0 

func (clause *Clause) GreaterThan(columnName string, value any) *Clause

func (*Clause) GreaterThanAndEqual added in v1.6.0 

func (clause *Clause) GreaterThanAndEqual(columnName string, value any) *Clause

func (*Clause) In added in v1.6.0 

func (clause *Clause) In(columnName string, value any) *Clause

func (*Clause) LessThan added in v1.6.0 

func (clause *Clause) LessThan(columnName string, value any) *Clause

func (*Clause) LessThanAndEqual added in v1.6.0 

func (clause *Clause) LessThanAndEqual(columnName string, value any) *Clause

func (*Clause) Like added in v1.6.0 

func (clause *Clause) Like(columnName string, value any) *Clause

func (*Clause) Not added in v1.6.0 

func (clause *Clause) Not(columnName string, value any) *Clause

func (*Clause) NotIn added in v1.6.0 

func (clause *Clause) NotIn(columnName string, value any) *Clause

func (*Clause) ToJson added in v1.6.0 

func (clause *Clause) ToJson() ([]byte, error)

type Client 

type Client interface {
	AutoMigrate(request *AutoMigrateRequest) error
	Transaction(txFunc TransactionFunc) error
	Insert(request *InsertRequest) (string, error)
	InsertBatch(request *InsertBatchRequest) (string, error)
	Delete(request *DeleteRequest) (string, error)
	DeleteWhere(request *DeleteWhereRequest) (string, error)
	Update(request *UpdateRequest) (string, error)
	UpdateWhere(request *UpdateWhereRequest) (string, error)
	Replay(request *ReplayRequest) (string, error)
	QueryByWhereAndOrderBy(request *QueryByWhereAndOrderByRequest) (string, []TableRow, int64, error)
	CommonQuery(request *CommonQueryRequest) (string, []TableRow, int64, error)
	QueryOnlyByWhereAndOrderBy(request *QueryByWhereAndOrderByRequest) (string, []TableRow, error)
	CommonQueryOnly(request *CommonQueryRequest) (string, []TableRow, error)
	QueryByKeys(request *QueryByKeysRequest) (string, *TableRow, error)
	CountWhere(request *CountWhereRequest) (string, int64, error)
	CommonCount(request *CommonCountRequest) (string, int64, error)
	EventQueryByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, int64, error)
	CommonEventQuery(request *CommonEventQueryRequest) (string, []EventInfo, int64, error)
	EventQueryOnlyByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, error)
	CommonEventQueryOnly(request *CommonEventQueryRequest) (string, []EventInfo, error)
	CountEventByKeys(request *CountEventByKeysRequest) (string, int64, error)
	CommonCountEvent(request *CommonCountEventRequest) (string, int64, error)
	EventHistoryQueryByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, int64, error)
	CommonEventHistoryQuery(request *CommonEventQueryRequest) (string, []EventInfo, int64, error)
	EventHistoryQueryOnlyByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, error)
	CommonEventHistoryQueryOnly(request *CommonEventQueryRequest) (string, []EventInfo, error)
	CountEventHistoryByKeys(request *CountEventByKeysRequest) (string, int64, error)
	CommonCountEventHistory(request *CommonCountEventRequest) (string, int64, error)
}

type CommonCountEventRequest 

type CommonCountEventRequest struct {
	TablePrefixWithSchema string
	KeyValues             []string
	Version               string
	Operation             string
	CreatorID             string
	StartCreatedTime      string
	EndCreatedTime        string
}

type CommonCountRequest 

type CommonCountRequest struct {
	TablePrefixWithSchema string
	Table                 string
	Version               string
	Where                 *Clause
	Or                    *Clause
	GroupBy               string
	Joins                 *Clause
	Having                *Clause
}

type CommonEventQueryRequest 

type CommonEventQueryRequest struct {
	TablePrefixWithSchema string
	Select                *Clause
	KeyValues             []string
	Version               string
	Operation             string
	CreatorID             string
	StartCreatedTime      string
	EndCreatedTime        string
	PageNo                int
	PageSize              int
}

type CommonQueryRequest 

type CommonQueryRequest struct {
	TablePrefixWithSchema string
	Table                 string
	Version               string
	Select                *Clause
	Where                 *Clause
	OrderBy               string
	Or                    *Clause
	GroupBy               string
	Joins                 *Clause
	Having                *Clause
	PageNo                int
	PageSize              int
}

type CountEventByKeysRequest 

type CountEventByKeysRequest struct {
	TablePrefixWithSchema string
	KeyValues             []string
}

type CountWhereRequest 

type CountWhereRequest struct {
	TablePrefixWithSchema string
	Table                 string
	Version               string
	Where                 *Clause
}

type DeleteRequest 

type DeleteRequest struct {
	TablePrefixWithSchema string
	Version               string
	KeyValues             *KeyValue
	UserID                string
}

type DeleteWhereRequest added in v1.6.6 

type DeleteWhereRequest struct {
	TablePrefixWithSchema string
	Version               string
	KeyColumns            []string
	Where                 *Clause
	UserID                string
}

type EventInfo 

type EventInfo struct {
	Key        string
	Version    string
	Operation  string
	Value      string
	CreatorID  string
	CreateTime time.Time
}

func FormEventInfo 

func FormEventInfo(info *response.EventInfo) *EventInfo

func FormEventInfoBatch 

func FormEventInfoBatch(infos []*response.EventInfo) []EventInfo

type EventQueryByKeysRequest 

type EventQueryByKeysRequest struct {
	TablePrefixWithSchema string
	Select                *Clause
	KeyValues             []string
	PageNo                int
	PageSize              int
}

type InsertBatchRequest 

type InsertBatchRequest struct {
	Items  []InsertTableRowItem
	UserID string
}

type InsertRequest 

type InsertRequest struct {
	TablePrefixWithSchema string
	Version               string
	KeyColumns            []string
	TableRow              *TableRow
	UserID                string
}

type InsertTableRowItem 

type InsertTableRowItem struct {
	TablePrefixWithSchema string
	Version               string
	KeyColumns            []string
	TableRows             []*TableRow
}

type KeyValue added in v1.8.0 

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

func NewKeyValue added in v1.8.0 

func NewKeyValue() *KeyValue

func (*KeyValue) Add added in v1.8.0 

func (keyValue *KeyValue) Add(column string, value string) *KeyValue

func (*KeyValue) Columns added in v1.8.0 

func (keyValue *KeyValue) Columns() []string

func (*KeyValue) Values added in v1.8.0 

func (keyValue *KeyValue) Values() []string

type QueryByKeysRequest 

type QueryByKeysRequest struct {
	TablePrefixWithSchema string
	Version               string
	Select                *Clause
	KeyValues             *KeyValue
}

type QueryByWhereAndOrderByRequest 

type QueryByWhereAndOrderByRequest struct {
	TablePrefixWithSchema string
	Table                 string
	Version               string
	Select                *Clause
	Where                 *Clause
	OrderBy               string
	PageNo                int
	PageSize              int
}

type ReplayRequest 

type ReplayRequest struct {
	TablePrefixWithSchema string
	Version               string
	KeyValues             *KeyValue
	UserID                string
}

type TableRow added in v1.6.0 

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

func FromDSPInfosData added in v1.6.0 

func FromDSPInfosData(infosData []*response.InfoData) ([]TableRow, error)

func NewTableRow added in v1.6.0 

func NewTableRow() *TableRow

func (*TableRow) AddColumnValueBool added in v1.6.0 

func (tableRow *TableRow) AddColumnValueBool(columnName string, value bool) *TableRow

func (*TableRow) AddColumnValueFloat32 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueFloat32(columnName string, value float32) *TableRow

func (*TableRow) AddColumnValueFloat64 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueFloat64(columnName string, value float64) *TableRow

func (*TableRow) AddColumnValueInt added in v1.6.0 

func (tableRow *TableRow) AddColumnValueInt(columnName string, value int) *TableRow

func (*TableRow) AddColumnValueInt16 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueInt16(columnName string, value int16) *TableRow

func (*TableRow) AddColumnValueInt32 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueInt32(columnName string, value int32) *TableRow

func (*TableRow) AddColumnValueInt64 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueInt64(columnName string, value int64) *TableRow

func (*TableRow) AddColumnValueInt8 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueInt8(columnName string, value int8) *TableRow

func (*TableRow) AddColumnValueString added in v1.6.0 

func (tableRow *TableRow) AddColumnValueString(columnName string, value string) *TableRow

func (*TableRow) AddColumnValueTime added in v1.6.0 

func (tableRow *TableRow) AddColumnValueTime(columnName string, value time.Time) *TableRow

func (*TableRow) AddColumnValueUint added in v1.6.0 

func (tableRow *TableRow) AddColumnValueUint(columnName string, value uint) *TableRow

func (*TableRow) AddColumnValueUint16 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueUint16(columnName string, value uint16) *TableRow

func (*TableRow) AddColumnValueUint32 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueUint32(columnName string, value uint32) *TableRow

func (*TableRow) AddColumnValueUint64 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueUint64(columnName string, value uint64) *TableRow

func (*TableRow) AddColumnValueUint8 added in v1.6.0 

func (tableRow *TableRow) AddColumnValueUint8(columnName string, value uint8) *TableRow

func (*TableRow) ColumnValueBool added in v1.6.0 

func (tableRow *TableRow) ColumnValueBool(columnName string) bool

func (*TableRow) ColumnValueFloat32 added in v1.6.0 

func (tableRow *TableRow) ColumnValueFloat32(columnName string) float32

func (*TableRow) ColumnValueFloat64 added in v1.6.0 

func (tableRow *TableRow) ColumnValueFloat64(columnName string) float64

func (*TableRow) ColumnValueInt added in v1.6.0 

func (tableRow *TableRow) ColumnValueInt(columnName string) int

func (*TableRow) ColumnValueInt16 added in v1.6.0 

func (tableRow *TableRow) ColumnValueInt16(columnName string) int16

func (*TableRow) ColumnValueInt32 added in v1.6.0 

func (tableRow *TableRow) ColumnValueInt32(columnName string) int32

func (*TableRow) ColumnValueInt64 added in v1.6.0 

func (tableRow *TableRow) ColumnValueInt64(columnName string) int64

func (*TableRow) ColumnValueInt8 added in v1.6.0 

func (tableRow *TableRow) ColumnValueInt8(columnName string) int8

func (*TableRow) ColumnValueString added in v1.6.0 

func (tableRow *TableRow) ColumnValueString(columnName string) string

func (*TableRow) ColumnValueTime added in v1.6.0 

func (tableRow *TableRow) ColumnValueTime(columnName string) time.Time

func (*TableRow) ColumnValueUint added in v1.6.0 

func (tableRow *TableRow) ColumnValueUint(columnName string) uint

func (*TableRow) ColumnValueUint16 added in v1.6.0 

func (tableRow *TableRow) ColumnValueUint16(columnName string) uint16

func (*TableRow) ColumnValueUint32 added in v1.6.0 

func (tableRow *TableRow) ColumnValueUint32(columnName string) uint32

func (*TableRow) ColumnValueUint64 added in v1.6.0 

func (tableRow *TableRow) ColumnValueUint64(columnName string) uint64

func (*TableRow) ColumnValueUint8 added in v1.6.0 

func (tableRow *TableRow) ColumnValueUint8(columnName string) uint8

func (*TableRow) FromDSPInfoData added in v1.6.0 

func (tableRow *TableRow) FromDSPInfoData(infoData *response.InfoData) error

func (*TableRow) SnapshotColumnValue added in v1.9.2 

func (tableRow *TableRow) SnapshotColumnValue(prefix string, version string, columnName string) any

func (*TableRow) ToDPSTableRow added in v1.6.0 

func (tableRow *TableRow) ToDPSTableRow() (*request.TableRow, error)

func (*TableRow) ToMap added in v1.10.2 

func (tableRow *TableRow) ToMap() map[string]any

type Transaction 

type Transaction interface {
	InsertTx(request *InsertRequest) (string, error)
	InsertBatchTx(request *InsertBatchRequest) (string, error)
	DeleteTx(request *DeleteRequest) (string, error)
	DeleteWhereTx(request *DeleteWhereRequest) (string, error)
	UpdateTx(request *UpdateRequest) (string, error)
	UpdateWhereTx(request *UpdateWhereRequest) (string, error)
}

type TransactionFunc 

type TransactionFunc func(tx Transaction) error

type UpdateRequest 

type UpdateRequest struct {
	TablePrefixWithSchema string
	Version               string
	KeyValues             *KeyValue
	NewTableRow           *TableRow
	UserID                string
}

type UpdateWhereRequest added in v1.7.0 

type UpdateWhereRequest struct {
	TablePrefixWithSchema string
	Version               string
	KeyColumns            []string
	Where                 *Clause
	NewTableRow           *TableRow
	UserID                string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.