ElasticSearch

Documentation

Index

• type ElasticClient
  • func GetElasticClient(config map[string]string) (*ElasticClient, error)
• type ElasticContent
  • func DataBaseMapping(client *ElasticClient) *ElasticContent
  • func (elasti *ElasticContent) GetElasticRepository(entity interface{}) IElasticRepository
• type ElasticRepository
  • func (elasti *ElasticRepository) Delete(id string) (res *elastic.DeleteResponse, err error)
  • func (elasti *ElasticRepository) GetById(id string, entity interface{}) error
  • func (elasti *ElasticRepository) Insert(id string, entity interface{}) (res *elastic.IndexResponse, err error)
  • func (elasti *ElasticRepository) InsertMany(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)
  • func (elasti *ElasticRepository) Query(query elastic.Query) (result *elastic.SearchResult, err error)
  • func (elasti *ElasticRepository) Search(query elastic.Query) (entity []interface{}, err error)
  • func (elasti *ElasticRepository) SearchPage(query elastic.Query, PageIndex, PageSize int) (entity []interface{}, totalCount int64, err error)
  • func (elasti *ElasticRepository) Update(id string, doc map[string]interface{}) (res *elastic.UpdateResponse, err error)
• type IElasticRepository

Types

type ElasticClient

type ElasticClient struct {
	Client *elastic.Client
	Index  string
}

Elastic 客户端

func GetElasticClient

func GetElasticClient(config map[string]string) (*ElasticClient, error)

type ElasticContent

type ElasticContent struct {
	*ElasticClient
}

集合上下文

func DataBaseMapping

func DataBaseMapping(client *ElasticClient) *ElasticContent

添加映射 @client 连接对象

func (*ElasticContent) GetElasticRepository

func (elasti *ElasticContent) GetElasticRepository(entity interface{}) IElasticRepository

获取集合仓储 entity 结构体

type ElasticRepository

type ElasticRepository struct {
	Content   *ElasticContent
	TableName string
	// contains filtered or unexported fields
}

Elastic 仓储

func (*ElasticRepository) Delete

func (elasti *ElasticRepository) Delete(id string) (res *elastic.DeleteResponse, err error)

删除 id id值

func (*ElasticRepository) GetById

func (elasti *ElasticRepository) GetById(id string, entity interface{}) error

查询单个 id id值 entity 查询的结果

func (*ElasticRepository) Insert

func (elasti *ElasticRepository) Insert(id string, entity interface{}) (res *elastic.IndexResponse, err error)

插入单个 id id值 entity 结构体

func (*ElasticRepository) InsertMany

func (elasti *ElasticRepository) InsertMany(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

插入单个 id id值 entity 结构体

func (*ElasticRepository) Query

func (elasti *ElasticRepository) Query(query elastic.Query) (result *elastic.SearchResult, err error)

查询直接返回结果

func (*ElasticRepository) Search

func (elasti *ElasticRepository) Search(query elastic.Query) (entity []interface{}, err error)

搜索 query 查询条件 搜索返回具体结果

func (*ElasticRepository) SearchPage

func (elasti *ElasticRepository) SearchPage(query elastic.Query, PageIndex, PageSize int) (entity []interface{}, totalCount int64, err error)

搜索结果分页显示

func (*ElasticRepository) Update

func (elasti *ElasticRepository) Update(id string, doc map[string]interface{}) (res *elastic.UpdateResponse, err error)

更新 id 文档id doc 更新内容

type IElasticRepository

type IElasticRepository interface {

	//批量插入
	// map[id值]结构体
	InsertMany(entityMap map[string]interface{}) (res *elastic.BulkResponse, err error)

	// 插入单个
	// id id值
	// entity  结构体
	Insert(id string, entity interface{}) (res *elastic.IndexResponse, err error)

	// 删除
	// id id值
	Delete(id string) (*elastic.DeleteResponse, error)

	//更新
	//id     文档id
	//doc    更新内容
	Update(id string, doc map[string]interface{}) (res *elastic.UpdateResponse, err error)

	//查询单个
	// id         id值
	// result      查询的结果
	GetById(id string, result interface{}) error

	//查询
	//query  查询条件
	//返回 搜索结果不处理
	Query(query elastic.Query) (result *elastic.SearchResult, err error)

	// 搜索
	// query  查询条件
	Search(query elastic.Query) (entity []interface{}, err error)

	// 搜索结果分页显示
	SearchPage(query elastic.Query, PageIndex, PageSize int) (entity []interface{}, totalCount int64, err error)
}

搜索引擎仓储接口