Documentation ¶
Index ¶
- func FormatCreatedTime(dataMap map[string]any, format string) string
- func FormatLastEventTime(dataMap map[string]any, format string) string
- func GetCreateUserID(dataMap map[string]any) string
- func GetLastUpdateUserID(dataMap map[string]any) string
- 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 DeleteRequest
- type DeleteTableRowItem
- type EventInfo
- type EventQueryByKeysRequest
- type InsertBatchRequest
- 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 FormatCreatedTime ¶ added in v1.2.0
func FormatLastEventTime ¶ added in v1.2.0
func GetCreateUserID ¶ added in v1.2.0
func GetLastUpdateUserID ¶ added in v1.2.0
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) QueryOnlyByWhereAndOrderBy(request *QueryByWhereAndOrderByRequest) (string, []map[string]any, error) CommonQueryOnly(request *CommonQueryRequest) (string, []map[string]any, 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) 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 CommonCountRequest ¶
type CommonEventQueryRequest ¶
type CommonQueryRequest ¶
type CountEventByKeysRequest ¶
type CountWhereRequest ¶
type DeleteBatchRequest ¶
type DeleteBatchRequest struct { Items []DeleteTableRowItem UserID string }
type DeleteRequest ¶
type DeleteTableRowItem ¶
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 InsertRequest ¶
type InsertTableRowItem ¶
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) }
type TransactionFunc ¶
type TransactionFunc func(tx Transaction) error
Click to show internal directories.
Click to hide internal directories.