- Added connection to PostgreSQL database

- Added business logic that both graphql and rest will call, in order to do performance testing between them

Author: OWalla

build.gradle

@@ -7,9 +7,13 @@ buildscript {
     }
 }
 
-apply plugin: 'java'
-apply plugin: 'eclipse'
-apply plugin: 'idea'
+plugins {
+    id 'java'
+    id 'eclipse'
+    id 'idea'
+    id 'net.ltgt.apt' version '0.8'
+}
+
 apply plugin: 'org.springframework.boot'
 
 jar {
@@ -27,8 +31,17 @@ targetCompatibility = 1.8
 dependencies {
     compile 'com.graphql-java:graphql-java:2.2.0'
     compile "com.graphql-java:graphql-java-annotations:0.13.1"
+    compile "postgresql:postgresql:9.1-901-1.jdbc4"
+    compile "org.hsqldb:hsqldb:2.3.2"
+    compile "org.json:json:20140107"
+    compile("org.springframework.boot:spring-boot-starter-data-jpa")
+    compile("org.springframework.boot:spring-boot-starter-data-rest")
+    compile 'org.mapstruct:mapstruct-jdk8:1.1.0.Final'
+    compile "org.mapstruct:mapstruct-processor:1.1.0.Final"
     compile("org.springframework.boot:spring-boot-starter-web")
     testCompile('org.springframework.boot:spring-boot-starter-test')
     testCompile('com.jayway.jsonpath:json-path')
+
+    apt 'org.mapstruct:mapstruct-processor:1.1.0.Final'
 }
 

src/main/java/Application.java

@@ -0,0 +1,18 @@
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.domain.EntityScan;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.aspectj.EnableSpringConfigured;
+
+@Configuration
+@EnableAutoConfiguration
+@EnableSpringConfigured
+@SpringBootApplication
+@ComponentScan("configuration")
+public class Application {
+    public static void main(String[] args) {
+        SpringApplication.run(Application.class, args);
+    }
+}

src/main/java/bl/ProductRetriever.java

@@ -0,0 +1,42 @@
+package bl;
+
+import domain.Product;
+import jpa.ProductRepository;
+import mappers.ProductMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ProductRetriever {
+
+    @Autowired
+    ProductRepository productRepository;
+
+    @Autowired
+    ProductMapper productMapper;
+
+    public List<Product> getProducts()
+    {
+        List<jpa.Product> all = productRepository.findAll();
+        List<Product> products = productMapper.productsToProductsApi(all);
+        return products;
+    }
+
+    public List<Product> getProductsByStoreId(int store_id)
+    {
+        List<jpa.Product> all = productRepository.findByStore_id(store_id);
+        List<Product> products = productMapper.productsToProductsApi(all);
+        return products;
+    }
+
+    public Product getProduct(int product_id)
+    {
+        jpa.Product all = productRepository.findByid(product_id);
+        Product product = productMapper.productToProductApi(all);
+        return product;
+    }
+}
+
+

src/main/java/bl/StoreRetriever.java

@@ -0,0 +1,30 @@
+package bl;
+
+import domain.Store;
+import jpa.StoreRepository;
+import mappers.StoreMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+public class StoreRetriever {
+    @Autowired
+    StoreRepository storeRepository;
+
+    @Autowired
+    StoreMapper storeMapper;
+
+    public List<Store> getStores() {
+        List<jpa.Store> all = storeRepository.findAll();
+        List<Store> stores = storeMapper.storesToStoresApi(all);
+        return stores;
+    }
+
+    public Store getStore(int storeId) {
+        jpa.Store all = storeRepository.findByid(storeId);
+        Store store = storeMapper.storeToStoreApi(all);
+        return store;
+    }
+}

src/main/java/configuration/AppConfig.java

@@ -0,0 +1,10 @@
+package configuration;
+
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ComponentScan
+@ComponentScan(basePackages = {"graphql", "bl", "domain", "mappers"})
+public class AppConfig {
+}

src/main/java/configuration/MvcConfig.java

@@ -0,0 +1,11 @@
+package configuration;
+
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@EnableAutoConfiguration
+@ComponentScan(basePackages = {"endpoints"})
+public class MvcConfig {
+}

src/main/java/configuration/RepositoryConfig.java

@@ -0,0 +1,13 @@
+package configuration;
+
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.boot.autoconfigure.domain.EntityScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
+
+@Configuration
+@EnableJpaRepositories(basePackages = "jpa")
+@EnableAutoConfiguration
+@EntityScan(basePackages = {"jpa"})
+public class RepositoryConfig {
+}

src/main/java/domain/Product.java

@@ -0,0 +1,91 @@
+package domain;
+
+import graphql.fetchers.ProductStoreFetcher;
+import graphql.annotations.GraphQLDataFetcher;
+import graphql.annotations.GraphQLField;
+import graphql.annotations.GraphQLName;
+import graphql.annotations.GraphQLType;
+
+@GraphQLType
+public class Product {
+    @GraphQLField
+    @GraphQLName("product_id")
+    private int id;
+
+    @GraphQLField
+    private int store_id;
+
+    @GraphQLField
+    @GraphQLDataFetcher(ProductStoreFetcher.class)
+    private Store store;
+
+    @GraphQLField
+    private String name;
+
+    @GraphQLField
+    private String description;
+
+    @GraphQLField
+    private double price;
+
+    @GraphQLField
+    private double score;
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public double getPrice() {
+        return price;
+    }
+
+    public void setPrice(double price) {
+        this.price = price;
+    }
+
+    public double getScore() {
+        return score;
+    }
+
+    public void setScore(double score) {
+        this.score = score;
+    }
+
+    public Store getStore() {
+        return store;
+    }
+
+    public void setStore(Store store) {
+        this.store = store;
+    }
+
+    public int getStore_id() {
+        return store_id;
+    }
+
+    public void setStore_id(int store_id) {
+        this.store_id = store_id;
+    }
+
+
+}

src/main/java/domain/Store.java

@@ -0,0 +1,72 @@
+package domain;
+
+import graphql.fetchers.StoreProductsFetcher;
+import graphql.annotations.GraphQLDataFetcher;
+import graphql.annotations.GraphQLField;
+import graphql.annotations.GraphQLType;
+
+import java.util.List;
+
+@GraphQLType
+public class Store {
+    @GraphQLField
+    private int id;
+
+    @GraphQLField
+    private String name;
+
+    @GraphQLField
+    private String address;
+
+    @GraphQLField
+    private int owner;
+
+    @GraphQLField
+    private int creation_date;
+
+    @GraphQLField
+    @GraphQLDataFetcher(StoreProductsFetcher.class)
+    private List<Product> products;
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getAddress() {
+        return address;
+    }
+
+    public void setAddress(String address) {
+        this.address = address;
+    }
+
+    public int getOwner() {
+        return owner;
+    }
+
+    public void setOwner(int owner) {
+        this.owner = owner;
+    }
+
+    public int getCreation_date() {
+        return creation_date;
+    }
+
+    public void setCreation_date(int creation_date) {
+        this.creation_date = creation_date;
+    }
+
+
+}

src/main/java/endpoints/GraphQLController.java

@@ -0,0 +1,26 @@
+package endpoints;
+
+import graphql.RepositorySchema;
+import org.json.JSONObject;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@CrossOrigin(origins = "*", maxAge = 3600)
+public class GraphQLController {
+
+    @Autowired
+    private RepositorySchema repositorySchema;
+
+    @RequestMapping(value = "/graphql", method = RequestMethod.POST)
+    public Object graphql(@RequestBody String input) throws IllegalAccessException, NoSuchMethodException, InstantiationException {
+        String queryString = getQueryString(input);
+        Object execute = repositorySchema.execute(queryString);
+        return execute;
+    }
+
+    private static String getQueryString(String input) {
+        JSONObject requestQuery = new JSONObject(input);
+        return requestQuery.getString("query");
+    }
+}