[#3] MongoDB Implementation

Author: Anand Rajneesh

pom.xml

@@ -13,9 +13,9 @@
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <java.version>1.8</java.version>
         <spring.version>1.5.4.RELEASE</spring.version>
+        <nosqlunit.version>0.7.6</nosqlunit.version>
     </properties>
 
-
     <dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -49,6 +49,11 @@
             <artifactId>spring-boot-starter-log4j2</artifactId>
             <version>${spring.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-mongodb</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
         <dependency>
             <groupId>io.springfox</groupId>
             <artifactId>springfox-swagger2</artifactId>
@@ -59,6 +64,23 @@
             <artifactId>springfox-swagger-ui</artifactId>
             <version>2.7.0</version>
         </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.datatype</groupId>
+            <artifactId>jackson-datatype-jsr310</artifactId>
+            <version>2.8.6</version>
+        </dependency>
+        <dependency>
+            <groupId>com.github.fakemongo</groupId>
+            <artifactId>fongo</artifactId>
+            <version>2.0.6</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.lordofthejars</groupId>
+            <artifactId>nosqlunit-mongodb</artifactId>
+            <version>${nosqlunit.version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/org/gluecoders/library/config/Database.java

@@ -0,0 +1,39 @@
+package org.gluecoders.library.config;
+
+import com.mongodb.BasicDBObject;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.convert.converter.Converter;
+import org.springframework.data.mongodb.MongoDbFactory;
+import org.springframework.data.mongodb.core.convert.CustomConversions;
+
+import java.time.YearMonth;
+import java.util.Arrays;
+
+/**
+ * Created by Anand_Rajneesh on 6/14/2017.
+ */
+@Configuration
+public class Database{
+
+    public enum YearMonthConverter implements Converter<BasicDBObject, YearMonth> {
+        INSTANCE;
+
+        private YearMonthConverter(){}
+
+        @Override
+        public YearMonth convert(BasicDBObject source) {
+            return YearMonth.of(
+                    (int) source.get("year"),
+                    (int) source.get("month")
+            );
+        }
+    }
+
+    @Bean
+    public CustomConversions customConversions(){
+        return new CustomConversions(Arrays.asList(YearMonthConverter.INSTANCE));
+    }
+
+}

src/main/java/org/gluecoders/library/config/Swagger.java

@@ -0,0 +1,26 @@
+package org.gluecoders.library.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import springfox.documentation.builders.PathSelectors;
+import springfox.documentation.builders.RequestHandlerSelectors;
+import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spring.web.plugins.Docket;
+import springfox.documentation.swagger2.annotations.EnableSwagger2;
+
+/**
+ * Created by Anand_Rajneesh on 6/13/2017.
+ */
+@Configuration
+@EnableSwagger2
+public class Swagger {
+
+    @Bean
+    public Docket swaggerSpringMvcPlugin() {
+        return new Docket(DocumentationType.SWAGGER_2)
+                .select()
+                .apis(RequestHandlerSelectors.any())
+                .paths(PathSelectors.any())
+                .build();
+    }
+}

src/main/java/org/gluecoders/library/config/SwaggerConfig.java

@@ -0,0 +1,14 @@
+package org.gluecoders.library.dao;
+
+import org.gluecoders.library.models.Book;
+import org.springframework.data.mongodb.repository.MongoRepository;
+import org.springframework.stereotype.Repository;
+
+/**
+ * Created by Anand_Rajneesh on 6/14/2017.
+ */
+@Repository
+public interface BookDao extends MongoRepository<Book, String> {
+
+    Book findDistinctByIsbnCode(long isbnCode);
+}

src/main/java/org/gluecoders/library/dao/BookDao.java

@@ -1,24 +1,42 @@
 package org.gluecoders.library.models;
 
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
 import java.io.Serializable;
+import java.time.Month;
+import java.time.YearMonth;
 import java.util.Arrays;
 import java.util.List;
 
 /**
  * Created by Anand_Rajneesh on 6/10/2017.
  */
+@Document(collection = "books")
 public class Book implements Serializable {
 
+    @Id @JsonIgnore
+    private String id;
     private String title;
     private String author;
-    private int publishedYear;
+    private YearMonth publishedYear;
     private List<String> categories;
     private String publisher;
     private long isbnCode;
 
+
     public Book() {
     }
 
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
     public String getTitle() {
         return title;
     }
@@ -59,14 +77,6 @@ public void setIsbnCode(long isbnCode) {
         this.isbnCode = isbnCode;
     }
 
-    public int getPublishedYear() {
-        return publishedYear;
-    }
-
-    public void setPublishedYear(int publishedYear) {
-        this.publishedYear = publishedYear;
-    }
-
     @Override
     public boolean equals(Object obj) {
         return obj != null && obj instanceof Book && Long.compare(isbnCode, ((Book) obj).getIsbnCode()) == 0;
@@ -81,6 +91,14 @@ public static Builder builder(){
         return new Builder();
     }
 
+    public YearMonth getPublishedYear() {
+        return publishedYear;
+    }
+
+    public void setPublishedYear(YearMonth publishedYear) {
+        this.publishedYear = publishedYear;
+    }
+
     public static class Builder{
 
         private Book book = new Book();
@@ -100,8 +118,8 @@ public Builder isbn(long isbnCode){
             return this;
         }
 
-        public Builder yearOfPublishing(int year){
-            book.setPublishedYear(year);
+        public Builder yearOfPublishing(int year, Month month){
+            book.setPublishedYear(YearMonth.of(year, month));
             return this;
         }
 

src/main/java/org/gluecoders/library/models/Book.java

@@ -11,6 +11,8 @@
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
+import java.time.Month;
+import java.util.ArrayList;
 import java.util.List;
 
 /**

src/main/java/org/gluecoders/library/rest/Books.java

@@ -1,9 +1,12 @@
 package org.gluecoders.library.services;
 
+import org.gluecoders.library.dao.BookDao;
 import org.gluecoders.library.models.Book;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import java.util.Collections;
 import java.util.List;
 
 /**
@@ -12,24 +15,35 @@
 @Component
 public class DefaultBookService implements BookService {
 
+    private static final Logger LOGGER = LoggerFactory.getLogger(DefaultBookService.class);
+
+    @Autowired
+    private BookDao bookDao;
 
     @Override
     public List<Book> getAllBooks() {
-        return Collections.emptyList();
+        LOGGER.info("getAllBooks() invoked");
+        return bookDao.findAll();
     }
 
     @Override
     public Book addBook(Book book) {
-        return book;
+        LOGGER.info("Adding book {} to library",book);
+        return bookDao.save(book);
     }
 
     @Override
     public Book getBookByISBN(long isbn) {
-        return null;
+        LOGGER.info("Get Book by ISBN {}", isbn);
+        return bookDao.findDistinctByIsbnCode(isbn);
     }
 
     @Override
     public void deleteBook(long isbn) {
-
+        LOGGER.info("Delete book by isbn {}",isbn);
+        Book book = bookDao.findDistinctByIsbnCode(isbn);
+        if(book != null) {
+            bookDao.delete(book);
+        }
     }
 }

src/main/java/org/gluecoders/library/services/DefaultBookService.java

@@ -2,16 +2,13 @@
 <Configuration status="WARN">
     <Appenders>
         <Console name="Console" target="SYSTEM_OUT">
-            <JsonLayout compact="true" eventEol="true"/>
+            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
         </Console>
     </Appenders>
     <Loggers>
         <logger name="org.gluecoders.library" level="debug" additivity="false">
             <AppenderRef ref="Console"/>
         </logger>
-        <logger name="org.springframework" level="error" additivity="false">
-            <AppenderRef ref="Console"/>
-        </logger>
         <Root level="info">
             <AppenderRef ref="Console"/>
         </Root>

src/main/resources/log4j2.xml

@@ -0,0 +1,17 @@
+package org.gluecoders.library.config;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.BlockJUnit4ClassRunner;
+import static org.junit.Assert.*;
+/**
+ * Created by Anand_Rajneesh on 6/14/2017.
+ */
+@RunWith(BlockJUnit4ClassRunner.class)
+public class SwaggerTest {
+
+    @Test
+    public void testSwaggerSpringMvcPlugin(){
+        assertNotNull(new Swagger().swaggerSpringMvcPlugin());
+    }
+}