Documentation ¶
Index ¶
- Constants
- func InjectPageesRequest(s *PageesRequest)
- func LoadPageesRequest() baseiface.ISingleton
- type PageesQuery
- func (this *PageesQuery) BuildQuery() elastic.Query
- func (this *PageesQuery) FuzzyQuery() []elastic.Query
- func (this *PageesQuery) IdQuery() []elastic.Query
- func (this *PageesQuery) IdsQuery() []elastic.Query
- func (this *PageesQuery) MatchAllQuery() []elastic.Query
- func (this *PageesQuery) MatchQuery() []elastic.Query
- func (this *PageesQuery) RangeQuery() []elastic.Query
- func (this *PageesQuery) TermQuery() []elastic.Query
- func (this *PageesQuery) TermsQuery() []elastic.Query
- type PageesRequest
- func (this *PageesRequest) AttachResp() bool
- func (this *PageesRequest) Avg(field string) *PageesRequest
- func (this *PageesRequest) BuildSource(service *elastic.SearchService)
- func (this *PageesRequest) Clear()
- func (this *PageesRequest) Client() *elastic.Client
- func (this *PageesRequest) Count(field string) *PageesRequest
- func (this *PageesRequest) EsCount() (int64, error)
- func (this *PageesRequest) EsCreateIndex(indexName string, mapping string) (bool, error)
- func (this *PageesRequest) EsDeleteIndex(id string) (*elastic.DeleteResponse, error)
- func (this *PageesRequest) EsDropIndex(indexName string)
- func (this *PageesRequest) EsFindId(id string) (*elastic.GetResult, error)
- func (this *PageesRequest) EsFindIds(ids ...string) (*elastic.SearchResult, error)
- func (this *PageesRequest) EsFindTerm(field string, value any) (*elastic.SearchResult, error)
- func (this *PageesRequest) EsFindTerms(key string, values ...any) (*elastic.SearchResult, error)
- func (this *PageesRequest) EsFuzzy(field string, opValue any) *PageesRequest
- func (this *PageesRequest) EsGetMapping(indexName string) (map[string]interface{}, error)
- func (this *PageesRequest) EsId(opValue any) *PageesRequest
- func (this *PageesRequest) EsIds(opValues []any) *PageesRequest
- func (this *PageesRequest) EsMatch(field string, opValue any) *PageesRequest
- func (this *PageesRequest) EsMatchAll() *PageesRequest
- func (this *PageesRequest) EsQuery() (*elastic.SearchResult, error)
- func (this *PageesRequest) EsQueryResult() (*PageesResult, error)
- func (this *PageesRequest) EsSaveIndex(id string, model any) (*elastic.IndexResponse, error)
- func (this *PageesRequest) EsTerm(field string, opValue any) *PageesRequest
- func (this *PageesRequest) EsTerms(field string, opValues ...any) *PageesRequest
- func (this *PageesRequest) Field2Keyword(field string) string
- func (this *PageesRequest) IndexAnalyze(text string) (*elastic.IndicesAnalyzeResponse, error)
- func (this *PageesRequest) IndexAnalyzeToken(token string, text string) (*elastic.IndicesAnalyzeResponse, error)
- func (this *PageesRequest) IndexAnalyzeWord(r *keyword.SplitWordRequest) (*elastic.IndicesAnalyzeResponse, error)
- func (this *PageesRequest) Ini(clientDto *baseconfig.ElasticClientDto)
- func (this *PageesRequest) IniDefault()
- func (this *PageesRequest) Max(field string) *PageesRequest
- func (this *PageesRequest) Min(field string) *PageesRequest
- func (this *PageesRequest) Open()
- func (this *PageesRequest) SetAttachResp(attachResp bool)
- func (this *PageesRequest) Stats(field string) *PageesRequest
- func (this *PageesRequest) Sum(field string) *PageesRequest
- func (this *PageesRequest) ValueOfPageRequest(that *PageesRequest) *PageesRequest
- type PageesResult
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) 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) 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 作者: [email protected] 时间(2024-02-22 22:38:21) @Update 作者: [email protected] 时间(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 ¶
Click to show internal directories.
Click to hide internal directories.