add Saving Events in DB

src/main/java/mops/gruppen2/controller/SwaggerAPIControllerExample.java

@@ -55,14 +55,16 @@ public class SwaggerAPIControllerExample {
 
     @GetMapping("/json")
     public void json() {
+        AddUserEvent aEvent = new AddUserEvent(
+                1,
+                1,
+                "Eins",
+                faker.leagueOfLegends().location(),
+                faker.name().lastName(),
+                "123@email.de");
         try {
-            serializationService.serializeEvent(new AddUserEvent(
-                    1,
-                    1,
-                    "Eins",
-                    faker.leagueOfLegends().location(),
-                    faker.name().lastName(),
-                    "123@email.de"));
+            serializationService.serializeEvent(aEvent);
+            serializationService.saveEvent(aEvent);
         } catch (JsonProcessingException e) {
             e.printStackTrace();
         }

src/main/java/mops/gruppen2/domain/EventDTO.java

@@ -1,11 +1,14 @@
 package mops.gruppen2.domain;
 
+import lombok.Data;
 import lombok.Value;
+import org.springframework.data.annotation.Id;
 import org.springframework.data.relational.core.mapping.Table;
 
-@Value
 @Table("event")
+@Data
 public class EventDTO {
+    @Id
     long event_id;
     long group_id;
     String user_id;

src/main/java/mops/gruppen2/repository/EventRepository.java

@@ -1,7 +1,8 @@
 package mops.gruppen2.repository;
 
+import mops.gruppen2.domain.EventDTO;
 import mops.gruppen2.domain.event.Event;
 import org.springframework.data.repository.CrudRepository;
 
-public interface EventRepository extends CrudRepository<Event, Long> {
+public interface EventRepository extends CrudRepository<EventDTO, Long> {
 }

src/main/java/mops/gruppen2/service/SerializationService.java

@@ -2,6 +2,7 @@ package mops.gruppen2.service;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import mops.gruppen2.domain.EventDTO;
 import mops.gruppen2.domain.event.Event;
 import mops.gruppen2.repository.EventRepository;
 import org.slf4j.Logger;
@@ -27,4 +28,17 @@ public class SerializationService {
         log.info(json);
         return json;
     }
+
+    public void saveEvent(Event event){
+        try {
+            EventDTO eventDTO = new EventDTO();
+            eventDTO.setGroup_id(event.getGroup_id());
+            eventDTO.setUser_id(event.getUser_id());
+            eventDTO.setEvent_payload(serializeEvent(event));
+            eventStore.save(eventDTO);
+        } catch (JsonProcessingException e) {
+            e.printStackTrace();
+        }
+
+    }
 }