Merge remote-tracking branch 'origin/294' into 292

Author: mgramin

pom.xml

@@ -111,6 +111,18 @@
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-transport-native-epoll</artifactId>
+            <version>4.0.27.Final</version>
+            <classifier>linux-x86_64</classifier>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-jdbc</artifactId>

src/main/kotlin/com/github/mgramin/sqlboot/sql/select/wrappers/RestSelectQuery.kt

@@ -0,0 +1,37 @@
+package com.github.mgramin.sqlboot.sql.select.wrappers
+
+import com.github.mgramin.sqlboot.sql.select.SelectQuery
+import com.google.gson.Gson
+import com.google.gson.reflect.TypeToken
+import org.springframework.http.MediaType
+import org.springframework.web.reactive.function.client.WebClient
+import reactor.core.publisher.Flux
+import reactor.core.publisher.toFlux
+
+
+class RestSelectQuery(
+        private val origin: SelectQuery,
+        private val endpoint: String
+) : SelectQuery {
+
+    override fun query() = origin.query()
+
+    override fun columns() = origin.columns()
+
+    override fun execute(variables: Map<String, Any>): Flux<Map<String, Any>> {
+        val client: List<Map<String, Any>>? = WebClient
+                .create(endpoint)
+                .get()
+                .uri("/exec?query=${origin.query()}")
+                .accept(MediaType.APPLICATION_JSON)
+                .retrieve()
+                .bodyToMono(String::class.java)
+                .map {
+                    val resultType = object : TypeToken<List<Map<String, Any>>>() {}.type
+                    return@map Gson().fromJson<List<Map<String, Any>>?>(it, resultType)
+                }
+                .block()
+        return client!!.toFlux()
+    }
+
+}

src/test/kotlin/com/github/mgramin/sqlboot/sql/select/wrappers/RestSelectQueryTest.kt

@@ -0,0 +1,36 @@
+package com.github.mgramin.sqlboot.sql.select.wrappers
+
+import com.github.mgramin.sqlboot.sql.select.SelectQuery
+import com.nhaarman.mockitokotlin2.doReturn
+import com.nhaarman.mockitokotlin2.mock
+import org.junit.jupiter.api.Test
+import kotlin.test.assertEquals
+
+/**
+ * @author Maksim Gramin (mgramin@gmail.com)
+ * @version $
+ * @since 0.1
+ */
+internal class RestSelectQueryTest {
+
+    @Test
+    fun query() {
+    }
+
+    @Test
+    fun columns() {
+    }
+
+    @Test
+    fun execute() {
+        val mockQuery = mock<SelectQuery> {
+            on { query() } doReturn "select * from processes limit 10"
+        }
+        val rows = RestSelectQuery(mockQuery, "http://5.8.181.165:8082")
+                .execute(hashMapOf())
+                .collectList()
+                .block()
+        assertEquals(10, rows.size)
+    }
+
+}