dps-sdk/ports/client.go

package ports

const (
	CompareEqual               = "equal"
	CompareLike                = "like"
	CompareNot                 = "not"
	CompareIn                  = "in"
	CompareNotIn               = "notin"
	CompareLessThan            = "lt"
	CompareGreaterThan         = "gt"
	CompareLessThanAndEqual    = "lte"
	CompareGreaterThanAndEqual = "gte"
)

type Client interface {
	AutoMigrate(request *AutoMigrateRequest) error
	AutoMigrateBatch(request *AutoMigrateBatchRequest) error
	Transaction(databaseID string, txFunc TransactionFunc) error
	Insert(request *InsertRequest) (string, error)
	InsertBatch(request *InsertBatchRequest) (string, error)
	Delete(request *DeleteRequest) (string, error)
	DeleteBatch(request *DeleteBatchRequest) (string, error)
	Update(request *UpdateRequest) (string, error)
	Replay(req *ReplayRequest) (string, error)
	QueryByWhereAndOrderBy(request *QueryByWhereAndOrderByRequest) (string, []map[string]any, int64, error)
	CommonQuery(request *CommonQueryRequest) (string, []map[string]any, int64, error)
	QueryByKeys(request *QueryByKeysRequest) (string, map[string]any, error)
	CountWhere(request *CountWhereRequest) (string, int64, error)
	CommonCount(request *CommonCountRequest) (string, int64, error)
}