Add method so that dataSourceProperties's keys are not rewritten to…

… kebab-case.
micronaut-projects · Jan 22, 2020 · 3dd96fb · 3dd96fb
1 parent 29a2848
commit 3dd96fb
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 0 deletions.
diff --git a/...-hikari/src/main/java/io/micronaut/configuration/jdbc/hikari/DatasourceConfiguration.java b/...-hikari/src/main/java/io/micronaut/configuration/jdbc/hikari/DatasourceConfiguration.java
@@ -19,9 +19,13 @@
 import com.zaxxer.hikari.HikariConfig;
 import io.micronaut.context.annotation.EachProperty;
 import io.micronaut.context.annotation.Parameter;
+import io.micronaut.core.convert.format.MapFormat;
+import io.micronaut.core.naming.conventions.StringConvention;
 import io.micronaut.jdbc.BasicJdbcConfiguration;
 import io.micronaut.jdbc.CalculatedSettings;
 
+import java.util.Map;
+
 import javax.annotation.PostConstruct;
 
 /**
@@ -164,4 +168,8 @@ public String getJndiName() {
     public void setJndiName(String jndiName) {
         setDataSourceJNDI(jndiName);
     }
+
+    public void setDataSourceProperties(@MapFormat(transformation = MapFormat.MapTransformation.FLAT, keyFormat = StringConvention.RAW) Map<String, ?> dsProperties) {
+        super.getDataSourceProperties().putAll(dsProperties);
+    }
 }
diff --git a/...src/test/groovy/io/micronaut/configuration/jdbc/hikari/DatasourceConfigurationSpec.groovy b/...src/test/groovy/io/micronaut/configuration/jdbc/hikari/DatasourceConfigurationSpec.groovy
@@ -251,4 +251,30 @@ class DatasourceConfigurationSpec extends Specification {
         applicationContext.stop()
     }
 
+    void "test data source properties"() {
+        given:
+        ApplicationContext applicationContext = new DefaultApplicationContext("test")
+        applicationContext.environment.addPropertySource(MapPropertySource.of(
+                'test',
+                ['datasources.default.data-source-properties' : ['reWriteBatchInserts' : true, 'anotherOne' : 'value']]
+        ))
+        applicationContext.start()
+
+        expect:
+        applicationContext.containsBean(DataSource)
+        applicationContext.containsBean(DatasourceConfiguration)
+
+        when:
+        HikariDataSource dataSource = applicationContext.getBean(DataSource).targetDataSource
+
+        then:
+        !dataSource.dataSourceProperties.isEmpty()
+        dataSource.dataSourceProperties.size() == 2
+        dataSource.dataSourceProperties.get('reWriteBatchInserts') == true
+        dataSource.dataSourceProperties.get('anotherOne') == 'value'
+
+        cleanup:
+        applicationContext.close()
+    }
+
 }