client.go 1.8 KB

123456789101112131415161718192021222324252627282930313233343536
  1. package client
  2. import "strings"
  3. func IsErrorDBRecordHasExist(err error) bool {
  4. return strings.Contains(err.Error(), "记录已存在")
  5. }
  6. func IsErrorDBRecordNotExist(err error) bool {
  7. return strings.Contains(err.Error(), "记录不存在")
  8. }
  9. type Client interface {
  10. AutoMigrate(request *AutoMigrateRequest) error
  11. AutoMigrateBatch(request *AutoMigrateBatchRequest) error
  12. Transaction(txFunc TransactionFunc) error
  13. Insert(request *InsertRequest) (string, error)
  14. InsertBatch(request *InsertBatchRequest) (string, error)
  15. Delete(request *DeleteRequest) (string, error)
  16. DeleteBatch(request *DeleteBatchRequest) (string, error)
  17. Update(request *UpdateRequest) (string, error)
  18. Replay(request *ReplayRequest) (string, error)
  19. QueryByWhereAndOrderBy(request *QueryByWhereAndOrderByRequest) (string, []map[string]any, int64, error)
  20. CommonQuery(request *CommonQueryRequest) (string, []map[string]any, int64, error)
  21. QueryByKeys(request *QueryByKeysRequest) (string, map[string]any, error)
  22. CountWhere(request *CountWhereRequest) (string, int64, error)
  23. CommonCount(request *CommonCountRequest) (string, int64, error)
  24. EventQueryByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, int64, error)
  25. CommonEventQuery(request *CommonEventQueryRequest) (string, []EventInfo, int64, error)
  26. CountEventByKeys(request *CountEventByKeysRequest) (string, int64, error)
  27. CommonCountEvent(request *CommonCountEventRequest) (string, int64, error)
  28. EventHistoryQueryByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, int64, error)
  29. CommonEventHistoryQuery(request *CommonEventQueryRequest) (string, []EventInfo, int64, error)
  30. CountEventHistoryByKeys(request *CountEventByKeysRequest) (string, int64, error)
  31. CommonCountEventHistory(request *CommonCountEventRequest) (string, int64, error)
  32. }