版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_38292691/article/details/88082887
package com.njnode.elastic.beans;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import java.io.Serializable;
@Data
@Document(indexName = "njnode", type = "user")
public class User implements Serializable {
@Id
private String id;
private String name;
private Integer age;
private String phone;
}
package com.njnode.elastic.controller;
import com.njnode.elastic.beans.User;
import com.njnode.elastic.dao.UserDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Optional;
@RestController
public class UserController {
@Autowired
private UserDao userDao;
@RequestMapping("addUser")
public User addUser(@RequestBody User user) {
return userDao.save(user);
}
@RequestMapping("getUserById")
public User getUserById(String id) {
Optional<User> optionalUser = userDao.findById(id);
return optionalUser.orElse(null);
}
}
package com.njnode.elastic.dao;
import com.njnode.elastic.beans.User;
import org.springframework.data.repository.CrudRepository;
import org.springframework.stereotype.Component;
@Component
public interface UserDao extends CrudRepository<User, String> {
}
package com.njnode.elastic;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
@SpringBootApplication
@EnableElasticsearchRepositories(basePackages = "com.njnode.elastic")
public class ElasticApplication {
public static void main(String[] args) {
SpringApplication.run(ElasticApplication.class, args);
}
}
spring:
data:
elasticsearch:
cluster-nodes: 101.37.148.209:9200
cluster-name: njnode