map = it.next();
+ String uuid = (String) map.get("uuid");
+ int beforeSize = keysSet.size();
+ keysSet.add(uuid);
+ int afterSize = keysSet.size();
+ if (afterSize != (beforeSize + 1)) {
+ it.remove();
+ }
+ }
+ return list;
+ }
+
+
+ @Override
+ public void close() throws Exception {
+ neo4jDriver.close();
+ }
+}
diff --git a/kgBuilder-base/src/main/java/com/warmer/base/util/R.java b/kgBuilder-base/src/main/java/com/warmer/base/util/R.java
new file mode 100644
index 0000000..2eaf10e
--- /dev/null
+++ b/kgBuilder-base/src/main/java/com/warmer/base/util/R.java
@@ -0,0 +1,122 @@
+package com.warmer.base.util;
+
+import com.warmer.base.enums.ReturnStatus;
+import lombok.Data;
+
+/**
+ * 接口统一返回结果
+ *
+ * 推荐使用
+ * 成功:R.success()
+ * 成功:R.success(data)
+ * 成功:R.success(data,msg)
+ * 出错:R.error()
+ * 出错:R.error(msg)
+ * 验证型错误:R.warn(msg)
+ * 定义参数的错误:R.create(returnStatus)
+ * @param
+ */
+@Data
+public class R {
+ public int code;
+ public T data;
+ public String msg;
+
+ /**
+ * 参数验证失败
+ *
+ * @param msg
+ * @return
+ */
+ public static R warn(String msg) {
+ return new R(ReturnStatus.ValidateFailure.getValue(), msg, "");
+ }
+
+ /**
+ * 创建实例
+ *
+ * @return
+ */
+ public static R create(ReturnStatus returnStatus) {
+ return new R(returnStatus.getValue(), returnStatus.getName(), "");
+ }
+
+ /**
+ * 创建实例
+ *
+ * @return
+ */
+ public static R create(ReturnStatus returnStatus, String msg) {
+ return new R(returnStatus.getValue(), msg, "");
+ }
+
+ /**
+ * 出错
+ *
+ * @param msg
+ * @return
+ */
+ public static R error(String msg) {
+ return new R(ReturnStatus.Error.getValue(), msg, "");
+ }
+
+ /**
+ * 出错
+ *
+ * @return
+ */
+ public static R error() {
+ return new R(ReturnStatus.Error.getValue(), ReturnStatus.Error.getName(), "");
+ }
+
+ /**
+ * 成功
+ *
+ * @param
+ * @return
+ */
+ public static R success() {
+ return new R(ReturnStatus.Success.getValue(), "", "");
+ }
+
+ /**
+ * 成功
+ *
+ * @param data
+ * @param
+ * @return
+ */
+ public static R success(T data) {
+ return new R(ReturnStatus.Success.getValue(), "", data);
+ }
+ /**
+ * 成功
+ *
+ * @param msg
+ * @param
+ * @return
+ */
+ public static R success(String msg) {
+ return new R(ReturnStatus.Success.getValue(), msg, null);
+ }
+ /**
+ * 成功
+ *
+ * @param data
+ * @param
+ * @return
+ */
+ public static R success(T data, String msg) {
+ return new R(ReturnStatus.Success.getValue(), msg, data);
+ }
+
+
+ /**
+ * 私有构建方法,请使用静态方法构建实例
+ */
+ private R(int code, String msg, T data) {
+ this.code = code;
+ this.msg = msg;
+ this.data = data;
+ }
+}
diff --git a/kgBuilder-base/src/main/java/com/warmer/base/util/StringUtil.java b/kgBuilder-base/src/main/java/com/warmer/base/util/StringUtil.java
new file mode 100644
index 0000000..300f328
--- /dev/null
+++ b/kgBuilder-base/src/main/java/com/warmer/base/util/StringUtil.java
@@ -0,0 +1,76 @@
+package com.warmer.base.util;
+
+import org.apache.commons.lang3.ObjectUtils;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+public class StringUtil {
+ /*
+ * 是否为空字符串
+ * @param str
+ * @return
+ */
+ public static boolean isBlank(String str){
+ int strLen;
+ if (str == null || (strLen = str.length()) == 0) {
+ return true;
+ }
+ for (int i = 0; i < strLen; i++) {
+ if (Character.isWhitespace(str.charAt(i)) == false) {
+ return false;
+ }
+ }
+ return true;
+ }
+
+ public static boolean isNotBlank(String str){
+ return !isBlank(str);
+ }
+ /**
+ * 连接方法 类似于javascript
+ * @param join 连接字符串
+ * @param strAry 需要连接的集合
+ * @return
+ */
+ public static String join(String join,String[] strAry){
+ StringBuffer sb=new StringBuffer();
+ for(int i=0,len =strAry.length;i cols,String colName){
+ List aColCons = new ArrayList();
+ for (Map map:
+ cols) {
+ aColCons.add(ObjectUtils.toString(map.get(colName)));
+ }
+ return join(join,aColCons);
+ }
+
+ public static String join(String join,List listStr){
+ StringBuffer sb=new StringBuffer();
+ for(int i=0,len =listStr.size();i
+
+ 4.0.0
+
+ com.warmer
+ kgbuilder
+ 0.0.1
+ ../pom.xml
+
+ com.warmer
+ kgBuilder-meta
+ 0.0.1
+ kgBuilder-meta
+ Demo project for Spring Boot
+
+
+
+ com.warmer
+ kgBuilder-base
+ 0.0.1
+
+
+
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/dao/MetaDataColumnDao.java b/kgBuilder-meta/src/main/java/com/warmer/meta/dao/MetaDataColumnDao.java
new file mode 100644
index 0000000..9c22759
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/dao/MetaDataColumnDao.java
@@ -0,0 +1,57 @@
+package com.warmer.meta.dao;
+
+import com.warmer.meta.entity.MetaDataColumn;
+import com.warmer.meta.vo.DataTableVo;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import java.util.List;
+
+/**
+ * (MetaDataColumn)表数据库访问层
+ *
+ * @author tanc
+ * @since 2021-11-21 11:00:14
+ */
+@Mapper
+public interface MetaDataColumnDao {
+
+ /**
+ * 通过ID查询单条数据
+ *
+ * @param dataColumnId 主键
+ * @return 实例对象
+ */
+ MetaDataColumn queryById(Integer dataColumnId);
+
+ /**
+ * 通过实体作为筛选条件查询
+ *
+ * @return 对象列表
+ */
+ List queryAll();
+ List queryByTableId(@Param("dataTableId") Integer dataTableId);
+ /**
+ * 新增数据
+ *
+ * @param metaDataColumn 实例对象
+ * @return 影响行数
+ */
+ int insert(MetaDataColumn metaDataColumn);
+
+ /**
+ * 修改数据
+ *
+ * @param metaDataColumn 实例对象
+ * @return 影响行数
+ */
+ int update(MetaDataColumn metaDataColumn);
+
+ /**
+ * 通过主键删除数据
+ *
+ * @param dataColumnId 主键
+ * @return 影响行数
+ */
+ int deleteById(Integer dataColumnId);
+
+}
\ No newline at end of file
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/dao/MetaDataSourceDao.java b/kgBuilder-meta/src/main/java/com/warmer/meta/dao/MetaDataSourceDao.java
new file mode 100644
index 0000000..058a3d8
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/dao/MetaDataSourceDao.java
@@ -0,0 +1,56 @@
+package com.warmer.meta.dao;
+
+import com.warmer.meta.entity.MetaDataSource;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import java.util.List;
+
+/**
+ * 数据源(MetaDataSource)表数据库访问层
+ *
+ * @author tanc
+ * @since 2021-11-21 11:00:18
+ */
+@Mapper
+public interface MetaDataSourceDao {
+
+ /**
+ * 通过ID查询单条数据
+ *
+ * @param dataSourceId 主键
+ * @return 实例对象
+ */
+ MetaDataSource queryById(Integer dataSourceId);
+
+ /**
+ * 通过实体作为筛选条件查询
+ *
+ * @return 对象列表
+ */
+ List queryAll();
+
+ /**
+ * 新增数据
+ *
+ * @param metaDataSource 实例对象
+ * @return 影响行数
+ */
+ int insert(MetaDataSource metaDataSource);
+
+ /**
+ * 修改数据
+ *
+ * @param metaDataSource 实例对象
+ * @return 影响行数
+ */
+ int update(MetaDataSource metaDataSource);
+
+ /**
+ * 通过主键删除数据
+ *
+ * @param dataSourceId 主键
+ * @return 影响行数
+ */
+ int deleteById(Integer dataSourceId);
+
+}
\ No newline at end of file
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/dao/MetaDataTableDao.java b/kgBuilder-meta/src/main/java/com/warmer/meta/dao/MetaDataTableDao.java
new file mode 100644
index 0000000..47fdbc8
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/dao/MetaDataTableDao.java
@@ -0,0 +1,58 @@
+package com.warmer.meta.dao;
+
+import com.warmer.meta.entity.MetaDataTable;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import java.util.List;
+
+/**
+ * (MetaDataTable)表数据库访问层
+ *
+ * @author tanc
+ * @since 2021-11-21 11:00:21
+ */
+@Mapper
+public interface MetaDataTableDao {
+
+ /**
+ * 通过ID查询单条数据
+ *
+ * @param dataTableId 主键
+ * @return 实例对象
+ */
+ MetaDataTable queryById(Integer dataTableId);
+
+ /**
+ * 通过实体作为筛选条件查询
+ *
+ * @return 对象列表
+ */
+ List queryAll();
+ List queryByDatasourceId(@Param("datasourceId") Integer datasourceId);
+ MetaDataTable queryByDatasourceIdAndTableCode(@Param("datasourceId") Integer datasourceId,@Param("dataTableCode") String dataTableCode);
+
+ /**
+ * 新增数据
+ *
+ * @param metaDataTable 实例对象
+ * @return 影响行数
+ */
+ int insert(MetaDataTable metaDataTable);
+
+ /**
+ * 修改数据
+ *
+ * @param metaDataTable 实例对象
+ * @return 影响行数
+ */
+ int update(MetaDataTable metaDataTable);
+
+ /**
+ * 通过主键删除数据
+ *
+ * @param dataTableId 主键
+ * @return 影响行数
+ */
+ int deleteById(Integer dataTableId);
+
+}
\ No newline at end of file
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/dto/DataTableSubmitItem.java b/kgBuilder-meta/src/main/java/com/warmer/meta/dto/DataTableSubmitItem.java
new file mode 100644
index 0000000..3512623
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/dto/DataTableSubmitItem.java
@@ -0,0 +1,20 @@
+package com.warmer.meta.dto;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class DataTableSubmitItem {
+
+ private Integer dataSourceId;
+
+ private List dataTables;
+
+ public Integer getDataSourceId() {
+ return dataSourceId==null?0:dataSourceId;
+ }
+
+ public void setDataSourceId(Integer dataSourceId) {
+ this.dataSourceId = dataSourceId==null?0:dataSourceId;
+ }
+}
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/dto/DatasourceSubmitItem.java b/kgBuilder-meta/src/main/java/com/warmer/meta/dto/DatasourceSubmitItem.java
new file mode 100644
index 0000000..0d7eb35
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/dto/DatasourceSubmitItem.java
@@ -0,0 +1,85 @@
+package com.warmer.meta.dto;
+
+import com.warmer.meta.entity.MetaDataSource;
+import lombok.Data;
+import org.springframework.beans.BeanUtils;
+
+import java.util.Locale;
+
+@Data
+public class DatasourceSubmitItem {
+
+ public Integer getDataSourceId() {
+ return dataSourceId==null?0:dataSourceId;
+ }
+
+ public void setDataSourceId(Integer dataSourceId) {
+ this.dataSourceId = dataSourceId==null?0:dataSourceId;
+ }
+
+ private Integer dataSourceId;
+ /**
+ * 数据源类型
+ */
+ private String dbType;
+
+ private String driverName;
+ /**
+ * IP及端口号
+ */
+ private String ipAndPort;
+ /**
+ * 数据库别名
+ */
+ private String dbName;
+ /**
+ * 数据库名称
+ */
+ private String dbCode;
+ /**
+ * 用户名
+ */
+ private String dbUserName;
+ /**
+ * 密码
+ */
+ private String dbPassWord;
+
+
+ public String buildConnUrl() {
+ String dbType = this.getDbType().toUpperCase();
+ String dbCode = this.getDbCode();
+ String connUrl="";
+ switch (dbType) {
+ case "MYSQL":
+ connUrl = String.format("jdbc:mysql://%s/%s?useSSL=false&serverTimezone=Asia/Shanghai", ipAndPort, dbCode);
+ break;
+ case "SQLSERVER":
+ connUrl = String.format("jdbc:sqlserver://%s;databaseName=%s", ipAndPort, dbCode);
+ break;
+ case "POSTGRESQL":
+ connUrl = String.format("jdbc:postgresql://%s", ipAndPort);
+ break;
+ case "ORACLE":
+ connUrl = String.format("jdbc:oracle:thin:@//%s/%s", ipAndPort, dbCode);
+ break;
+ case "MARIADB":
+ connUrl = String.format("jdbc:mariadb://%s/%s", ipAndPort, dbCode);
+ break;
+ case "HIVE":
+ connUrl = String.format("jdbc:hive2://%s/%s", ipAndPort, dbCode);
+ break;
+ default:
+ return "";
+ }
+ return connUrl;
+ }
+
+ public MetaDataSource transfer(){
+ MetaDataSource source = new MetaDataSource();
+ BeanUtils.copyProperties(this, source);
+ source.setConnectUrl(this.buildConnUrl());
+ source.setIPAndPort(this.ipAndPort);
+ return source;
+ }
+}
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/entity/MetaDataColumn.java b/kgBuilder-meta/src/main/java/com/warmer/meta/entity/MetaDataColumn.java
new file mode 100644
index 0000000..33da7ae
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/entity/MetaDataColumn.java
@@ -0,0 +1,47 @@
+package com.warmer.meta.entity;
+
+import java.util.Date;
+import java.io.Serializable;
+
+import com.warmer.base.common.BaseEntity;
+import lombok.Data;
+/**
+ * (MetaDataColumn)实体类
+ *
+ * @author tanc
+ * @since 2021-11-21 11:00:13
+ */
+@Data
+public class MetaDataColumn extends BaseEntity implements Serializable {
+ private static final long serialVersionUID = 728550695358682173L;
+ /**
+ * 数据列id
+ */
+ private Integer dataColumnId;
+ /**
+ * 数据表id
+ */
+ private Integer dataTableId;
+ /**
+ * 数据列名称
+ */
+ private String dataColumnCode;
+ /**
+ * 数据列别名
+ */
+ private String dataColumnName;
+ /**
+ * 数据列描述
+ */
+ private String dataColumnComment;
+ /**
+ * 数据类型
+ */
+ private String dataColumnType;
+ /**
+ * 是否主键
+ */
+ private Integer isPrimary;
+
+
+}
\ No newline at end of file
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/entity/MetaDataSource.java b/kgBuilder-meta/src/main/java/com/warmer/meta/entity/MetaDataSource.java
new file mode 100644
index 0000000..736aace
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/entity/MetaDataSource.java
@@ -0,0 +1,64 @@
+package com.warmer.meta.entity;
+
+import java.util.Date;
+import java.io.Serializable;
+
+import com.warmer.base.common.BaseEntity;
+import lombok.Data;
+/**
+ * 数据源(MetaDataSource)实体类
+ *
+ * @author tanc
+ * @since 2021-11-21 11:00:17
+ */
+@Data
+public class MetaDataSource extends BaseEntity implements Serializable {
+ private static final long serialVersionUID = 931209553011500059L;
+ /**
+ * 数据源主键
+ */
+ private Integer dataSourceId;
+ /**
+ * 数据源类型
+ */
+ private String dbType;
+
+ private String driverName;
+ /**
+ * IP及端口号
+ */
+ private String iPAndPort;
+ /**
+ * url
+ */
+ private String connectUrl;
+ /**
+ * 数据库别名
+ */
+ private String dbName;
+ /**
+ * 数据库名称
+ */
+ private String dbCode;
+ /**
+ * 用户名
+ */
+ private String dbUserName;
+ /**
+ * 密码
+ */
+ private String dbPassWord;
+ /**
+ * 最大连接数
+ */
+ private Integer maxPoolSize;
+ /**
+ * 数据库编码
+ */
+ private String databaseCoding;
+ /**
+ * 转换编码
+ */
+ private String transcoding;
+
+}
\ No newline at end of file
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/entity/MetaDataTable.java b/kgBuilder-meta/src/main/java/com/warmer/meta/entity/MetaDataTable.java
new file mode 100644
index 0000000..79a6075
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/entity/MetaDataTable.java
@@ -0,0 +1,35 @@
+package com.warmer.meta.entity;
+
+import java.util.Date;
+import java.io.Serializable;
+
+import com.warmer.base.common.BaseEntity;
+import lombok.Data;
+/**
+ * (MetaDataTable)实体类
+ *
+ * @author tanc
+ * @since 2021-11-21 11:00:20
+ */
+@Data
+public class MetaDataTable extends BaseEntity implements Serializable {
+ private static final long serialVersionUID = 146313789945681038L;
+ /**
+ * 数据表主键
+ */
+ private Integer dataTableId;
+ /**
+ * 数据源id
+ */
+ private Integer datasourceId;
+ /**
+ * 表名
+ */
+ private String dataTableCode;
+ /**
+ * 表别名
+ */
+ private String dataTableName;
+
+
+}
\ No newline at end of file
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/query/TableQuery.java b/kgBuilder-meta/src/main/java/com/warmer/meta/query/TableQuery.java
new file mode 100644
index 0000000..c8887aa
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/query/TableQuery.java
@@ -0,0 +1,15 @@
+package com.warmer.meta.query;
+
+import com.warmer.base.common.FieldQueryItem;
+import com.warmer.base.common.PageQuery;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class TableQuery extends PageQuery {
+ private Integer dataSourceId;
+ private Integer dataTableId;
+ private String dataTableName;
+ private List filterItems;
+}
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/service/MetaDataColumnService.java b/kgBuilder-meta/src/main/java/com/warmer/meta/service/MetaDataColumnService.java
new file mode 100644
index 0000000..86243f4
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/service/MetaDataColumnService.java
@@ -0,0 +1,57 @@
+package com.warmer.meta.service;
+
+import com.warmer.meta.entity.MetaDataColumn;
+import com.warmer.meta.vo.DataColumnVo;
+import com.warmer.meta.vo.DataTableVo;
+
+import java.util.List;
+
+/**
+ * (MetaDataColumn)表服务接口
+ *
+ * @author tanc
+ * @since 2021-11-21 11:00:15
+ */
+public interface MetaDataColumnService {
+
+ /**
+ * 通过ID查询单条数据
+ *
+ * @param dataColumnId 主键
+ * @return 实例对象
+ */
+ MetaDataColumn queryById(Integer dataColumnId);
+
+ /**
+ * 查询多条数据
+ *
+ * @return 对象列表
+ */
+ List queryAll();
+
+ List queryByTableId(Integer tableId);
+ /**
+ * 新增数据
+ *
+ * @param metaDataColumn 实例对象
+ * @return 实例对象
+ */
+ MetaDataColumn insert(MetaDataColumn metaDataColumn);
+
+ /**
+ * 修改数据
+ *
+ * @param metaDataColumn 实例对象
+ * @return 实例对象
+ */
+ MetaDataColumn update(MetaDataColumn metaDataColumn);
+
+ /**
+ * 通过主键删除数据
+ *
+ * @param dataColumnId 主键
+ * @return 是否成功
+ */
+ boolean deleteById(Integer dataColumnId);
+
+}
\ No newline at end of file
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/service/MetaDataSourceService.java b/kgBuilder-meta/src/main/java/com/warmer/meta/service/MetaDataSourceService.java
new file mode 100644
index 0000000..300f571
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/service/MetaDataSourceService.java
@@ -0,0 +1,61 @@
+package com.warmer.meta.service;
+
+import com.warmer.meta.entity.MetaDataSource;
+import com.warmer.meta.vo.DatasourceVo;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * 数据源(MetaDataSource)表服务接口
+ *
+ * @author tanc
+ * @since 2021-11-21 11:00:18
+ */
+public interface MetaDataSourceService {
+
+ /**
+ * 通过ID查询单条数据
+ *
+ * @param dataSourceId 主键
+ * @return 实例对象
+ */
+ MetaDataSource queryById(Integer dataSourceId);
+
+ /**
+ * 查询多条数据
+ *
+ * @return 对象列表
+ */
+ List queryAll();
+
+ List queryList();
+ /**
+ * 新增数据
+ *
+ * @param metaDataSource 实例对象
+ * @return 实例对象
+ */
+ MetaDataSource insert(MetaDataSource metaDataSource);
+
+ /**
+ * 修改数据
+ *
+ * @param metaDataSource 实例对象
+ * @return 实例对象
+ */
+ MetaDataSource update(MetaDataSource metaDataSource);
+
+ /**
+ * 通过主键删除数据
+ *
+ * @param dataSourceId 主键
+ * @return 是否成功
+ */
+ boolean deleteById(Integer dataSourceId);
+
+ HashMap>> getMetaData(MetaDataSource metaDataSource);
+
+
+}
\ No newline at end of file
diff --git a/kgBuilder-meta/src/main/java/com/warmer/meta/service/MetaDataTableService.java b/kgBuilder-meta/src/main/java/com/warmer/meta/service/MetaDataTableService.java
new file mode 100644
index 0000000..4e4be9d
--- /dev/null
+++ b/kgBuilder-meta/src/main/java/com/warmer/meta/service/MetaDataTableService.java
@@ -0,0 +1,67 @@
+package com.warmer.meta.service;
+
+import com.warmer.base.common.PageRecord;
+import com.warmer.base.util.DbUtils;
+import com.warmer.meta.dto.DataTableSubmitItem;
+import com.warmer.meta.entity.MetaDataSource;
+import com.warmer.meta.entity.MetaDataTable;
+import com.warmer.meta.query.TableQuery;
+import com.warmer.meta.vo.DataTableVo;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * (MetaDataTable)表服务接口
+ *
+ * @author tanc
+ * @since 2021-11-21 11:00:21
+ */
+public interface MetaDataTableService {
+
+ /**
+ * 通过ID查询单条数据
+ *
+ * @param dataTableId 主键
+ * @return 实例对象
+ */
+ MetaDataTable queryById(Integer dataTableId);
+
+ /**
+ * 查询多条数据
+ *
+ * @return 对象列表
+ */
+ List queryAll();
+
+ List queryByDatasourceId(Integer datasourceId);
+ /**
+ * 新增数据
+ *
+ * @param metaDataTable 实例对象
+ * @return 实例对象
+ */
+ MetaDataTable insert(MetaDataTable metaDataTable);
+ /**
+ * 修改数据
+ *
+ * @param metaDataTable 实例对象
+ * @return 实例对象
+ */
+ MetaDataTable update(MetaDataTable metaDataTable);
+
+ /**
+ * 通过主键删除数据
+ *
+ * @param dataTableId 主键
+ * @return 是否成功
+ */
+ boolean deleteById(Integer dataTableId);
+
+ ArrayList getMetaTables(MetaDataSource metaDataSource) ;
+
+ void saveTables(DataTableSubmitItem submitItem);
+
+ PageRecord