| | |
| | | |
| | | |
| | | |
| | | import com.ruoyi.service.esService; |
| | | import com.ruoyi.common.config.ElasticSearchConfig; |
| | | import com.ruoyi.common.core.domain.entity.EsModel; |
| | | import com.ruoyi.domain.ZfEvent; |
| | | import com.ruoyi.mapper.EsRepository; |
| | | import com.ruoyi.service.ZfEventService; |
| | | import com.ruoyi.service.EsService; |
| | | import org.elasticsearch.client.IndicesClient; |
| | | |
| | | import org.junit.jupiter.api.Test; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.boot.test.context.SpringBootTest; |
| | | |
| | | //@RunWith(SpringRunner.class) |
| | | //@SpringBootTest(classes = esTest.class) |
| | | import java.util.UUID; |
| | | |
| | | |
| | | @SpringBootTest |
| | | public class esTest { |
| | | @Autowired |
| | | private esService ess; |
| | | private EsService ess; |
| | | |
| | | @Autowired |
| | | private ElasticSearchConfig elas; |
| | | private EsRepository resp; |
| | | @Autowired |
| | | private ZfEventService zfEs; |
| | | |
| | | @Test |
| | | public void esUser() |
| | | { |
| | | // 操作索引的对象 |
| | | // this.elas = new ElasticSearchConfig(); |
| | | System.out.println(elas); |
| | | |
| | | IndicesClient indices = elas.client().indices(); |
| | | System.out.println(indices); |
| | | |
| | | |
| | | // CreateIndexRequest request = new CreateIndexRequest("ysx_course"); |
| | | |
| | | // request.settings(Settings.builder().put("number_of_shards", "1").put("number_of_replicas", "0")); |
| | | // System.out.println("__________________________"); |
| | | // System.out.println(ess.findByCondition("我真的很开心")); |
| | | // request.settings(Settings.builder().put("number_of_shards", "1").put("number_of_replicas", "0")); |
| | | // request.settings(Settings.builder().put("number_of_shards", "1").put("number_of_replicas", "0")); |
| | | } |
| | | @Test |
| | | public void esUs() |
| | | { |
| | | // 操作索引的对象 |
| | | System.out.println(ess); |
| | | // // 操作索引的对象 |
| | | // System.out.println(ess); |
| | | // ZfEvent zfe = new ZfEvent(); |
| | | // zfe.setId(1489); |
| | | // zfe.setRemark("大家好90"); |
| | | // zfe.setAddress("你好2"); |
| | | // zfe.setTitle("很好很好"); |
| | | // zfe.setPeople("你好"); |
| | | // zfEs.addData(zfe); |
| | | // |
| | | // System.out.println(ess); |
| | | // System.out.println("sdsdsdsds"); |
| | | // System.out.println("sdsdsdsds"); |
| | | // |
| | | // System.out.println("sdsdsdsds"); |
| | | // System.out.println(ess); |
| | | |
| | | // ess.insertTable("lis"); |
| | | // |
| | | // EsModel esModel = new EsModel(); |
| | | // Integer inte = 5688; |
| | | // String uuid = UUID.randomUUID().toString().replace("-",""); |
| | | // esModel.setId(Long.valueOf(inte)); |
| | | // esModel.setCtId(Long.valueOf(inte)); |
| | | // esModel.setCtName("3434"); |
| | | // esModel.setCtContent("大家好,才是真的好!"); |
| | | // |
| | | // //这里存储查询详情的路径 |
| | | // esModel.setBy5("/family/zfEvent"); |
| | | // resp.save(esModel); |
| | | // ess.insertTable(esModel); |
| | | |
| | | |
| | | |