add mongodb to query-service

.gitignore

@@ -38,3 +38,6 @@ gradle-app.setting
 # # Work around https://youtrack.jetbrains.com/issue/IDEA-116898
 # gradle/wrapper/gradle-wrapper.properties
 
+# mongo
+data
+

docker-compose-eventuate-local.yml

@@ -7,7 +7,6 @@ services:
       - 2888:2888
       - 3888:3888
 
-
   kafka:
     image: eventuateio/eventuateio-local-kafka:0.14.0
     ports:
@@ -141,3 +140,13 @@ services:
       EVENTUATELOCAL_ZOOKEEPER_CONNECTION_STRING: zookeeper:2181
       DEBUG: kafka-node:*
 
+  mongodb:
+    image: mongo:3.0.15
+    environment:
+      - MONGO_DATA_DIR=/data/db
+      - MONGO_LOG_DIR=/dev/null
+    volumes:
+      - ./data/db:/data/db
+    ports:
+      - 27017:27017
+    #command: mongod --smallfiles --logpath=/dev/null # --quiet

query-service/build.gradle

@@ -32,6 +32,7 @@ dependencies {
     compile "io.eventuate.local.java:eventuate-local-java-embedded-cdc-autoconfigure:${eventuateLocalVersion}"
 
 
+    compile("org.springframework.boot:spring-boot-starter-data-mongodb")
     compile "io.springfox:springfox-swagger2:2.2.2"
     compile 'io.springfox:springfox-swagger-ui:2.2.2'
     compileOnly 'org.projectlombok:lombok:1.16.18'

query-service/src/main/java/org/learn/eventuate/queryservice/controller/QueryController.java

@@ -0,0 +1,31 @@
+package org.learn.eventuate.queryservice.controller;
+
+import org.learn.eventuate.coreapi.ProductInfo;
+import org.learn.eventuate.queryservice.model.Order;
+import org.learn.eventuate.queryservice.repository.OrderRepository;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class QueryController {
+
+    public static final Logger log = LoggerFactory.getLogger(QueryController.class);
+
+    @Autowired
+    private OrderRepository orderRepository;
+
+    @GetMapping("/test")
+    public void getTest() {
+        orderRepository.deleteAll();
+
+        log.info("trying to persist entity");
+        orderRepository.save(new Order("testId", new ProductInfo("testProduct", "testComment", 100)));
+        orderRepository.save(new Order("testId2", new ProductInfo("testProduct2", "testComment2", 200)));
+
+        log.info("trying to retrieve data");
+        orderRepository.findAll().forEach(System.out::println);
+    }
+}

query-service/src/main/java/org/learn/eventuate/queryservice/model/Order.java

@@ -0,0 +1,31 @@
+package org.learn.eventuate.queryservice.model;
+
+import org.learn.eventuate.coreapi.ProductInfo;
+import org.springframework.data.annotation.Id;
+
+public class Order {
+
+    @Id
+    private String id;
+
+    private String orderId;
+    private ProductInfo productInfo;
+
+    public Order(String orderId, ProductInfo productInfo) {
+        this.orderId = orderId;
+        this.productInfo = productInfo;
+    }
+
+    public String getOrderId() {
+        return orderId;
+    }
+
+    public ProductInfo getProductInfo() {
+        return productInfo;
+    }
+
+    @Override
+    public String toString() {
+        return String.format("id: %s, product - %s", orderId, productInfo.getProductId());
+    }
+}

query-service/src/main/java/org/learn/eventuate/queryservice/repository/OrderRepository.java

@@ -0,0 +1,8 @@
+package org.learn.eventuate.queryservice.repository;
+
+import org.learn.eventuate.queryservice.model.Order;
+import org.springframework.data.mongodb.repository.MongoRepository;
+
+public interface OrderRepository extends MongoRepository<Order, String> {
+
+}

query-service/src/main/java/org/learn/eventuate/queryservice/subscribtion/OrderEventSubscriber.java

@@ -16,7 +16,7 @@ public class OrderEventSubscriber {
 
     @EventHandlerMethod
     public void onOrderFiledEvent(DispatchedEvent<OrderFiledEvent> dispatchedEvent) {
-        log.info("on OrderFiledEventXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX");
+
     }
 
 }

query-service/src/main/resources/application.properties

@@ -9,3 +9,5 @@ spring.jpa.hibernate.ddl-auto=create
 queryservice.orderUrl=http://${ORDER_SERVICE_URL:order-service}:8080
 queryservice.shipmentUrl=http://${SHIPMENT_SERVICE_URL:shipment-service}:8080
 queryservice.invoiceUrl=http://${INVOICE_SERVICE_URL:invoice-service}:8080
+
+spring.data.mongodb.uri=mongodb://mongodb:27017/local