3、ES的使用

#查看所有节点
GET /_cat/nodes
#查看es健康状况
GET /_cat/health
#查看主节点
GET /_cat/master
#查看所有索引
GET /_cat/indices

PUT index_name

# 创建索引时设置字典属性（类型、分词器等）
PUT index_name
{
  "mappings": {
    "properties": {
      "objId": {
        "type": "text"
      },
      "name":{
        "type": "text",
        "analyzer": "ik_smart",
        "search_analyzer": "ik_smart"
      }
    }
  }
}

GET index_name/_settings

DELETE index_name

GET /index_name/_search

GET /index_name/types_name/id

POST /index_name/types_name/id
{
	"key":"value"
}

POST /index_name/types_name/id/_update
{
	"key":"value"
}

DELETE /index_name/types_name/id

GET /index_name/_search
{
	"query":{
		"match_all":{
			
		}
    },
    "sort":{
        "key":{
        "order":"desc[降序]|asc[升序]"
        }
    }
}

GET /index_name/_search
{
	"query":{
		"match_phrase":{
			"key":"value"
		}
	}
}

<properties>
    <elasticsearch.version>7.6.0</elasticsearch.version>
</properties>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

spring:
  #配置elasticsearch
  elasticsearch:
    rest:
      uris: http://192.168.52.128:9200

@Data
//@Document用于声明Bean对应的index库名
@Document(indexName = "userinfo")
public class UserInfo implements Serializable {
    //@Id指定该属性对应ES中的Id
    @Id
    private Integer userId;
    //@Field指定该属性对应ES中的字段，字段名就是属性名，类型是Keyword
    @Field(type = FieldType.Keyword)
    private String userName;
    @Field(type = FieldType.Integer)
    private Integer userAge;
    //属性analyzer指定了此属性使用哪种分词器
    @Field(type = FieldType.Text,analyzer = "ik_max_word")
    private String userMsg;
}

//需要交给spring容器管理
@Component
public interface UserInfoDao extends ElasticsearchRepository<UserInfo,Long> {
	/* 自定义方法
	 * 会根据方法名进行查询
	 * 如果在方法名中声明了多个字段，那么需要将这些字段都列为属性
	 */
    List<UserInfo> findByUserNameOrUserAgeOrUserMsg(String userName,Integer userAge,String userMsg);
}

public interface UserInfoService {

    boolean insert(UserInfo userInfo);

    List<UserInfo> findAllUserInfo();

    UserInfo findById(Integer i);

    List<UserInfo> findByUserNameOrUserAgeOrUserMsg(String userName,Integer userAge,String userMsg);
}

@Service
public class UserInfoServiceImpl implements UserInfoService{
    @Resource
    private UserInfoDao userInfoDao;
    @Override
    public boolean insert(UserInfo userInfo) {
        UserInfo save = userInfoDao.save(userInfo);
        return save != null;
    }

    @Override
    public List<UserInfo> findAllUserInfo() {
        Iterable<UserInfo> all = userInfoDao.findAll();
        List<UserInfo> userInfos = new ArrayList<>();
        for (UserInfo userInfo : all) {
            userInfos.add(userInfo);
        }
        return userInfos;
    }

    @Override
    public UserInfo findById(Integer i) {
        Optional<UserInfo> byId = userInfoDao.findById(i.longValue());
        UserInfo userInfo = byId.get();
        return userInfo;
    }

    @Override
    public List<UserInfo> findByUserNameOrUserAgeOrUserMsg(String userName,Integer userAge,String userMsg) {
        return userInfoDao.findByUserNameOrUserAgeOrUserMsg(userName,userAge,userMsg);
    }
}

@SpringBootTest
public class MyTest {
    @Resource
    private UserInfoService userInfoService;

    //插入一条信息
    @Test
    public void test1(){
        UserInfo userInfo = new UserInfo();
        userInfo.setUserId(3);
        userInfo.setUserAge(18);
        userInfo.setUserName("tom");
        userInfo.setUserMsg("这是一为名叫tom的老师");
        boolean b = userInfoService.insert(userInfo);
    }
    //查询所有
    @Test
    public void test2(){
        List<UserInfo> list = userInfoService.findAllUserInfo();
        System.out.println(list);
    }
    //根据id查询
    @Test
    public void test3(){
        UserInfo userInfo = userInfoService.findById(1);
        System.out.println(userInfo);
    }
    //根据名字或年龄或信息查询
    @Test
    public void test4(){
        String msg = "学生";
        List<UserInfo> list = userInfoService.findByUserNameOrUserAgeOrUserMsg(msg,25,msg);
        System.out.println(list);
    }
}