elasticsearch ?

Author: tsiupa-coder

pom.xml

@@ -67,6 +67,10 @@
 			<artifactId>jakarta.xml.bind-api</artifactId>
 			<version>2.3.3</version>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
+		</dependency>
 	</dependencies>
 
 

src/main/java/com/serve/api/configuration/Config.java

@@ -0,0 +1,31 @@
+package com.serve.api.configuration;
+
+import org.elasticsearch.client.RestHighLevelClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.elasticsearch.client.ClientConfiguration;
+import org.springframework.data.elasticsearch.client.RestClients;
+import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration;
+import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
+
+@Configuration
+@EnableElasticsearchRepositories(basePackages = "com.serve.api.repository")
+@ComponentScan(basePackages = "com.serve.api")
+public class Config extends AbstractElasticsearchConfiguration {
+
+    @Value("${elasticsearch.url}")
+    public String elasticsearchUrl;
+
+    @Bean
+    @Override
+    public RestHighLevelClient elasticsearchClient() {
+
+        final ClientConfiguration config = ClientConfiguration.builder()
+                .connectedTo(elasticsearchUrl)
+                .build();
+
+        return RestClients.create(config).rest();
+    }
+}

src/main/java/com/serve/api/model/document/Staff.java

@@ -0,0 +1,35 @@
+package com.serve.api.model.document;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.elasticsearch.annotations.Document;
+import org.springframework.data.elasticsearch.annotations.Field;
+import org.springframework.data.elasticsearch.annotations.FieldType;
+import org.springframework.data.elasticsearch.annotations.Setting;
+
+@Document(indexName = "staff")
+@Setting(settingPath = "static/es-settings.json")
+public class Staff {
+
+    @Id
+    @Field(type = FieldType.Keyword)
+    public Long id;
+
+    @Field(type = FieldType.Text)
+    public String name;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+}

src/main/java/com/serve/api/repository/StaffRepository.java

@@ -0,0 +1,9 @@
+package com.serve.api.repository;
+
+import com.serve.api.model.document.Staff;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface StaffRepository extends ElasticsearchRepository<Staff, Long> {
+}

src/main/java/com/serve/api/service/ArriveService.java

@@ -3,7 +3,6 @@
 import com.serve.api.dto.ArriveDto;
 import com.serve.api.mapper.ArriveMapper;
 import com.serve.api.model.entity.Arrive;
-import com.serve.api.model.entity.Worker;
 import com.serve.api.model.enumeration.Type;
 import com.serve.api.repository.ArriveRepository;
 import com.serve.api.repository.CompanyRepository;
@@ -13,11 +12,9 @@
 import lombok.experimental.FieldDefaults;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.security.core.context.SecurityContextHolder;
-import org.springframework.security.core.userdetails.UserDetails;
+
 import org.springframework.stereotype.Service;
 
-import java.time.Duration;
 import java.time.Period;
 import java.util.Date;
 import java.util.List;

src/main/java/com/serve/api/service/StaffService.java

@@ -0,0 +1,25 @@
+package com.serve.api.service;
+
+import com.serve.api.model.document.Staff;
+import com.serve.api.repository.StaffRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class StaffService {
+
+    private final StaffRepository repository;
+
+    @Autowired
+    public StaffService(StaffRepository repository) {
+        this.repository = repository;
+    }
+
+    public void save(final Staff staff){
+        repository.save(staff);
+    }
+
+    public Staff findById(final Long id){
+        return repository.findById(id).orElse(null);
+    }
+}

src/main/resources/application.properties

@@ -7,3 +7,5 @@ spring.datasource.password=apiuser
 spring.jpa.hibernate.ddl-auto=update
 spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.PostgreSQLDialect
 spring.liquibase.change-log=db/changelog/db/changelog/db.changelog-master.xml
+
+elasticsearch.url = localhost:9200

src/main/resources/static/es-settings.json

@@ -0,0 +1,5 @@
+{
+  "index" : {
+
+  }
+}