Mule Mysql connector support

Author: sanagaraj-pivotal

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

@@ -0,0 +1,60 @@
+/*
+ * 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.MySqlDatabaseConfigType;
+import org.mulesoft.schema.mule.db.OracleDatabaseConfigType;
+import org.springframework.sbm.build.api.Dependency;
+import org.springframework.sbm.mule.api.toplevel.configuration.ConfigurationTypeAdapter;
+import org.springframework.stereotype.Component;
+
+import java.util.AbstractMap;
+import java.util.ArrayList;
+import java.util.List;
+
+@Component
+public class MysqlConfigAdapter extends ConfigurationTypeAdapter<MySqlDatabaseConfigType>  {
+    @Override
+    public String getName() {
+        return getMuleConfiguration().getName();
+    }
+
+    @Override
+    public Class getMuleConfigurationType() {
+        return MySqlDatabaseConfigType.class;
+    }
+
+    @Override
+    public List<AbstractMap.SimpleEntry<String, String>> configProperties() {
+        List<AbstractMap.SimpleEntry<String, String>> properties = new ArrayList<>();
+        properties.add(new AbstractMap.SimpleEntry<>("spring.datasource.url", "--INSERT--DB-URL-HERE-Example:--INSERT--DB-URL-HERE-Example:jdbc:mysql://localhost:3306/sonoo"));
+        properties.add(new AbstractMap.SimpleEntry<>("spring.datasource.username", "--INSERT-USER-NAME--"));
+        properties.add(new AbstractMap.SimpleEntry<>("spring.datasource.password", "--INSERT-PASSWORD--"));
+        properties.add(new AbstractMap.SimpleEntry<>("spring.datasource.driverClassName", "com.mysql.cj.jdbc.Driver"));
+        properties.add(new AbstractMap.SimpleEntry<>("spring.jpa.show-sql", "true"));
+        return properties;
+    }
+
+    @Override
+    public List<Dependency> getDependencies() {
+
+        return List.of(Dependency.builder()
+                .groupId("mysql")
+                .artifactId("mysql-connector-java")
+                .version("8.0.29")
+                .build());
+    }
+}

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

@@ -37,7 +37,7 @@
 public class HttpListenerTranslator implements MuleComponentToSpringIntegrationDslTranslator<ListenerType> {
 
     private final static String javaDslHttpListenerTemplate =
-            "return IntegrationFlows.from(Http.inboundChannelAdapter(\"${path}\")).handle((p, h) -> p)";
+            "return IntegrationFlows.from(Http.inboundGateway(\"${path}\")).handle((p, h) -> p)";
 
     @Override
     public Class<ListenerType> getSupportedMuleType() {

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

@@ -26,6 +26,7 @@
 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.InsertTranslator;
+import org.springframework.sbm.mule.actions.javadsl.translators.db.MysqlConfigAdapter;
 import org.springframework.sbm.mule.actions.javadsl.translators.db.OracleConfigAdapter;
 import org.springframework.sbm.mule.actions.javadsl.translators.db.SelectTranslator;
 import org.springframework.sbm.mule.actions.javadsl.translators.dwl.DwlTransformTranslator;
@@ -98,7 +99,8 @@ public void setup() {
                         new HttpListenerConfigTypeAdapter(),
                         new WmqConnectorTypeAdapter(),
                         new RequestConfigTypeAdapter(),
-                        new OracleConfigAdapter()
+                        new OracleConfigAdapter(),
+                        new MysqlConfigAdapter()
                 )
         );
         MuleMigrationContextFactory muleMigrationContextFactory = new MuleMigrationContextFactory(new MuleConfigurationsExtractor(configurationTypeAdapterFactory));

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

@@ -0,0 +1,76 @@
+/*
+ * 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.db;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.sbm.mule.actions.JavaDSLActionBaseTest;
+
+
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+
+public class MuleToJavaDSLMysqlDBConfigTest extends JavaDSLActionBaseTest {
+
+    private final String xml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
+            "<mule xmlns:scripting=\"http://www.mulesoft.org/schema/mule/scripting\"\n" +
+            "\txmlns=\"http://www.mulesoft.org/schema/mule/core\" xmlns:api-platform-gw=\"http://www.mulesoft.org/schema/mule/api-platform-gw\" xmlns:apikit=\"http://www.mulesoft.org/schema/mule/apikit\" xmlns:cmis=\"http://www.mulesoft.org/schema/mule/cmis\" xmlns:context=\"http://www.springframework.org/schema/context\" xmlns:db=\"http://www.mulesoft.org/schema/mule/db\" xmlns:doc=\"http://www.mulesoft.org/schema/mule/documentation\" xmlns:dw=\"http://www.mulesoft.org/schema/mule/ee/dw\" xmlns:ee=\"http://www.mulesoft.org/schema/mule/ee/core\" xmlns:http=\"http://www.mulesoft.org/schema/mule/http\" xmlns:spring=\"http://www.springframework.org/schema/beans\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:schemaLocation=\"http://www.mulesoft.org/schema/mule/scripting http://www.mulesoft.org/schema/mule/scripting/current/mule-scripting.xsd\n" +
+            "http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-current.xsd\n" +
+            "http://www.mulesoft.org/schema/mule/api-platform-gw http://www.mulesoft.org/schema/mule/api-platform-gw/current/mule-api-platform-gw.xsd\n" +
+            "http://www.mulesoft.org/schema/mule/ee/dw http://www.mulesoft.org/schema/mule/ee/dw/current/dw.xsd\n" +
+            "http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd\n" +
+            "http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd\n" +
+            "http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd\n" +
+            "http://www.mulesoft.org/schema/mule/apikit http://www.mulesoft.org/schema/mule/apikit/current/mule-apikit.xsd\n" +
+            "http://www.mulesoft.org/schema/mule/cmis http://www.mulesoft.org/schema/mule/cmis/current/mule-cmis.xsd\n" +
+            "http://www.mulesoft.org/schema/mule/db http://www.mulesoft.org/schema/mule/db/current/mule-db.xsd\n" +
+            "http://www.mulesoft.org/schema/mule/ee/core http://www.mulesoft.org/schema/mule/ee/core/current/mule-ee.xsd\">\n" +
+            "   <db:mysql-config name=\"MySQL_Configuration\" host=\"localhost\" port=\"3306\" user=\"root\" password=\"pw\" database=\"mule\" doc:name=\"MySQL Configuration\"/>\n" +
+            "    <http:listener-config name=\"http-lc-0.0.0.0-8081\" host=\"0.0.0.0\" port=\"8080\" protocol=\"HTTP\"/>\n" +
+            "</mule>";
+
+
+    @Test
+    public void fillApplicationPropertiesForDBConnection() {
+        addXMLFileToResource(xml);
+        runAction();
+        assertThat(getApplicationPropertyContent()).isEqualTo("server.port=8080\n" +
+                "spring.datasource.url=--INSERT--DB-URL-HERE-Example:--INSERT--DB-URL-HERE-Example:jdbc:mysql://localhost:3306/sonoo\n" +
+                "spring.datasource.username=--INSERT-USER-NAME--\n" +
+                "spring.datasource.password=--INSERT-PASSWORD--\n" +
+                "spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver\n" +
+                "spring.jpa.show-sql=true"
+        );
+    }
+
+
+
+    @Test
+    public void importsOracleDrivers() {
+        addXMLFileToResource(xml);
+        runAction();
+
+        Set<String> declaredDependencies = projectContext
+                .getBuildFile().getDeclaredDependencies()
+                .stream()
+                .map(dependency -> dependency.getGroupId() + ":" + dependency.getArtifactId() + ":" + dependency.getVersion())
+                .collect(Collectors.toSet());
+
+        assertThat(declaredDependencies).contains("mysql:mysql-connector-java:8.0.29");
+    }
+}

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

@@ -62,7 +62,7 @@ void httpTranslator() {
                 .build();
 
         DslSnippet snippet = apply(projectContext);
-        assertThat(snippet.getRenderedSnippet()).isEqualTo("return IntegrationFlows.from(Http.inboundChannelAdapter(\"/test\")).handle((p, h) -> p)");
+        assertThat(snippet.getRenderedSnippet()).isEqualTo("return IntegrationFlows.from(Http.inboundGateway(\"/test\")).handle((p, h) -> p)");
     }