Save randomly generated users to MySQL database

Author: kasramp

.gitignore

@@ -25,3 +25,5 @@ hs_err_pid*
 .idea/
 target/
 *.iml
+
+.DS_Store

docker-compose.yml

@@ -44,4 +44,12 @@ services:
       KAFKA_BROKERCONNECT: kafka:29092
     healthcheck:
       test: "curl -f kafdrop:9000/actuator/health || exit 1"
-      start_period: 30s
+      start_period: 30s
+
+  mysql:
+    image: mysql:8.0.30
+    ports:
+      - "3306:3306"
+    environment:
+      - MYSQL_ROOT_PASSWORD=secret
+      - MYSQL_DATABASE=test

pom.xml

@@ -5,7 +5,7 @@
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
-		<version>2.3.4.RELEASE</version>
+		<version>2.5.14</version>
 		<relativePath/> <!-- lookup parent from repository -->
 	</parent>
 	<groupId>com.madadipouya</groupId>
@@ -16,6 +16,10 @@
 
 	<properties>
 		<java.version>11</java.version>
+		<flyway.version>7.7.3</flyway.version>
+		<flyway.url>jdbc:mysql://localhost:3306/test</flyway.url>
+		<flyway.user>root</flyway.user>
+		<flyway.password>secret</flyway.password>
 	</properties>
 
 	<dependencies>
@@ -27,6 +31,25 @@
 			<groupId>org.springframework.kafka</groupId>
 			<artifactId>spring-kafka</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>javax.validation</groupId>
+			<artifactId>validation-api</artifactId>
+			<version>2.0.1.Final</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-jpa</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>mysql</groupId>
+			<artifactId>mysql-connector-java</artifactId>
+			<scope>runtime</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.flywaydb</groupId>
+			<artifactId>flyway-core</artifactId>
+			<version>${flyway.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>io.springfox</groupId>
 			<artifactId>springfox-boot-starter</artifactId>
@@ -80,7 +103,10 @@
 				<groupId>org.springframework.boot</groupId>
 				<artifactId>spring-boot-maven-plugin</artifactId>
 			</plugin>
+			<plugin>
+				<groupId>org.flywaydb</groupId>
+				<artifactId>flyway-maven-plugin</artifactId>
+			</plugin>
 		</plugins>
 	</build>
-
 </project>

src/main/java/com/madadipouya/springkafkatest/entity/User.java

@@ -0,0 +1,53 @@
+package com.madadipouya.springkafkatest.entity;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import javax.validation.constraints.NotBlank;
+
+@Entity()
+@Table(name = "users")
+public class User {
+
+    @Id
+    private String id;
+
+    @NotBlank
+    @Column(name = "first_name", nullable = false)
+    private String firstName;
+
+    @NotBlank
+    @Column(name = "last_name", nullable = false)
+    private String lastName;
+
+    protected User() {
+
+    }
+
+    public User(String id, String firstName, String lastName) {
+        this.id = id;
+        this.firstName = firstName;
+        this.lastName = lastName;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public String getFirstName() {
+        return firstName;
+    }
+
+    public void setFirstName(String firstName) {
+        this.firstName = firstName;
+    }
+
+    public String getLastName() {
+        return lastName;
+    }
+
+    public void setLastName(String lastName) {
+        this.lastName = lastName;
+    }
+}

src/main/java/com/madadipouya/springkafkatest/repository/UserRepository.java

@@ -0,0 +1,10 @@
+package com.madadipouya.springkafkatest.repository;
+
+import com.madadipouya.springkafkatest.entity.User;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface UserRepository extends JpaRepository<User, String> {
+
+}

src/main/java/com/madadipouya/springkafkatest/service/impl/DefaultUserService.java

@@ -1,6 +1,7 @@
 package com.madadipouya.springkafkatest.service.impl;
 
 import com.madadipouya.springkafkatest.dto.User;
+import com.madadipouya.springkafkatest.repository.UserRepository;
 import com.madadipouya.springkafkatest.service.UserService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -11,8 +12,15 @@ public class DefaultUserService implements UserService {
 
     private static final Logger logger = LoggerFactory.getLogger(DefaultUserService.class);
 
+    private final UserRepository userRepository;
+
+    public DefaultUserService(UserRepository userRepository) {
+        this.userRepository = userRepository;
+    }
+
     @Override
     public void save(User user) {
         logger.info("Saving user with id = {}", user.getUuid());
+        userRepository.save(new com.madadipouya.springkafkatest.entity.User(user.getUuid(), user.getFirstName(), user.getLastName()));
     }
 }

src/main/resources/application.properties

@@ -1,3 +1,9 @@
+spring.jpa.hibernate.ddl-auto=none
+spring.datasource.hikari.maxLifetime=600000
+spring.datasource.initialization-mode=always
+spring.datasource.url=jdbc:mysql://localhost:3306/test
+spring.datasource.username=root
+spring.datasource.password=secret
 spring.kafka.bootstrap-servers=localhost:9092
 spring.kafka.topic.name=com.madadipouya.kafka.user
 spring.kafka.replication.factor=3
@@ -13,3 +19,4 @@ spring.kafka.producer.value-serializer=org.springframework.kafka.support.seriali
 spring.kafka.producer.properties.spring.json.value.default.type=com.madadipouya.springkafkatest.dto.User
 # more about default serializer and deserializer here:
 # https://docs.spring.io/spring-kafka/api/constant-values.html
+#spring.flyway.enabled=true

src/main/resources/db/migration/V1__user_table.sql

@@ -0,0 +1,7 @@
+CREATE TABLE IF NOT EXISTS users (
+    id VARCHAR(36) PRIMARY KEY,
+    first_name VARCHAR(256) NOT NULL,
+    last_name VARCHAR(256) NOT NULL,
+    CONSTRAINT uc_user_email_address UNIQUE(first_name, last_name),
+    INDEX idx_user_id (id)
+) engine=InnoDB;