pageesdto

package
v0.0.0-...-36220ec Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 17, 2024 License: MulanPSL-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AggSign_COUNT = "count"
	AggSign_MAX   = "max"
	AggSign_MIN   = "min"
	AggSign_AVG   = "avg"
	AggSign_SUM   = "sum"
	AggSign_STATS = "stats"
)

索是 ES 最为复杂精妙的地方，这里只示例项目中较为常用的查询。 

ES 中的查询分为三大类，

一是 Term-level queries（我翻译成字段匹配）， 二是 Full-text queries（全文搜索） ，三是不常用的 Specialized queries（专门查询）。各自可细分为如下几种： 

Term-level queries
exists query 字段是否存在值
fuzzy query 模糊查询
ids query ID 查询
prefix query 前缀查询
range query 范围查询
regexp query 正则查询
term query 精确匹配单个字段
terms query 精确匹配单个字段，但使用多值进行匹配，类似于 SQL 中的 in 操作
terms_set query 字段集合查询。文档需包含字段集合中指定的最少数量字段
wildcard query 通配符查询
Full-text queries
match query 单字段搜索（匹配分词结果，不需要全文匹配）
Specialized queries
script query 脚本查询

原文链接：https://blog.csdn.net/K346K346/article/details/120906440

Variables

This section is empty.

Functions

func InjectPageesRequest 

func InjectPageesRequest(s *PageesRequest)

func LoadPageesRequest 

func LoadPageesRequest() baseiface.ISingleton

Types

type PageesQuery 

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

func NewPageesQuery 

func NewPageesQuery(pageReq *PageesRequest) *PageesQuery

func (*PageesQuery) BuildQuery 

func (this *PageesQuery) BuildQuery() elastic.Query

func (*PageesQuery) FuzzyQuery 

func (this *PageesQuery) FuzzyQuery() []elastic.Query

func (*PageesQuery) IdQuery 

func (this *PageesQuery) IdQuery() []elastic.Query

func (*PageesQuery) IdsQuery 

func (this *PageesQuery) IdsQuery() []elastic.Query

func (*PageesQuery) MatchAllQuery 

func (this *PageesQuery) MatchAllQuery() []elastic.Query

func (*PageesQuery) MatchQuery 

func (this *PageesQuery) MatchQuery() []elastic.Query

text

func (*PageesQuery) RangeQuery 

func (this *PageesQuery) RangeQuery() []elastic.Query

func (*PageesQuery) TermQuery 

func (this *PageesQuery) TermQuery() []elastic.Query

match term keyword

func (*PageesQuery) TermsQuery 

func (this *PageesQuery) TermsQuery() []elastic.Query

type PageesRequest 

type PageesRequest struct {
	basedto.BaseEntity
	page.PageRequest
	//ES INDEX名称
	IndexName string `json:"index_name"`
	//返回fields
	Source string `json:"Source"` //source

	//must filter
	AggFields *pagedto2.QueryField `json:"agg_fields,omitempty"`

	EsClient *ichubelastic.ElasticClient `json:"-"`
	// contains filtered or unexported fields
}

func FindBeanPageesRequest 

func FindBeanPageesRequest() *PageesRequest

func New 

func New() *PageesRequest

func NewEsRequest 

func NewEsRequest(pageSize, current int) *PageesRequest

func NewPageEsRequest 

func NewPageEsRequest(indexName string) *PageesRequest

func NewPageesRequest 

func NewPageesRequest() *PageesRequest

func (*PageesRequest) AttachResp 

func (this *PageesRequest) AttachResp() bool

func (*PageesRequest) Avg 

func (this *PageesRequest) Avg(field string) *PageesRequest

func (*PageesRequest) BuildSource 

func (this *PageesRequest) BuildSource(service *elastic.SearchService)

func (*PageesRequest) Clear 

func (this *PageesRequest) Clear()

func (*PageesRequest) Client 

func (this *PageesRequest) Client() *elastic.Client

func (*PageesRequest) Count 

func (this *PageesRequest) Count(field string) *PageesRequest

func (*PageesRequest) EsCount 

func (this *PageesRequest) EsCount() (int64, error)

排序字段是keyword

func (*PageesRequest) EsCreateIndex 

func (this *PageesRequest) EsCreateIndex(indexName string, mapping string) (bool, error)

EsCreateIndex EsDropIndex

func (*PageesRequest) EsDeleteIndex 

func (this *PageesRequest) EsDeleteIndex(id string) (*elastic.DeleteResponse, error)

func (*PageesRequest) EsDropIndex 

func (this *PageesRequest) EsDropIndex(indexName string)

func (*PageesRequest) EsFindId 

func (this *PageesRequest) EsFindId(id string) (*elastic.GetResult, error)

func (*PageesRequest) EsFindIds 

func (this *PageesRequest) EsFindIds(ids ...string) (*elastic.SearchResult, error)

func (*PageesRequest) EsFindTerm 

func (this *PageesRequest) EsFindTerm(field string, value any) (*elastic.SearchResult, error)

func (*PageesRequest) EsFindTerms 

func (this *PageesRequest) EsFindTerms(key string, values ...any) (*elastic.SearchResult, error)

func (*PageesRequest) EsFuzzy 

func (this *PageesRequest) EsFuzzy(field string, opValue any) *PageesRequest

func (*PageesRequest) EsGetMapping 

func (this *PageesRequest) EsGetMapping(indexName string) (map[string]interface{}, error)

func (*PageesRequest) EsId 

func (this *PageesRequest) EsId(opValue any) *PageesRequest

func (*PageesRequest) EsIds 

func (this *PageesRequest) EsIds(opValues []any) *PageesRequest

func (*PageesRequest) EsMatch 

func (this *PageesRequest) EsMatch(field string, opValue any) *PageesRequest

func (*PageesRequest) EsMatchAll 

func (this *PageesRequest) EsMatchAll() *PageesRequest

func (*PageesRequest) EsQuery 

func (this *PageesRequest) EsQuery() (*elastic.SearchResult, error)

func (*PageesRequest) EsQueryResult 

func (this *PageesRequest) EsQueryResult() (*PageesResult, error)

func (*PageesRequest) EsSaveIndex 

func (this *PageesRequest) EsSaveIndex(id string, model any) (*elastic.IndexResponse, error)

func (*PageesRequest) EsTerm 

func (this *PageesRequest) EsTerm(field string, opValue any) *PageesRequest

func (*PageesRequest) EsTerms 

func (this *PageesRequest) EsTerms(field string, opValues ...any) *PageesRequest

func (*PageesRequest) Field2Keyword 

func (this *PageesRequest) Field2Keyword(field string) string

func (*PageesRequest) IndexAnalyze 

func (this *PageesRequest) IndexAnalyze(text string) (*elastic.IndicesAnalyzeResponse, error)

func (*PageesRequest) IndexAnalyzeToken 

func (this *PageesRequest) IndexAnalyzeToken(token string, text string) (*elastic.IndicesAnalyzeResponse, error)

func (*PageesRequest) IndexAnalyzeWord 

func (this *PageesRequest) IndexAnalyzeWord(r *keyword.SplitWordRequest) (*elastic.IndicesAnalyzeResponse, error)

func (*PageesRequest) Ini 

func (this *PageesRequest) Ini(clientDto *baseconfig.ElasticClientDto)

func (*PageesRequest) IniDefault 

func (this *PageesRequest) IniDefault()

func (*PageesRequest) Max 

func (this *PageesRequest) Max(field string) *PageesRequest

func (*PageesRequest) Min 

func (this *PageesRequest) Min(field string) *PageesRequest

func (*PageesRequest) Open 

func (this *PageesRequest) Open()

func (*PageesRequest) SetAttachResp 

func (this *PageesRequest) SetAttachResp(attachResp bool)

func (*PageesRequest) Stats 

func (this *PageesRequest) Stats(field string) *PageesRequest

func (*PageesRequest) Sum 

func (this *PageesRequest) Sum(field string) *PageesRequest

func (*PageesRequest) ValueOfPageRequest 

func (this *PageesRequest) ValueOfPageRequest(that *PageesRequest) *PageesRequest

type PageesResult 

type PageesResult struct {
	page.PageResult
	SearchResult *elastic.SearchResult `json:"search_result,omitempty"`
}

@Title 文件名称: pageesresponse.go @Description 描述: es响应消息

@Author 作者: leijianming@163.com 时间(2024-02-22 22:38:21) @Update 作者: leijianming@163.com 时间(2024-02-21 22:38:21)

func NewPageesResult 

func NewPageesResult() *PageesResult

func (*PageesResult) FailMsg 

func (this *PageesResult) FailMsg(Msg string) *PageesResult

func (*PageesResult) Hits2Sources 

func (this *PageesResult) Hits2Sources(hits []*elastic.SearchHit) *[]json.RawMessage

func (*PageesResult) InitPage 

func (this *PageesResult) InitPage()

func (*PageesResult) PageEsResultOf 

func (this *PageesResult) PageEsResultOf(that *PageesRequest, SearchResult *elastic.SearchResult)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.