mongo insert document to collection

.travis.yml

@@ -12,11 +12,15 @@ before_install:
 - sudo service mysql restart
 - mysql -e 'CREATE DATABASE pandaria;' -u root -ppassword
 
+before_script:
+- mongo mydb_test --eval 'db.createUser({user:"root",pwd:"password",roles:["readWrite"]});'
+
 script:
   "./gradlew clean build -x signArchives"
 
 services:
 - mysql
+- mongodb
 
 addons:
   apt:

build.gradle

@@ -37,6 +37,8 @@ subprojects {
         json_schema_validator = '1.9.2'
 
         json_unit = '2.0.0.RC4'
+
+        mongo = '3.8.2'
     }
 
     task javadocJar(type: Jar) {

docker-compose.yml

@@ -8,3 +8,11 @@ services:
     environment:
       MYSQL_DATABASE: pandaria
       MYSQL_ROOT_PASSWORD: password
+
+  pandaria-mongo:
+    image: mongo:4.0.3
+    ports:
+    - "27017:27017"
+    environment:
+      MONGO_INITDB_ROOT_USERNAME: root
+      MONGO_INITDB_ROOT_PASSWORD: password

pandaria-mongo/build.gradle

@@ -0,0 +1,37 @@
+ext {
+    archivesBaseName = "pandaria-mongo"
+}
+
+dependencies {
+    compile(
+            project(":pandaria-core"),
+            "org.mongodb:mongodb-driver:${mongo}"
+    )
+
+    testCompile(
+            "io.cucumber:cucumber-junit:${cucumber}",
+
+            "com.github.dreamhead:moco-core:${moco}",
+            "com.github.dreamhead:moco-runner:${moco}",
+            "com.github.dreamhead:moco-junit:${moco}"
+    )
+}
+
+configurations {
+    cucumberRuntime {
+        extendsFrom testRuntime
+    }
+}
+
+task cucumber() {
+    dependsOn assemble, compileTestJava
+    doLast {
+        javaexec {
+            main = "cucumber.api.cli.Main"
+            classpath = configurations.cucumberRuntime + sourceSets.main.output + sourceSets.test.output
+            args = ['--plugin', 'pretty', '--glue', 'com.github.jakimli.pandaria', 'src/test/resources']
+        }
+    }
+}
+
+build.dependsOn tasks.cucumber

pandaria-mongo/src/main/java/com/github/jakimli/pandaria/domain/MongoClient.java

@@ -0,0 +1,32 @@
+package com.github.jakimli.pandaria.domain;
+
+import com.mongodb.client.MongoCollection;
+import com.mongodb.client.MongoDatabase;
+import org.bson.Document;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import static com.mongodb.client.MongoClients.create;
+
+@Component
+public class MongoClient {
+
+    private MongoDatabase database;
+
+    public MongoClient(
+            @Value("${mongo.db.name}") String name,
+            @Value("${mongo.connection.string}") String connection) {
+        database = create(connection).getDatabase(name);
+    }
+
+    public void insert(String collection, String document) {
+        MongoCollection<Document> collect = database.getCollection(collection);
+
+        if (collect == null) {
+            database.createCollection(collection);
+            collect = database.getCollection(collection);
+        }
+
+        collect.insertOne(Document.parse(document));
+    }
+}

pandaria-mongo/src/main/java/com/github/jakimli/pandaria/steps/MongoSteps.java

@@ -0,0 +1,16 @@
+package com.github.jakimli.pandaria.steps;
+
+import com.github.jakimli.pandaria.domain.MongoClient;
+import cucumber.api.java.en.When;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class MongoSteps {
+
+    @Autowired
+    MongoClient mongo;
+
+    @When("^collection: '([^\"]*)' insert:$")
+    public void insert(String collection, String document) {
+        mongo.insert(collection, document);
+    }
+}

pandaria-mongo/src/test/resources/application.properties

@@ -0,0 +1,2 @@
+mongo.db.name=test
+mongo.connection.string=mongodb://root:password@localhost:27017

pandaria-mongo/src/test/resources/features/mongo/mongo_insert.feature

@@ -0,0 +1,12 @@
+Feature: simple mongo insert
+  insert document into mongo collection
+
+  Background:
+    * dir: features/mongo
+
+  Scenario: insert a simple document
+
+    * collection: 'users' insert:
+    """
+    {"user": "jakim"}
+    """

settings.gradle

@@ -2,4 +2,5 @@ rootProject.name = 'pandaria'
 
 include 'pandaria-core'
 include 'pandaria-db'
+include 'pandaria-mongo'
 include 'doc'