本站文章除注明转载/出处外,均为本站原创或翻译,转载前请务必署名原文链接~~~

Elasticsearch(4)之客户端操作

微信搜索 zze_coding 或扫描 👉 二维码关注我的微信公众号获取更多资源推送:


索引操作

url 格式:

{host}:{port}/{indexname}

创建索引

以 put 方式请求 127.0.0.1:9200/blog,body 内容如下:

{
    "mappings":{
        "article":{
            "properties":{
                "id":{
                    "type":"long",
                    "store":true
                },
                "title":{
                    "type":"text",
                    "store":true,
                    "index":true,
                    "analyzer":"standard"
                },
                "content":{
                    "type":"text",
                    "store":true,
                    "index":true,
                    "analyzer":"standard"
                }
            }
        }
    }
}

响应:

{
    "acknowledged": true,
    "shards_acknowledged": true,
    "index": "blog"
}

刷新 head 服务页面,会发现已经创建了 blog 索引库,并且在创建索引库的同时设置了 mappings 信息。查看索引信息如下:

image.png

删除索引库

如果要删除 blog 索引库,只需要以 delete 方式发送请求到 127.0.0.1:9200/blog 即可,无请求体,响应如下:

{
    "acknowledged": true
}

文档编辑操作

url 格式:

{host}:{port}/{indexname}/{typename}/{id}

添加文档

重新执行创建索引库操作,在创建索引库 blog 时已经指定了一个 type 信息即 article,所以添加文档时也应对应 article 的属性。
以 post 方式发送请求到 127.0.0.1:9200/blog/article/1,请求体如下:

{
    "id":1,
    "title":"测试标题",
    "content":"测试内容"
}

响应如下:

{
    "_index": "blog",
    "_type": "article",
    "_id": "1",
    "_version": 1,
    "result": "created",
    "_shards": {
        "total": 2,
        "successful": 1,
        "failed": 0
    },
    "_seq_no": 0,
    "_primary_term": 1
}

该操作会添加一条 id 为 1 的 article 文档。

注:可以看到该条数据有两个 id,后面一个 id 是我们创建索引库时设置 mapping 的字段,对应请求体 json 的 id,而前面的 _id 是 ES 内部维护记录的标识,对应 url 中的 id 部分。

修改文档

修改操作实际上和添加相同,发送 post 请求到 127.0.0.1:9200/blog/article/1 即可,请求体如下:

{
    "id":1,
    "title":"测试修改标题",
    "content":"测试修改内容xxxx"
}

响应:

{
    "_index": "blog",
    "_type": "article",
    "_id": "1",
    "_version": 2,
    "result": "updated",
    "_shards": {
        "total": 2,
        "successful": 1,
        "failed": 0
    },
    "_seq_no": 3,
    "_primary_term": 1
}

注:ES 内部如果发现已经存在了相同 _id 的文档,则就是修改操作,如果不存在,则就是添加操作。

删除文档

以删除刚刚创建的那条数据为例,发送一个 delete 请求到 127.0.0.1:9100/blog/article/1 即可,无请求体,响应如下:

{
    "_index": "blog",
    "_type": "article",
    "_id": "1",
    "_version": 2,
    "result": "deleted",
    "_shards": {
        "total": 2,
        "successful": 1,
        "failed": 0
    },
    "_seq_no": 1,
    "_primary_term": 1
}

注意,这里 url 中的 1 对应的是 _id 的值。

image.png

文档查询操作

为方便后面演示,添加一些测试数据如下:

image.png

根据id查询

url 格式:

{hostname}:{port}/{indexname}/{typename}/{id}

以 get 方式发送请求到 127.0.0.1:9200/blog/article/5,即查询 _id 为 5 的文档,响应如下:

{
    "_index": "blog",
    "_type": "article",
    "_id": "5",
    "_version": 1,
    "found": true,
    "_source": {
        "id": 5,
        "title": "硬核海军老爷子!7旬老海军深海区救女童,家长激动得3次跪谢",
        "content": "波涛起伏的大海、海水中漂摇的“充气艇”、在海浪中扑腾的小女孩、奋力游泳逐渐接近孩子的老人……这是动人心魄又感人至深的一幕。近日,烟台73岁老人孙开疆在海水中奋力救起一名5岁落水女童的事情引发网友关注,视频发到抖音之后,点击和点赞达150多万,网友纷纷为这位老人点赞。但在退役很久依然军人本色不改的老兵孙开疆看来,这是一件很普通的事情,也是一件自己应该做的事情。 事发后的当晚,孙开疆写下了这样一段文字:我不是为救一个孩子而炫耀,我更注重的是呼唤……我呼唤舍己救人的社会主义核心价值,呼唤鲜红的军旗与人民的血肉相连,呼唤全社会尊老爱幼的 崇高美德……这是我献给八一建军节一份珍贵的礼物!。"
    }
}

term 查询

url 格式:

{hostname}:{port}/{indexname}/{typename}/_search

term 查询除了要指定 url,还需要指定请求体。
以查询 blog 索引下 article 类型中文档属性 title 中包含 "在"字的文档为例,以 get 方式发送请求到 127.0.0.1:9200/blog/article/_search,请求体如下:

{
    "query":{
        "term":{
            "title":"在"
        }
    }
}

响应如下:

{
    "took": 1,
    "timed_out": false,
    "_shards": {
        "total": 5,
        "successful": 5,
        "skipped": 0,
        "failed": 0
    },
    "hits": {
        "total": 2,
        "max_score": 0.6866149,
        "hits": [
            {
                "_index": "blog",
                "_type": "article",
                "_id": "4",
                "_score": 0.6866149,
                "_source": {
                    "id": 4,
                    "title": "港媒:北京没有掉进圈套,而自欺欺人每天在香港上演",
                    "content": "当前香港上空弥漫一股“揽炒”(粤语:玉石俱焚)之风。很多年轻人似乎不在乎安危与犯法,要与执法者抱着一起“与汝皆亡”。激进氛围像一种流行病,开始蔓延,但立刻暴露出幼稚的双重标准。一些专业人士也学街头斗士,戴上口罩抗议警察暴力,却不谴责动乱者对旅客施私刑,丢汽油弹烧伤警察。"
                }
            },
            {
                "_index": "blog",
                "_type": "article",
                "_id": "1",
                "_score": 0.2876821,
                "_source": {
                    "id": 1,
                    "title": "将经贸问题政治化在香港问题上做文章,这些拙劣行径注定失败",
                    "content": "锐评指出,这是赤裸裸地将经贸问题政治化,公然干涉中国内政,企图增加施压和遏制中国的筹码,用心极其险恶!彭斯副总统应该去补一补历史课,拿《中英联合声明》这份过时无效的文件干涉香港事务与中国内政,不仅让自己沦为国际笑柄,也令美国国家形象蒙羞。"
                }
            }
        ]
    }
}

因目前使用的是标准分析器,对于中文是直接将每个汉字拆分为一个关键字,所以查询时只能根据单个汉字查询,否则是找不到结果的。

querystring 查询

该种查询方式与 term 查询的 url 格式相同,请求体不同。
querystring 查询是根据字符串查询,会先将字符串进行分词,然后用这些词去进行匹配查询。
以 get 方式发送请求体到 127.0.0.1:9200/blog/article/_search,请求体如下:

{
	"query":{
		"query_string":{
			"default_field":"title",
			"query":"我没有不开心"
		}
	}
}

default_field:指定在哪个域进行查询。
query:查询的字符串。

响应:

{
    "took": 3,
    "timed_out": false,
    "_shards": {
        "total": 5,
        "successful": 5,
        "skipped": 0,
        "failed": 0
    },
    "hits": {
        "total": 2,
        "max_score": 1.3732297,
        "hits": [
            {
                "_index": "blog",
                "_type": "article",
                "_id": "4",
                "_score": 1.3732297,
                "_source": {
                    "id": 4,
                    "title": "港媒:北京没有掉进圈套,而自欺欺人每天在香港上演",
                    "content": "当前香港上空弥漫一股“揽炒”(粤语:玉石俱焚)之风。很多年轻人似乎不在乎安危与犯法,要与执法者抱着一起“与汝皆亡”。激进氛围像一种流行病,开始蔓延,但立刻暴露出幼稚的双重标准。一些专业人士也学街头斗士,戴上口罩抗议警察暴力,却不谴责动乱者对旅客施私刑,丢汽油弹烧伤警察。"
                }
            },
            {
                "_index": "blog",
                "_type": "article",
                "_id": "3",
                "_score": 0.2876821,
                "_source": {
                    "id": 3,
                    "title": "50岁带仨娃,还能成功撬走世界首富,这女人不只是顶配版邓文迪",
                    "content": "大概一周前,在法国避暑天堂蓝色海岸,贝佐斯搭上传媒大亨大卫·格芬价值2亿美元的游艇,戴着Garrett Leight墨镜,趿拉着Prada凉拖,挽上新女朋友劳伦·桑切斯的手,吹着海风,品着鸡尾酒,逍遥自在地开启了度假模式 。"
                }
            }
        ]
    }
}

使用 head 插件查询

head 插件给我们提供了更方便的可视化的查询工具。

term 查询

image.png

querystring 查询

image.png


如果这篇文章对您有帮助,可点击下方链接分享给你的朋友们😋,如果遇到问题欢迎评论、留言~~~😇

评论

公众号:zze_coding

Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×