feat: 支持mongodb

backend/src/main/java/io/dataease/datasource/constants/DatasourceTypes.java

@@ -9,7 +9,7 @@ public enum DatasourceTypes {
     sqlServer("sqlServer", "sqlServer", "com.microsoft.sqlserver.jdbc.SQLServerDriver", "\"", "\"", "\"", "\""),
     de_doris("de_doris", "de_doris", "com.mysql.jdbc.Driver", "`", "`", "", ""),
     oracle("oracle", "oracle", "oracle.jdbc.driver.OracleDriver", "\"", "\"", "\"", "\""),
-    mongo("mongo", "mongodb", "com.mongodb.jdbc.MongoDriver", "`", "`", "'", "'"),
+    mongo("mongo", "mongodb", "com.mongodb.jdbc.MongoDriver", "`", "`", "\"", "\""),
     ck("ch", "ch", "ru.yandex.clickhouse.ClickHouseDriver", "`", "`", "'", "'"),
     es("es", "es", "", "\"", "\"", "\"", "\"");
 

backend/src/main/java/io/dataease/datasource/provider/JdbcProvider.java

@@ -11,11 +11,8 @@ import io.dataease.exception.DataEaseException;
 import io.dataease.i18n.Translator;
 import io.dataease.provider.QueryProvider;
 import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-
 import javax.annotation.PostConstruct;
-import javax.annotation.Resource;
 import java.beans.PropertyVetoException;
 import java.io.File;
 import java.io.IOException;
@@ -29,9 +26,6 @@ public class JdbcProvider extends DatasourceProvider {
     public ExtendedJdbcClassLoader extendedJdbcClassLoader;
     static private String FILE_PATH = "/opt/dataease/drivers";
 
-//    @Resource
-//    private WallFilter wallFilter;
-
     @PostConstruct
     public void init() throws Exception{
         ClassLoader classLoader = Thread.currentThread().getContextClassLoader();

backend/src/main/java/io/dataease/datasource/provider/ProviderFactory.java

@@ -48,6 +48,8 @@ public class ProviderFactory implements ApplicationContextAware {
                 return context.getBean("esQuery", QueryProvider.class);
             case ck:
                 return context.getBean("ckQuery", QueryProvider.class);
+            case mongo:
+                return context.getBean("mongoQuery", QueryProvider.class);
             default:
                 return context.getBean("mysqlQuery", QueryProvider.class);
         }

backend/src/main/java/io/dataease/provider/mongodb/MongoConstants.java

+package io.dataease.provider.mongodb;
+
+import io.dataease.provider.SQLConstants;
+
+import static io.dataease.datasource.constants.DatasourceTypes.mongo;
+import static io.dataease.datasource.constants.DatasourceTypes.oracle;
+
+/**
+ * @Author gin
+ * @Date 2021/7/8 7:22 下午
+ */
+public class MongoConstants extends SQLConstants {
+    public static final String KEYWORD_TABLE = "%s";
+
+    public static final String KEYWORD_FIX = "%s." + mongo.getKeywordPrefix() + "%s" + mongo.getKeywordSuffix();
+
+    public static final String ALIAS_FIX = mongo.getAliasPrefix() + "%s" + oracle.getAliasSuffix();
+
+    public static final String toInt32 = "toInt32(%s)";
+
+    public static final String toDateTime = "toDateTime(%s)";
+
+    public static final String toInt64 = "toInt64(%s)";
+
+    public static final String toFloat64 = "toFloat64(%s)";
+
+    public static final String formatDateTime = "formatDateTime(%s,'%s')";
+
+    public static final String toDecimal = "toDecimal64(%s,2)";
+
+    public static final String DEFAULT_DATE_FORMAT = "%Y-%m-%d %H:%M:%S";
+
+    public static final String WHERE_VALUE_NULL = "(NULL,'')";
+
+    public static final String WHERE_VALUE_VALUE = "'%s'";
+
+    public static final String AGG_COUNT = "COUNT(*)";
+
+    public static final String AGG_FIELD = "%s(%s)";
+
+    public static final String WHERE_BETWEEN = "'%s' AND '%s'";
+
+    public static final String BRACKETS = "(%s)";
+}

backend/src/main/java/io/dataease/service/dataset/DataSetTableService.java

@@ -1037,6 +1037,7 @@ public class DataSetTableService {
         if (CollectionUtils.isNotEmpty(fields)) {
             for (int i = 0; i < fields.size(); i++) {
                 TableFiled filed = fields.get(i);
+                System.out.println(new Gson().toJson(filed));
                 DatasetTableField datasetTableField = DatasetTableField.builder().build();
                 datasetTableField.setTableId(datasetTable.getId());
                 datasetTableField.setOriginName(filed.getFieldName());

frontend/src/views/system/datasource/DsTree.vue

@@ -163,6 +163,8 @@ export default {
         return 'MariaDB'
       } else if (type === 'ds_doris') {
         return 'Doris'
+      } else if (type === 'mongo') {
+        return 'MongoDB'
       }
     },
 

frontend/src/views/system/datasource/form.vue

@@ -158,7 +158,8 @@ export default {
         { name: 'es', label: 'Elasticsearch', type: 'es' },
         { name: 'mariadb', label: 'MariaDB', type: 'jdbc', extraParams: 'characterEncoding=UTF-8&connectTimeout=5000&useSSL=false&allowPublicKeyRetrieval=true' },
         { name: 'ds_doris', label: 'Doris', type: 'jdbc', extraParams: 'characterEncoding=UTF-8&connectTimeout=5000&useSSL=false&allowPublicKeyRetrieval=true' },
-        { name: 'ck', label: 'ClickHouse', type: 'jdbc', extraParams: '' }
+        { name: 'ck', label: 'ClickHouse', type: 'jdbc', extraParams: '' },
+        { name: 'mongo', label: 'MongoDB', type: 'jdbc', extraParams: '' }
         ],
       schemas: [],
       canEdit: false,