base

Documentation

Index

• type DefaultModel
• type GraphQLField
  • func ForGraphQLField(queryFields []string, prefix string) GraphQLField
  • func NewGraphQLField(ctx context.Context, prefix string) GraphQLField
• type Model
  • func (m *Model) Begin()
  • func (m *Model) Commit() (err error)
  • func (m *Model) Count(model interface{}) (total int64, err error)
  • func (m *Model) Create(value interface{}) (err error)
  • func (m *Model) Delete(value interface{}, ids []int64) (err error)
  • func (m *Model) Find(dest interface{}) error
  • func (m *Model) First(dest interface{}) error
  • func (m *Model) FuzzyQuery(keyword string, field string) Repository
  • func (m *Model) GetDB() *gorm.DB
  • func (m *Model) IDArrayQuery(ids interface{}, idFieldName ...string) Repository
  • func (m *Model) IDQuery(id interface{}, idFieldName ...string) Repository
  • func (m *Model) LeftJoin(query string, args ...interface{}) Repository
  • func (m *Model) Order(value interface{}) Repository
  • func (m *Model) Pagination(offset, limit int) Repository
  • func (m *Model) Preload(query string, args ...interface{}) Repository
  • func (m *Model) Raw(sql string, result interface{}, value ...interface{}) (err error)
  • func (m *Model) ReSetDB()
  • func (m *Model) Rollback()
  • func (m *Model) Save(value interface{}) (err error)
  • func (m *Model) Select(fields []string, omitFields ...string) Repository
  • func (m *Model) SelectWithPrefix(fields []string, prefix string, omitFields ...string) Repository
  • func (m *Model) SetDB(db *gorm.DB)
  • func (m *Model) Sort(sorts []*Sort) Repository
  • func (m *Model) Table(name string, args ...interface{}) Repository
  • func (m *Model) Take(dest interface{}) error
  • func (m *Model) Unscoped() Repository
  • func (m *Model) Updates(value interface{}) (err error)
  • func (m *Model) Where(query interface{}, args ...interface{}) Repository
• type Repository
• type Search
  • func NewSearch(ctx context.Context, searchParam *SearchParam, scheme string) *Search
  • func (s *Search) Filter()
  • func (s *Search) GetAggResults(aggsParams []*es.AggsParam, result *elastic.SearchResult) []*model.AggResult
  • func (s *Search) GetPageInfo() (int, int)
• type Service
  • func (s Service) GetByID(r Repository, id uint, columns []string) error
  • func (s Service) GetConnection(r Repository, searchParam *SearchParam, data interface{}, ...) (total int64, err error)
  • func (s Service) GetInputFields(ctx context.Context) []string
  • func (s Service) GetPageInfo(searchParam *SearchParam) (int, int)
  • func (s Service) GetValidIDs(r Repository, tableName string, ids []uint) []uint
  • func (s Service) OldGetConnection(ctx context.Context, r Repository, searchParam *SearchParam, data interface{}, ...) (total int64, err error)
  • func (s Service) RecordNotExist(r Repository, id interface{}, uid ...uint) bool
  • func (s Service) ToInt64(ids []uint) []int64
  • func (s Service) ToUintIDs(ids []int64) []uint

Types

type DefaultModel

type DefaultModel struct {
	Model
	ID        uint `gorm:"primarykey"`
	CreatedAt time.Time
	UpdatedAt time.Time
	DeletedAt sql.NullTime `gorm:"index"`
}

DefaultModel ..

type GraphQLField

type GraphQLField struct {
	FieldMap map[string]bool
	Fields   []string
}

GraphQLField ..

func ForGraphQLField

func ForGraphQLField(queryFields []string, prefix string) GraphQLField

ForGraphQLField get fields from queryFields

func NewGraphQLField

func NewGraphQLField(ctx context.Context, prefix string) GraphQLField

NewGraphQLField get graphql field from context

type Model

type Model struct {
	// contains filtered or unexported fields
}

Model ..

func (*Model) Begin

func (m *Model) Begin()

Begin 开启事务

func (*Model) Commit

func (m *Model) Commit() (err error)

Commit 提交事务

func (*Model) Count

func (m *Model) Count(model interface{}) (total int64, err error)

Count 查询数据总量

func (*Model) Create

func (m *Model) Create(value interface{}) (err error)

Create 新建数据

func (*Model) Delete

func (m *Model) Delete(value interface{}, ids []int64) (err error)

Delete 删除数据

func (*Model) Find

func (m *Model) Find(dest interface{}) error

Find 查找数据

func (*Model) First

func (m *Model) First(dest interface{}) error

First 查找按主键排序第一条数据

func (*Model) FuzzyQuery

func (m *Model) FuzzyQuery(keyword string, field string) Repository

FuzzyQuery 增加模糊查询

func (*Model) GetDB

func (m *Model) GetDB() *gorm.DB

GetDB ..

func (*Model) IDArrayQuery

func (m *Model) IDArrayQuery(ids interface{}, idFieldName ...string) Repository

IDArrayQuery ids查询

func (*Model) IDQuery

func (m *Model) IDQuery(id interface{}, idFieldName ...string) Repository

IDQuery id查询

func (*Model) LeftJoin

func (m *Model) LeftJoin(query string, args ...interface{}) Repository

LeftJoin 左连接

func (*Model) Order

func (m *Model) Order(value interface{}) Repository

Order 排序

func (*Model) Pagination

func (m *Model) Pagination(offset, limit int) Repository

Pagination 分页

func (*Model) Preload

func (m *Model) Preload(query string, args ...interface{}) Repository

Preload 预加载

func (*Model) Raw

func (m *Model) Raw(sql string, result interface{}, value ...interface{}) (err error)

Raw 保存数据

func (*Model) ReSetDB

func (m *Model) ReSetDB()

ReSetDB ..

func (*Model) Rollback

func (m *Model) Rollback()

Rollback 撤回事务

func (*Model) Save

func (m *Model) Save(value interface{}) (err error)

Save 保存数据

func (*Model) Select

func (m *Model) Select(fields []string, omitFields ...string) Repository

Select 选择字段

func (*Model) SelectWithPrefix

func (m *Model) SelectWithPrefix(fields []string, prefix string, omitFields ...string) Repository

SelectWithPrefix 选择字段带上特定前缀

func (*Model) SetDB

func (m *Model) SetDB(db *gorm.DB)

SetDB ..

func (*Model) Sort

func (m *Model) Sort(sorts []*Sort) Repository

Sort 排序

func (*Model) Table

func (m *Model) Table(name string, args ...interface{}) Repository

Table ..

func (*Model) Take

func (m *Model) Take(dest interface{}) error

Take 查找单条数据

func (*Model) Unscoped

func (m *Model) Unscoped() Repository

Save 保存数据

func (*Model) Updates

func (m *Model) Updates(value interface{}) (err error)

Updates 更新数据

func (*Model) Where

func (m *Model) Where(query interface{}, args ...interface{}) Repository

Where where查询

type Repository

type Repository interface {
	SetDB(db *gorm.DB)
	ReSetDB()
	GetDB() *gorm.DB
	Table(name string, args ...interface{}) Repository
	SelectWithPrefix(fields []string, prefix string, omitFields ...string) Repository
	Select(fields []string, omitFields ...string) Repository
	LeftJoin(query string, args ...interface{}) Repository
	FuzzyQuery(keyword string, field string) Repository
	IDQuery(id interface{}, idFieldName ...string) Repository
	IDArrayQuery(ids interface{}, idFieldName ...string) Repository
	Where(query interface{}, args ...interface{}) Repository
	Pagination(offset, limit int) Repository
	Sort(sorts []*Sort) Repository
	Order(value interface{}) Repository
	Preload(query string, args ...interface{}) Repository
	First(dest interface{}) error
	Take(dest interface{}) error
	Find(dest interface{}) error
	Count(model interface{}) (total int64, err error)
	Create(value interface{}) error
	Updates(value interface{}) error
	Delete(value interface{}, ids []int64) error
	Begin()
	Rollback()
	Commit() error
}

Repository 。。

type Search

type Search struct {
	Ctx           context.Context
	SearchParam   *SearchParam
	Scheme        string
	SearchService *elastic.SearchService
	BoolQuery     *elastic.BoolQuery
	FilterQueries []elastic.Query
	IgnoreQueries []elastic.Query
}

Search ..

func NewSearch

func NewSearch(ctx context.Context, searchParam *SearchParam, scheme string) *Search

NewSearch ..

func (*Search) Filter

func (s *Search) Filter()

Filter ..

func (*Search) GetAggResults

func (s *Search) GetAggResults(aggsParams []*es.AggsParam,
	result *elastic.SearchResult) []*model.AggResult

GetAggResults ..

func (*Search) GetPageInfo

func (s *Search) GetPageInfo() (int, int)

GetPageInfo ..

type Service

type Service struct {
}

Service base service

func (Service) GetByID

func (s Service) GetByID(r Repository, id uint, columns []string) error

GetByID Get model by id

func (Service) GetConnection

func (s Service) GetConnection(r Repository, searchParam *SearchParam,
	data interface{}, replaceFunc func(field GraphQLField) error, omitFields ...string) (total int64, err error)

GetConnection get list data and total count

func (Service) GetInputFields

func (s Service) GetInputFields(ctx context.Context) []string

GetInputFields from context

func (Service) GetPageInfo

func (s Service) GetPageInfo(searchParam *SearchParam) (int, int)

GetPageInfo ...

func (Service) GetValidIDs

func (s Service) GetValidIDs(r Repository, tableName string, ids []uint) []uint

GetValidIDs ..

func (Service) OldGetConnection

func (s Service) OldGetConnection(ctx context.Context, r Repository, searchParam *SearchParam,
	data interface{}, replaceFunc func(field GraphQLField) error, omitFields ...string) (total int64, err error)

Deprecated: query params should get from searchParam not context

func (Service) RecordNotExist

func (s Service) RecordNotExist(r Repository, id interface{}, uid ...uint) bool

RecordNotExist ..

func (Service) ToInt64

func (s Service) ToInt64(ids []uint) []int64

ToInt64 change id type from uint to int64

func (Service) ToUintIDs

func (s Service) ToUintIDs(ids []int64) []uint

ToUintIDs change id type from int64 to uint