提交 468c0d8d 编写于 作者: M misaya295

support es jdbc

上级 17a723b0
...@@ -131,5 +131,10 @@ public class Constants { ...@@ -131,5 +131,10 @@ public class Constants {
*/ */
public static final Object[] EMPTY_OBJECT_ARRAY = new Object[0]; public static final Object[] EMPTY_OBJECT_ARRAY = new Object[0];
/**
* The Es driver.
*/
public static final String ES_DRIVER = "org.elasticsearch.xpack.sql.jdbc.EsDriver";
} }
...@@ -13,6 +13,7 @@ import org.springframework.boot.context.properties.source.MapConfigurationProper ...@@ -13,6 +13,7 @@ import org.springframework.boot.context.properties.source.MapConfigurationProper
import org.springframework.boot.jdbc.DatabaseDriver; import org.springframework.boot.jdbc.DatabaseDriver;
import org.springframework.context.event.EventListener; import org.springframework.context.event.EventListener;
import org.springframework.util.ClassUtils; import org.springframework.util.ClassUtils;
import org.ssssssss.magicapi.core.config.Constants;
import org.ssssssss.magicapi.datasource.model.MagicDynamicDataSource; import org.ssssssss.magicapi.datasource.model.MagicDynamicDataSource;
import org.ssssssss.magicapi.core.event.FileEvent; import org.ssssssss.magicapi.core.event.FileEvent;
import org.ssssssss.magicapi.datasource.model.DataSourceInfo; import org.ssssssss.magicapi.datasource.model.DataSourceInfo;
...@@ -57,6 +58,9 @@ public class DataSourceMagicDynamicRegistry extends AbstractMagicDynamicRegistry ...@@ -57,6 +58,9 @@ public class DataSourceMagicDynamicRegistry extends AbstractMagicDynamicRegistry
protected boolean register(MappingNode<DataSourceInfo> mappingNode) { protected boolean register(MappingNode<DataSourceInfo> mappingNode) {
DataSourceInfo info = mappingNode.getEntity(); DataSourceInfo info = mappingNode.getEntity();
Map<String, Object> properties = new HashMap<>(info.getProperties()); Map<String, Object> properties = new HashMap<>(info.getProperties());
if(Constants.ES_DRIVER.equals(info.getDriverClassName())){
properties.put("defaultReadOnly", true);
}
properties.put("url", info.getUrl()); properties.put("url", info.getUrl());
properties.put("username", info.getUsername()); properties.put("username", info.getUsername());
properties.put("password", info.getPassword()); properties.put("password", info.getPassword());
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册