提交 1fce6296 authored 作者: taojinlong's avatar taojinlong

fix: mongo 支持JDBC连接字符串

上级 b8bfedfe
...@@ -2,6 +2,7 @@ package io.dataease.dto.datasource; ...@@ -2,6 +2,7 @@ package io.dataease.dto.datasource;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import org.apache.commons.lang3.StringUtils;
@Getter @Getter
@Setter @Setter
...@@ -9,11 +10,21 @@ public class MongodbConfiguration extends JdbcConfiguration { ...@@ -9,11 +10,21 @@ public class MongodbConfiguration extends JdbcConfiguration {
private String driver = "mongodb.jdbc.MongoDriver"; private String driver = "mongodb.jdbc.MongoDriver";
private String connectionType; private String connectionType;
private String extraParams = "rebuildschema=true";
public String getJdbc() { public String getJdbc() {
return "jdbc:mongodb://HOSTNAME:PORT/DATABASE" if(StringUtils.isEmpty(extraParams.trim())){
.replace("HOSTNAME", getHost().trim()) return "jdbc:mongodb://HOSTNAME:PORT/DATABASE"
.replace("PORT", getPort().toString().trim()) .replace("HOSTNAME", getHost().trim())
.replace("DATABASE", getDataBase().trim()); .replace("PORT", getPort().toString().trim())
.replace("DATABASE", getDataBase().trim());
}else {
return "jdbc:mongodb://HOSTNAME:PORT/DATABASE?EXTRA_PARAMS"
.replace("HOSTNAME", getHost().trim())
.replace("PORT", getPort().toString().trim())
.replace("DATABASE", getDataBase().trim())
.replace("EXTRA_PARAMS", getExtraParams().trim());
}
} }
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论