add mongo repository

hr-microservice-hexagonal/pom.xml

@@ -81,6 +81,10 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-websocket</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-mongodb</artifactId>
+		</dependency>
 	</dependencies>
 
 	<build>

hr-microservice-hexagonal/src/main/java/com/example/hr/HrMicroserviceHexagonalApplication.java

@@ -1,18 +1,48 @@
 package com.example.hr;
 
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
+import com.example.hr.adapter.EmployeeRepositoryMongoAdapter;
+import com.example.hr.document.EmployeeDocument;
+import com.example.hr.domain.Department;
+import com.example.hr.domain.Employee;
+import com.example.hr.domain.MoneyCurrency;
+import com.example.hr.repository.EmployeeMongoRepository;
+
 /**
  * 
  * @author Binnur Kurt <binnur.kurt@gmail.com>
  *
  */
 @SpringBootApplication
-public class HrMicroserviceHexagonalApplication {
-
+public class HrMicroserviceHexagonalApplication implements ApplicationRunner {
+	@Autowired private EmployeeRepositoryMongoAdapter mongoAdapter;
+	@Autowired private EmployeeMongoRepository mongoRepo;
+
 	public static void main(String[] args) {
 		SpringApplication.run(HrMicroserviceHexagonalApplication.class, args);
 	}
 
+	@Override
+	public void run(ApplicationArguments args) throws Exception {
+		/*
+		 Employee jack = new Employee.Builder("40310900232").fullname("jack", "bauer").birthYear(1956)
+				.salary(100_000, MoneyCurrency.USD).iban("TR820006235455781668847562").fulltime(true)
+				.department(Department.IT)
+				.photo("iVBORw0KGgoAAAANSUhEUgAAAIAAAACACAMAAAD04JH5AAABC1BMVEX///8AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAADXsw3hAAAAWXRSTlMAWQFYVwIlVUpSTypIR0wSKBFFAw9WCRo/OgUvQjMNIR5EBhBOLiIZExRTCjsdDlBBHD1UQwc4Sx8wQC0kKxtGBAwsPDEnMhU0N00gOSlJNSYjURY+CxcINmo6xHsAAATwSURBVHhe7Ztnbxs5EIbfGXK16l22VSwXufcax70kju30enf//5ccJDsXCPJyaK3I4BA/XwQLEN6Hs/SSw5Xwf+IZZnSZ7YwnmncTM8l0KtSKSIepuWyr/qa4vvQ3ujCzk3gAaE/dlr9SJCvZ99fLjZ6Di/jCcU5TD9WFegy+kV6bWh21AwMXX8oPSWTgQSPcWa8APML4RibdSycbehJvM/ujUmDgZHMgXXZYuWqAeRTxSzkiTU9FE21OxS9CADQN8ZLC0VhMA0Y7S6RoSBSF07GKwJjWwvDFIkwOb8DAqTB8GUUzswiGzT+k+GhKtxEMlz9JaiQGu6VhDOR8e4NwCANGU8i3R9FKG/zU/CKNDkVvG08zCLBNo0TT1lPvPzVSNEIUXT2tBDlSNGKW7A0YxyPPV5SDfX5V0chRlEBgK7BDDgwoXbHNXyIXKLpGYCfw3qoASvXvBGUO2C5/NSSJB0OdSs9t7j68IaJoHGwj8JmURXzy7uTb5X4luBgrvXydUxYKiup2Ai1SUnx6voQ+Nk7zFgqpWVgwFkoD0R8qALgLgJ8vX76Skq+BBdukzPn5DhAw+uAAaKyJpXsNCw6NAor2AgQRG+hJyb0MC7ZIGbd4QBDZQgg1sJoEwZxxDHOGhZ3BScGgAJFLLaxpgUEey8IkmIbIN2MBjk35AKNuvoAZiEyRis7PM4wwbqRbkcipSeCluJzwAZlIQuQ2UkBZfJxxZ5yGNYjUDQKfwaJAwihAsW4D4aqFwCIZgUg2SkDREUQYhbgCedP/EMsCGzqmQJoiWbQRaBsFQoisUBSqGr8CWxAJKYrdMRuBEsW8E973ZGoATal9G4HtuDsSiuaHhYB5TxCuQuQgf5BMfsxmc7nzcnlmb6/V2jqamPi+82qnvioLIMibCnAOGY5z2s4YFxbTJ8J92AhMkBL2Iy5h3IgNcnzknkJYzNwR4CUpoS9xCWM/ZbwCTQRwijADwzhH5/FPFhXNOy0AM67JyGbDZQEYuBJagimXBQgQ1IX8FhzCuJR6slob7C4e6yFpMvIOgbt8niSpL58HO4tHJ0tmFN26nP0fiLSQ/wlgV/HVsnw4degwPyMPn4qu8gOMzUjD16TPwHCUX1ghTUJ+vupqBWBs1OTyr1Xc5V/MieWnBMAOF38tDD9bBbvKD5AhJQy/6XD4jI509ZPLAMMdM6SMw59nl/EsbH8pWwIYLjEs/4po0nE8Y9uYv+A4H4zvhrO82l9gx/mGhyqKwoLz9oOxbrgCy87zwXgTLTDtPh+MPVKRD4UY7qmkDcf57gUYP3T0AxGGB4FlQwE8wBh/fApomocPA45+qnPjSSBBSjiCcSxQJCU8F3UskIkQeAH2I3AaIdAE+6pATQ1So6IvgXl6FH8CheJJYpCTYhWMPwOOAn8czzzzeyf/r2D8DgcGUKmeLSQWzjoVAOw/f/HFHN2Tfj8OsO/4XN+vaz6e+VRg4FM3vO/LlS/YmwGDW//F/1IoB74MGK9IP7Ipn/BWgIVe/qBBwlMJgrcRfcHmhZ8CLEb2xtt+WsOriCNSTYd+BD51BeTGwP/5iKJ/wL+zNdRU9COwQVGUwN7uQ4NoOvLVmFxqUo+dkPpqTBjrRGow/53H1Wi6bzG8/2PK63rcOX+I/fmSLYDhDwbendMvcsIBuRMDlD6sfUztppKvMgUMnf/Mv8NIVU+cyYl6AAAAAElFTkSuQmCC"
+						.getBytes())
+				.build();
+		mongoAdapter.save(jack);
+		*/
+		List<EmployeeDocument> employees = mongoRepo.findAllByBirthYearBetweenAndDepartment(1950, 1960,Department.IT);
+		System.err.println(employees);
+		employees.forEach(System.out::println);
+	}
+
 }

hr-microservice-hexagonal/src/main/java/com/example/hr/adapter/EmployeeRepositoryAdapter.java → hr-microservice-hexagonal/src/main/java/com/example/hr/adapter/EmployeeRepositoryJpaAdapter.java

@@ -8,6 +8,8 @@
 import com.example.hr.domain.Employee;
 import com.example.hr.domain.FullName;
 import com.example.hr.domain.TcKimlikNo;
+import com.example.hr.meta.Persistence;
+import com.example.hr.meta.PersistenceTarget;
 import com.example.hr.orm.EmployeeEntity;
 import com.example.hr.repository.EmployeeJpaRepository;
 import com.example.hr.repository.EmployeeRepository;
@@ -18,7 +20,8 @@
  *
  */
 @Repository
-public class EmployeeRepositoryAdapter implements EmployeeRepository {
+@Persistence(PersistenceTarget.JPA_MYSQL)
+public class EmployeeRepositoryJpaAdapter implements EmployeeRepository {
 	@Autowired
 	private EmployeeJpaRepository empJpaRepo;
 

hr-microservice-hexagonal/src/main/java/com/example/hr/adapter/EmployeeRepositoryMongoAdapter.java

@@ -0,0 +1,55 @@
+package com.example.hr.adapter;
+
+import java.util.Optional;
+
+import org.modelmapper.ModelMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Repository;
+
+import com.example.hr.document.EmployeeDocument;
+import com.example.hr.domain.Employee;
+import com.example.hr.domain.FullName;
+import com.example.hr.domain.TcKimlikNo;
+import com.example.hr.meta.Persistence;
+import com.example.hr.meta.PersistenceTarget;
+import com.example.hr.repository.EmployeeMongoRepository;
+import com.example.hr.repository.EmployeeRepository;
+
+@Repository
+@Persistence(PersistenceTarget.MONGO)
+public class EmployeeRepositoryMongoAdapter implements EmployeeRepository{
+	@Autowired
+	private EmployeeMongoRepository empRepo;
+	@Autowired
+	private ModelMapper mapper;
+
+	@Override
+	public Optional<Employee> findByIdentity(TcKimlikNo identity) {
+		Optional<EmployeeDocument> empDoc = empRepo.findById(identity.getValue());
+		if (!empDoc.isEmpty()) return Optional.empty();
+		Employee employee = mapper.map(empDoc.get(), Employee.class);
+		return Optional.of(employee);
+	}
+
+	@Override
+	public void save(Employee employee) {
+		//EmployeeDocument empDoc= mapper.map(employee, EmployeeDocument.class);
+		EmployeeDocument employeeDocument = new EmployeeDocument();
+		employeeDocument.setIdentity(employee.getIdentityNo().getValue());
+		FullName fullname = employee.getFullname();
+		employeeDocument.setFullname(fullname.getFirst() + " " + fullname.getLast());
+		employeeDocument.setSalary(employee.getSalary().getValue());
+		employeeDocument.setIban(employee.getIban().getValue());
+		employeeDocument.setPhoto(new String(employee.getPhoto().getValue()));
+		employeeDocument.setBirthYear(employee.getBirthYear().getValue());
+		employeeDocument.setDepartment(employee.getDepartment());
+		employeeDocument.setFulltime(employee.isFulltime());
+		empRepo.save(employeeDocument);
+	}
+
+	@Override
+	public void remove(Employee employee) {
+		empRepo.deleteById(employee.getIdentityNo().getValue());		
+	}
+
+}

hr-microservice-hexagonal/src/main/java/com/example/hr/config/AppConfig.java

@@ -6,6 +6,8 @@
 import com.example.hr.application.EmployeeApplication;
 import com.example.hr.application.business.SimpleEmployeeApplication;
 import com.example.hr.infrastructure.EventPushlisher;
+import com.example.hr.meta.Persistence;
+import com.example.hr.meta.PersistenceTarget;
 import com.example.hr.repository.EmployeeRepository;
 
 /**
@@ -17,7 +19,8 @@
 public class AppConfig {
 
 	@Bean
-	public EmployeeApplication employeeApplication(EmployeeRepository employeeRepository,
+	public EmployeeApplication employeeApplication(
+			@Persistence(PersistenceTarget.JPA_MYSQL) EmployeeRepository employeeRepository,
 			EventPushlisher eventPushlisher) {
 		SimpleEmployeeApplication employeeApplication = new SimpleEmployeeApplication();
 		employeeApplication.setEmployeeRepository(employeeRepository);

hr-microservice-hexagonal/src/main/java/com/example/hr/config/ModelMapperConfig.java

@@ -5,7 +5,9 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import com.example.hr.document.EmployeeDocument;
 import com.example.hr.domain.Employee;
+import com.example.hr.domain.FullName;
 import com.example.hr.domain.MoneyCurrency;
 import com.example.hr.dto.EmployeeRequest;
 
@@ -33,6 +35,38 @@ public ModelMapper modelMapper() {
 					.birthYear(employeeRequest.getBirthYear()).fulltime(employeeRequest.isFulltime())
 					.department(employeeRequest.getDepartment()).photo(employeeRequest.getPhoto()).build();
 		});
+		TypeMap<EmployeeDocument, Employee> employeeDocumentToEmployeeTypeMap = mapper
+				.getTypeMap(EmployeeDocument.class, Employee.class);
+		if (employeeDocumentToEmployeeTypeMap == null) {
+			employeeDocumentToEmployeeTypeMap = mapper.createTypeMap(EmployeeDocument.class, Employee.class);
+		}
+		employeeRequestToEmployeeTypeMap.setProvider(provisionRequest -> {
+			var employeeDocument = EmployeeDocument.class.cast(provisionRequest.getSource());
+			String[] tokens = employeeDocument.getFullname().split("\\w+");
+			return new Employee.Builder(employeeDocument.getIdentity()).fullname(tokens[0], tokens[1])
+					.iban(employeeDocument.getIban()).salary(employeeDocument.getSalary(), MoneyCurrency.TL)
+					.birthYear(employeeDocument.getBirthYear()).fulltime(employeeDocument.getFulltime())
+					.department(employeeDocument.getDepartment()).photo(employeeDocument.getPhoto().getBytes()).build();
+		});
+		TypeMap<Employee, EmployeeDocument> employeeToEmployeeDocumentTypeMap = mapper.getTypeMap(Employee.class,
+				EmployeeDocument.class);
+		if (employeeToEmployeeDocumentTypeMap == null) {
+			employeeToEmployeeDocumentTypeMap = mapper.createTypeMap(Employee.class, EmployeeDocument.class);
+		}
+		employeeToEmployeeDocumentTypeMap.setProvider(provisionRequest -> {
+			var employee = Employee.class.cast(provisionRequest.getSource());
+			EmployeeDocument employeeDocument = new EmployeeDocument();
+			employeeDocument.setIdentity(employee.getIdentityNo().getValue());
+			FullName fullname = employee.getFullname();
+			employeeDocument.setFullname(fullname.getFirst() + " " + fullname.getLast());
+			employeeDocument.setSalary(employee.getSalary().getValue());
+			employeeDocument.setIban(employee.getIban().getValue());
+			employeeDocument.setPhoto(new String(employee.getPhoto().getValue()));
+			employeeDocument.setBirthYear(employee.getBirthYear().getValue());
+			employeeDocument.setDepartment(employee.getDepartment());
+			employeeDocument.setFulltime(employee.isFulltime());
+			return employeeDocument;
+		});
 		return mapper;
 	}
 }

hr-microservice-hexagonal/src/main/java/com/example/hr/document/EmployeeDocument.java

@@ -0,0 +1,140 @@
+package com.example.hr.document;
+
+import javax.validation.constraints.Max;
+import javax.validation.constraints.Min;
+import javax.validation.constraints.Size;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import com.example.hr.domain.Department;
+import com.example.validation.Iban;
+import com.example.validation.TcKimlikNo;
+
+@Document(collection = "employees")
+public class EmployeeDocument {
+	@TcKimlikNo
+	@Id
+	private String identity;
+	@Size(min = 5)
+	private String fullname;
+	@Min(3_000)
+	private Double salary;
+	@Iban
+	private String iban;
+	private Boolean fulltime;
+	@Max(2002)
+	private int birthYear;
+	private String photo;
+	private Department department;
+
+	public EmployeeDocument() {
+	}
+
+	public EmployeeDocument(String identity, @Size(min = 5) String fullname, @Min(3000) Double salary, String iban,
+			Boolean fulltime, @Max(2002) int birthYear, Department department) {
+		this.identity = identity;
+		this.fullname = fullname;
+		this.salary = salary;
+		this.iban = iban;
+		this.fulltime = fulltime;
+		this.birthYear = birthYear;
+		this.department = department;
+	}
+
+	public String getIdentity() {
+		return identity;
+	}
+
+	public void setIdentity(String identity) {
+		this.identity = identity;
+	}
+
+	public String getFullname() {
+		return fullname;
+	}
+
+	public void setFullname(String fullname) {
+		this.fullname = fullname;
+	}
+
+	public Double getSalary() {
+		return salary;
+	}
+
+	public void setSalary(Double salary) {
+		this.salary = salary;
+	}
+
+	public String getIban() {
+		return iban;
+	}
+
+	public void setIban(String iban) {
+		this.iban = iban;
+	}
+
+	public Boolean getFulltime() {
+		return fulltime;
+	}
+
+	public void setFulltime(Boolean fulltime) {
+		this.fulltime = fulltime;
+	}
+
+	public int getBirthYear() {
+		return birthYear;
+	}
+
+	public void setBirthYear(int birthYear) {
+		this.birthYear = birthYear;
+	}
+
+	public String getPhoto() {
+		return photo;
+	}
+
+	public void setPhoto(String photo) {
+		this.photo = photo;
+	}
+
+	public Department getDepartment() {
+		return department;
+	}
+
+	public void setDepartment(Department department) {
+		this.department = department;
+	}
+
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((identity == null) ? 0 : identity.hashCode());
+		return result;
+	}
+
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		EmployeeDocument other = (EmployeeDocument) obj;
+		if (identity == null) {
+			if (other.identity != null)
+				return false;
+		} else if (!identity.equals(other.identity))
+			return false;
+		return true;
+	}
+
+	@Override
+	public String toString() {
+		return "EmployeeDocument [identity=" + identity + ", fullname=" + fullname + ", salary=" + salary + ", iban="
+				+ iban + ", fulltime=" + fulltime + ", birthYear=" + birthYear + ", department=" + department + "]";
+	}
+
+}

hr-microservice-hexagonal/src/main/java/com/example/hr/meta/Persistence.java

@@ -0,0 +1,15 @@
+package com.example.hr.meta;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE, ElementType.PARAMETER, ElementType.FIELD})
+@Qualifier
+public @interface Persistence {
+	PersistenceTarget value() ;
+}

hr-microservice-hexagonal/src/main/java/com/example/hr/meta/PersistenceTarget.java

@@ -0,0 +1,5 @@
+package com.example.hr.meta;
+
+public enum PersistenceTarget {
+	JPA_MYSQL, MONGO, CASSANDRA, REDIS, ELASTIC_SEARCH
+}

hr-microservice-hexagonal/src/main/java/com/example/hr/repository/EmployeeJpaRepository.java

@@ -1,7 +1,10 @@
 package com.example.hr.repository;
 
+import java.util.List;
+
 import org.springframework.data.jpa.repository.JpaRepository;
 
+import com.example.hr.document.EmployeeDocument;
 import com.example.hr.orm.EmployeeEntity;
 
 /**
@@ -10,5 +13,5 @@
  *
  */
 public interface EmployeeJpaRepository extends JpaRepository<EmployeeEntity, String> {
-
+	List<EmployeeDocument> findByBirthYearBetween(int fromYear,int toYear);		
 }