closes #119 Add support for <db:select /> in mule

* SBM now supports DB select
* DB select component brings in the necessary dependencies
* Db Select autowires jdbc template
* Refactor: DB select removes duplicacy
* DB:Select should handle non-limited queries
* Removing unused imports

Co-authored-by: Sandeep Nagaraj (@sanagaraj-pivotal)

Author: sanagaraj-pivotal

components/sbm-recipes-mule-to-boot/src/main/java/org/springframework/sbm/mule/actions/javadsl/translators/db/SelectTranslator.java

@@ -0,0 +1,63 @@
+/*
+ * Copyright 2021 - 2022 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.sbm.mule.actions.javadsl.translators.db;
+
+import org.mulesoft.schema.mule.db.SelectMessageProcessorType;
+import org.springframework.sbm.mule.actions.javadsl.translators.Bean;
+import org.springframework.sbm.mule.actions.javadsl.translators.DslSnippet;
+import org.springframework.sbm.mule.actions.javadsl.translators.MuleComponentToSpringIntegrationDslTranslator;
+import org.springframework.sbm.mule.api.toplevel.configuration.MuleConfigurations;
+import org.springframework.stereotype.Component;
+
+import javax.xml.namespace.QName;
+import java.util.Collections;
+import java.util.Map;
+import java.util.Set;
+
+@Component
+public class SelectTranslator implements MuleComponentToSpringIntegrationDslTranslator<SelectMessageProcessorType> {
+
+    @Override
+    public Class<SelectMessageProcessorType> getSupportedMuleType() {
+        return SelectMessageProcessorType.class;
+    }
+
+    @Override
+    public DslSnippet translate(SelectMessageProcessorType component,
+                                QName name,
+                                MuleConfigurations muleConfigurations,
+                                String flowName,
+                                Map<Class, MuleComponentToSpringIntegrationDslTranslator> translatorsMap) {
+
+        String limitString = component.getMaxRows() == null ? "" : " LIMIT " + component.getMaxRows();
+
+        return new DslSnippet("// TODO: substitute expression language with appropriate java code \n" +
+                "                .handle((p, h) -> jdbcTemplate.queryForList(\"" +
+                escapeDoubleQuotes(component.getDynamicQuery())
+                + limitString + "\"))",
+                Collections.emptySet(),
+                Set.of(
+                        "org.springframework.boot:spring-boot-starter-jdbc:2.5.5",
+                        "org.springframework.integration:spring-integration-jdbc:5.5.4"
+                ),
+                Set.of(new Bean("jdbcTemplate", "org.springframework.jdbc.core.JdbcTemplate"))
+        );
+    }
+
+    private String escapeDoubleQuotes(String str) {
+        return str.replace("\"", "\\\"");
+    }
+}

components/sbm-recipes-mule-to-boot/src/test/java/org/springframework/sbm/mule/actions/JavaDSLActionBaseTest.java

@@ -24,6 +24,7 @@
 import org.springframework.sbm.mule.actions.javadsl.translators.amqp.AmqpOutboundEndpointTranslator;
 import org.springframework.sbm.mule.actions.javadsl.translators.common.ExpressionLanguageTranslator;
 import org.springframework.sbm.mule.actions.javadsl.translators.core.*;
+import org.springframework.sbm.mule.actions.javadsl.translators.db.SelectTranslator;
 import org.springframework.sbm.mule.actions.javadsl.translators.dwl.DwlTransformTranslator;
 import org.springframework.sbm.mule.actions.javadsl.translators.http.HttpListenerConfigTypeAdapter;
 import org.springframework.sbm.mule.actions.javadsl.translators.http.HttpListenerTranslator;
@@ -74,7 +75,8 @@ public void setup() {
                 new WmqInboundEndpointTranslator(),
                 new DwlTransformTranslator(),
                 new HttpRequestTranslator(),
-                new ChoiceTranslator()
+                new ChoiceTranslator(),
+                new SelectTranslator()
         );
         List<TopLevelElementFactory> topLevelTypeFactories = List.of(
                 new FlowTopLevelElementFactory(translators),

components/sbm-recipes-mule-to-boot/src/test/java/org/springframework/sbm/mule/actions/MuleToJavaDSLDBTest.java

@@ -16,13 +16,17 @@
 package org.springframework.sbm.mule.actions;
 
 import org.junit.jupiter.api.Test;
+import org.springframework.sbm.build.api.Dependency;
+
+import java.util.Set;
+import java.util.stream.Collectors;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-public class MuleToJavaDSLDBTest extends JavaDSLActionBaseTest  {
+public class MuleToJavaDSLDBTest extends JavaDSLActionBaseTest {
 
     @Test
-    public void sbmHasKnowledgeOfDBNamespace() {
+    public void translateDbSelectQuery() {
         String muleXml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
                 "\n" +
                 "<mule xmlns:db=\"http://www.mulesoft.org/schema/mule/db\" xmlns:http=\"http://www.mulesoft.org/schema/mule/http\" xmlns=\"http://www.mulesoft.org/schema/mule/core\" xmlns:doc=\"http://www.mulesoft.org/schema/mule/documentation\"\n" +
@@ -36,13 +40,24 @@ public void sbmHasKnowledgeOfDBNamespace() {
                 "    <flow name=\"dbFlow\">\n" +
                 "        <http:listener config-ref=\"HTTP_Listener_Configuration\" path=\"/\" doc:name=\"HTTP\"/>\n" +
                 "        <logger level=\"INFO\" doc:name=\"Logger\"/>\n" +
-                "        <db:select config-ref=\"MySQL_Configuration\" doc:name=\"Database\">\n" +
-                "            <db:parameterized-query/>\n" +
-                "        </db:select>\n" +
+                "        <db:select config-ref=\"MySQL_Configuration\" doc:name=\"Database\" fetchSize=\"500\" maxRows=\"500\">\n" +
+                "            <db:dynamic-query><![CDATA[SELECT * FROM STUDENTS]]></db:dynamic-query>\n" +
+                "        </db:select>" +
                 "    </flow>\n" +
                 "</mule>\n";
+
         addXMLFileToResource(muleXml);
         runAction();
+
+        Set<String> listOfImportedArtifacts = projectContext
+                .getBuildFile()
+                .getDeclaredDependencies()
+                .stream()
+                .map(Dependency::getArtifactId)
+                .collect(Collectors.toSet());
+
+        assertThat(listOfImportedArtifacts).contains("spring-integration-jdbc");
+        assertThat(listOfImportedArtifacts).contains("spring-boot-starter-jdbc");
         assertThat(projectContext.getProjectJavaSources().list()).hasSize(1);
         assertThat(projectContext.getProjectJavaSources().list().get(0).print())
                 .isEqualTo(
@@ -61,10 +76,11 @@ public void sbmHasKnowledgeOfDBNamespace() {
                                 "    }\n" +
                                 "\n" +
                                 "    @Bean\n" +
-                                "    IntegrationFlow dbFlow() {\n" +
+                                "    IntegrationFlow dbFlow(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate) {\n" +
                                 "        return IntegrationFlows.from(Http.inboundChannelAdapter(\"/\")).handle((p, h) -> p)\n" +
                                 "                .log(LoggingHandler.Level.INFO)\n" +
-                                "                //FIXME: element is not supported for conversion: <db:select/>\n" +
+                                "                // TODO: substitute expression language with appropriate java code \n" +
+                                "                .handle((p, h) -> jdbcTemplate.queryForList(\"SELECT * FROM STUDENTS LIMIT 500\"))\n" +
                                 "                .get();\n" +
                                 "    }}");
     }

components/sbm-recipes-mule-to-boot/src/test/java/org/springframework/sbm/mule/actions/javadsl/translators/db/SelectTranslatorTest.java

@@ -0,0 +1,37 @@
+package org.springframework.sbm.mule.actions.javadsl.translators.db;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mulesoft.schema.mule.db.SelectMessageProcessorType;
+import org.springframework.sbm.mule.actions.javadsl.translators.DslSnippet;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+class SelectTranslatorTest {
+
+    private final SelectTranslator target = new SelectTranslator();
+    private SelectMessageProcessorType input;
+
+    @BeforeEach
+    public void setup() {
+        input = new SelectMessageProcessorType();
+    }
+
+    @Test
+    public void itShouldEscapeDoubleQuotes() {
+
+        input.setMaxRows("500");
+        input.setDynamicQuery("Select * from Students where name like \"Sandeep\"");
+        DslSnippet output = target.translate(input, null, null, null, null);
+
+        assertThat(output.getRenderedSnippet()).isEqualTo("// TODO: substitute expression language with appropriate java code \n " + "               .handle((p, h) -> jdbcTemplate.queryForList(\"Select * from Students where name like \\\"Sandeep\\\" LIMIT 500\"))");
+    }
+
+    @Test
+    public void itShouldOmitLimitWhenMaxRowsIsNotAvailable() {
+        input.setDynamicQuery("Select * from Students where name like \"Sandeep\"");
+        DslSnippet output = target.translate(input, null, null, null, null);
+
+        assertThat(output.getRenderedSnippet()).isEqualTo("// TODO: substitute expression language with appropriate java code \n " + "               .handle((p, h) -> jdbcTemplate.queryForList(\"Select * from Students where name like \\\"Sandeep\\\"\"))");
+    }
+}