Documentation
¶
Index ¶
- func IsErrorDBRecordHasExist(err error) bool
- func IsErrorDBRecordNotExist(err error) bool
- type AutoMigrateItem
- type AutoMigrateRequest
- type Client
- type CommonCountEventRequest
- type CommonCountRequest
- type CommonEventQueryRequest
- type CommonQueryRequest
- type CountEventByKeysRequest
- type CountWhereRequest
- type DeleteBatchRequest
- type DeleteItem
- type DeleteRequest
- type DeleteTableRowItem
- type EventInfo
- type EventQueryByKeysRequest
- type InsertBatchRequest
- type InsertItem
- type InsertRequest
- type InsertTableRowItem
- type QueryByKeysRequest
- type QueryByWhereAndOrderByRequest
- type ReplayRequest
- type Transaction
- type TransactionFunc
- type UpdateRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsErrorDBRecordHasExist ¶
func IsErrorDBRecordNotExist ¶
Types ¶
type AutoMigrateItem ¶
type AutoMigrateRequest ¶
type AutoMigrateRequest struct {
Items []AutoMigrateItem
}
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) DeleteBatch(request *DeleteBatchRequest) (string, error) Update(request *UpdateRequest) (string, error) Replay(request *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) EventQueryByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, int64, error) CommonEventQuery(request *CommonEventQueryRequest) (string, []EventInfo, int64, 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) CountEventHistoryByKeys(request *CountEventByKeysRequest) (string, int64, error) CommonCountEventHistory(request *CommonCountEventRequest) (string, int64, error) }
type CommonCountEventRequest ¶
type CommonCountRequest ¶
type CommonEventQueryRequest ¶
type CommonQueryRequest ¶
type CountEventByKeysRequest ¶
type CountWhereRequest ¶
type DeleteBatchRequest ¶
type DeleteBatchRequest struct { Items []DeleteTableRowItem UserID string }
type DeleteItem ¶
type DeleteRequest ¶
type DeleteTableRowItem ¶
type DeleteTableRowItem struct { TablePrefixWithSchema string Version string Items []DeleteItem }
type EventInfo ¶
type EventInfo struct { Key string Version string Operation string Value string CreatorID string CreateTime time.Time }
func FormEventInfo ¶
func FormEventInfoBatch ¶
type EventQueryByKeysRequest ¶
type InsertBatchRequest ¶
type InsertBatchRequest struct { Items []InsertTableRowItem UserID string }
type InsertItem ¶
type InsertRequest ¶
type InsertTableRowItem ¶
type InsertTableRowItem struct { TablePrefixWithSchema string Version string Items []InsertItem }
type QueryByKeysRequest ¶
type ReplayRequest ¶
type Transaction ¶
type Transaction interface { InsertTx(request *InsertRequest) (string, error) InsertBatchTx(request *InsertBatchRequest) (string, error) DeleteTx(request *DeleteRequest) (string, error) DeleteBatchTx(request *DeleteBatchRequest) (string, error) UpdateTx(request *UpdateRequest) (string, error) End() error }
type TransactionFunc ¶
type TransactionFunc func(tx Transaction) error
Click to show internal directories.
Click to hide internal directories.