dps

package module
v1.8.0 Latest Latest
Warning

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

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

README

dps-sdk

数据库代理服务SDK

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AutoMigrate

func AutoMigrate(items ...client.AutoMigrateItem) error

func CheckEventExistByKeys

func CheckEventExistByKeys(req *client.CountEventByKeysRequest) (bool, error)

func CheckEventHistoryExistByKeys

func CheckEventHistoryExistByKeys(req *client.CountEventByKeysRequest) (bool, error)

func CheckExistWhere

func CheckExistWhere(req *client.CountWhereRequest) (bool, error)

func CommonCheckEventExist

func CommonCheckEventExist(req *client.CommonCountEventRequest) (bool, error)

func CommonCheckEventHistoryExist

func CommonCheckEventHistoryExist(req *client.CommonCountEventRequest) (bool, error)

func CommonCheckExist

func CommonCheckExist(req *client.CommonCountRequest) (bool, error)

func CommonCount

func CommonCount(req *client.CommonCountRequest) (int64, error)

func CommonCountEvent

func CommonCountEvent(req *client.CommonCountEventRequest) (int64, error)

func CommonCountEventHistory

func CommonCountEventHistory(req *client.CommonCountEventRequest) (int64, error)

func CommonEventHistoryQuery

func CommonEventHistoryQuery(req *client.CommonEventQueryRequest) ([]client.EventInfo, int64, error)

func CommonEventHistoryQueryOnly

func CommonEventHistoryQueryOnly(req *client.CommonEventQueryRequest) ([]client.EventInfo, error)

func CommonEventQuery

func CommonEventQuery(req *client.CommonEventQueryRequest) ([]client.EventInfo, int64, error)

func CommonEventQueryOnly

func CommonEventQueryOnly(req *client.CommonEventQueryRequest) ([]client.EventInfo, error)

func CommonQuery

func CommonQuery(req *client.CommonQueryRequest) ([]client.TableRow, int64, error)

func CommonQueryOnly

func CommonQueryOnly(req *client.CommonQueryRequest) ([]client.TableRow, error)

func CountEventByKeys

func CountEventByKeys(req *client.CountEventByKeysRequest) (int64, error)

func CountEventHistoryByKeys

func CountEventHistoryByKeys(req *client.CountEventByKeysRequest) (int64, error)

func CountWhere

func CountWhere(req *client.CountWhereRequest) (int64, error)

func Delete

func Delete(req *client.DeleteRequest, tx client.Transaction) error

func DeleteWhere added in v1.6.6

func DeleteWhere(req *client.DeleteWhereRequest, tx client.Transaction) error

func DestroyClient

func DestroyClient(clientVersion string, databaseID string) error

func DestroyInstance

func DestroyInstance(clientVersion string, databaseID string) error

func EventHistoryQueryByKeys

func EventHistoryQueryByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, int64, error)

func EventHistoryQueryOnlyByKeys

func EventHistoryQueryOnlyByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, error)

func EventQueryByKeys

func EventQueryByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, int64, error)

func EventQueryOnlyByKeys

func EventQueryOnlyByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, error)

func GetDataCreateUserID

func GetDataCreateUserID(dataMap map[string]any) string

func GetDataLastUpdateUserID

func GetDataLastUpdateUserID(dataMap map[string]any) string

func GetLastEventTime

func GetLastEventTime(dataMap map[string]any) *time.Time

func InitInstance

func InitInstance(address string, clientVersion string, databaseID string) error

func Insert

func Insert(req *client.InsertRequest, tx client.Transaction) error

func InsertBatch

func InsertBatch(req *client.InsertBatchRequest, tx client.Transaction) error

func NewClient

func NewClient(address string, clientVersion string, databaseID string) (client.Client, error)

func QueryByKeys

func QueryByKeys(req *client.QueryByKeysRequest) (*client.TableRow, error)

func QueryOnlyByWhereAndOrderBy

func QueryOnlyByWhereAndOrderBy(req *client.QueryByWhereAndOrderByRequest) ([]client.TableRow, error)

func Replay

func Replay(req *client.ReplayRequest) error

func Transaction

func Transaction(txFunc client.TransactionFunc) error

func Update

func Update(req *client.UpdateRequest, tx client.Transaction) error

func UpdateWhere added in v1.7.0

func UpdateWhere(req *client.UpdateWhereRequest, tx client.Transaction) error

Types

This section is empty.

Directories

Path Synopsis
pb
v1
test
v1

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL