提交

ibzdata-core/src/main/java/cn/ibizlab/core/data/model/POSchema.java

+package cn.ibizlab.core.data.model;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.experimental.Accessors;
+import org.apache.ibatis.mapping.VendorDatabaseIdProvider;
+import org.springframework.util.StringUtils;
+
+import java.util.HashMap;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@Accessors(chain = true)
+@JsonInclude(JsonInclude.Include.NON_EMPTY)
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class POSchema {
+
+    private String name;
+
+    private String remarks;
+
+    private String dsType;
+
+    private List<Column> columns;
+
+    private List<ForeignKeyConstraint> foreignKeyConstraints;
+
+    @JsonIgnore
+    @JSONField(serialize = false)
+    private Map<String,Column> columnMaps;
+
+    public Map<String, Column> getColumnMaps() {
+        if(columns!=null&&columnMaps==null)
+        {
+            columnMaps=new LinkedHashMap<>();
+            columns.forEach(column -> {
+                columnMaps.put(column.getName().toLowerCase(),column);
+                if((!StringUtils.isEmpty(column.getAlias()))&&column.getAlias().equalsIgnoreCase(column.getName()))
+                    columnMaps.put(column.getAlias().toLowerCase(),column);
+            });
+        }
+        return columnMaps;
+    }
+
+    public Column getColumn(String name)
+    {
+        if(getColumnMaps()!=null)
+        {
+            return columnMaps.get(name.toLowerCase());
+        }
+        return null;
+    }
+
+    @JsonIgnore
+    @JSONField(serialize = false)
+    private Column lastModifyColumn;
+    @JsonIgnore
+    @JSONField(serialize = false)
+    public Column getLastModifyField() {
+        if(columns!=null&&lastModifyColumn==null)
+            for(Column col:columns)
+                if(col.isLastModify())
+                {
+                    lastModifyColumn=col;
+                    return lastModifyColumn;
+                }
+        return lastModifyColumn;
+    }
+
+    @JsonIgnore
+    @JSONField(serialize = false)
+    private Column createTimeColumn;
+    @JsonIgnore
+    @JSONField(serialize = false)
+    public Column getCreateTimeColumn() {
+        if(columns!=null&&createTimeColumn==null)
+            for(Column col:columns)
+                if(col.isCreateTime())
+                {
+                    createTimeColumn=col;
+                    return createTimeColumn;
+                }
+        return createTimeColumn;
+    }
+
+    @JsonIgnore
+    @JSONField(serialize = false)
+    private Column tenantColumn;
+    @JsonIgnore
+    @JSONField(serialize = false)
+    public Column getTenantColumn() {
+        if(columns!=null&&tenantColumn==null)
+            for(Column col:columns)
+                if(col.isTenant())
+                {
+                    tenantColumn=col;
+                    return tenantColumn;
+                }
+        return tenantColumn;
+    }
+
+    @JsonIgnore
+    @JSONField(serialize = false)
+    private boolean logicValid=true;
+    @JsonIgnore
+    @JSONField(serialize = false)
+    public boolean isLogicValid()
+    {
+        if(logicValid&&logicValidColumn==null) {
+            if (columns != null) {
+                for (Column col:columns) {
+                    if (col.isLogicValid()) {
+                        logicValidColumn = col;
+                        return logicValid;
+                    }
+                }
+            }
+            logicValid = false;
+        }
+        return logicValid;
+    }
+
+    @JsonIgnore
+    @JSONField(serialize = false)
+    private Column logicValidColumn;
+    @JsonIgnore
+    @JSONField(serialize = false)
+    public Column getLogicValidColumn() {
+        if(logicValid&&logicValidColumn==null) {
+            if (columns != null) {
+                for (Column col:columns) {
+                    if (col.isLogicValid()) {
+                        logicValidColumn = col;
+                        return logicValidColumn;
+                    }
+                }
+            }
+            logicValid = false;
+        }
+        return logicValidColumn;
+    }
+
+    @Getter
+    @Setter
+    @NoArgsConstructor
+    @Accessors(chain = true)
+    @JsonInclude(JsonInclude.Include.NON_EMPTY)
+    @JsonIgnoreProperties(ignoreUnknown = true)
+    public static class Column{
+        private String name;
+        private String remarks;
+        private String type;
+        private Integer length;
+        private Integer precision;
+        private String defaultValue;
+        private Boolean autoIncrement;
+        private String alias;
+        private String predefined;
+        private Boolean tenant;
+
+        @JsonIgnore
+        @JSONField(serialize = false)
+        public boolean isLogicValid()
+        {
+            return "LOGICVALID".equals(this.getPredefined());
+        }
+
+        @JsonIgnore
+        @JSONField(serialize = false)
+        public boolean isLastModify()
+        {
+            return "UPDATEDATE".equals(this.getPredefined());
+        }
+
+        @JsonIgnore
+        @JSONField(serialize = false)
+        public boolean isCreateTime()
+        {
+            return "CREATEDATE".equals(this.getPredefined());
+        }
+
+        @JsonIgnore
+        @JSONField(serialize = false)
+        public boolean isTenant()
+        {
+            return "TENANT".equals(this.getPredefined());
+        }
+
+        @JsonIgnore
+        @JSONField(serialize = false)
+        public boolean isText()
+        {
+            return this.getType().toUpperCase().indexOf("TEXT")>=0||this.getType().toUpperCase().indexOf("CHAR")>=0;
+        }
+        private Constraints constraints;
+
+    }
+
+    @Getter
+    @Setter
+    @NoArgsConstructor
+    @Accessors(chain = true)
+    @JsonInclude(JsonInclude.Include.NON_EMPTY)
+    @JsonIgnoreProperties(ignoreUnknown = true)
+    public static class Constraints{
+        private Boolean nullable;
+        private Boolean primaryKey;
+        private String primaryKeyName;
+        private String foreignKeyName;
+        private String referencedTableName;
+        private String referencedColumnNames;
+
+    }
+
+    @Getter
+    @Setter
+    @NoArgsConstructor
+    @Accessors(chain = true)
+    @JsonInclude(JsonInclude.Include.NON_EMPTY)
+    @JsonIgnoreProperties(ignoreUnknown = true)
+    public static class ForeignKeyConstraint{
+        private String baseColumnNames;
+        private String baseTableName;
+        private String constraintName;
+        private String referencedTableName;
+        private String referencedColumnNames;
+        private Boolean validate;
+        private String onUpdate;
+        private String onDelete;
+
+    }
+
+    @Getter
+    @Setter
+    @NoArgsConstructor
+    @Accessors(chain = true)
+    @JsonInclude(JsonInclude.Include.NON_EMPTY)
+    @JsonIgnoreProperties(ignoreUnknown = true)
+    public static class Script{
+        private String name;
+        private String vendorProvider;
+        private String declare;
+        private String body;
+        private Map params;
+
+    }
+
+
+    public List<Script> scripts;
+
+    private static Map<String, String> provider = new HashMap<String, String>(){{
+        put("oracle", "oracle");
+        put("mysql", "mysql");
+        put("postgresql", "postgresql");
+        put("mppdb", "postgresql");
+        put("dm", "oracle");
+        put("dameng", "oracle");
+        put("gbase", "oracle");
+        put("h2", "mysql");
+    }};
+
+
+
+    public Script getScript(String name,String type)
+    {
+        if(scripts!=null)
+        {
+            String vendorProvider="mysql";
+            if((!StringUtils.isEmpty(type))&&provider.containsKey(type.toLowerCase()))
+                vendorProvider=provider.get(type.toLowerCase());
+            for(Script script:scripts)
+            {
+                if(name.equalsIgnoreCase(script.getName())&&(vendorProvider.equals(script.getVendorProvider())||StringUtils.isEmpty(script.getVendorProvider())))
+                    return script;
+            }
+        }
+        return getDefaultQueryScript();
+    }
+
+    @JsonIgnore
+    @JSONField(serialize = false)
+    public Script defaultQueryScript;
+
+    @JsonIgnore
+    @JSONField(serialize = false)
+    public Script getDefaultQueryScript()
+    {
+        if(defaultQueryScript==null)
+        {
+            defaultQueryScript=new Script();
+
+            defaultQueryScript.setName("default");
+
+            String sql="select ";
+            if(columns!=null)
+            {
+                String cols="";
+                for(Column col:columns)
+                {
+                    if(!StringUtils.isEmpty(cols))
+                        cols+=",";
+                    cols+=(col.getName());
+                    if((!StringUtils.isEmpty(col.getAlias()))&&col.getAlias().equalsIgnoreCase(col.getName()))
+                        cols+=(" as "+col.getAlias());
+                }
+                sql+=cols;
+            }
+            else
+                sql+=" * ";
+            sql += (" from "+name+" t ");
+
+            if(isLogicValid())
+            {
+                String defaultVal=this.getLogicValidColumn().getDefaultValue();
+                if(StringUtils.isEmpty(defaultVal))
+                    defaultVal="1";
+                sql += " where t."+this.getLogicValidColumn().getName()+"=";
+                if(this.getLogicValidColumn().isText())
+                    sql+=("'"+defaultVal+"'" );
+                else
+                    sql+=(defaultVal+" ");
+            }
+            defaultQueryScript.setBody(sql);
+
+
+        }
+        return defaultQueryScript;
+    }
+
+}

ibzdata-core/src/main/java/cn/ibizlab/core/data/model/PojoSchema.java

@@ -122,7 +122,7 @@ public class PojoSchema {
 
     public Map<String,PojoSchema> getProperties()
     {
-        if(!"object".equals(this.type))
+        if(!Type.object.getCode().equals(this.type))
         {
             properties=null;
             return properties;
@@ -152,7 +152,7 @@ public class PojoSchema {
 
     public Set<String> getRequired()
     {
-        if(!"object".equals(this.type))
+        if(!Type.object.getCode().equals(this.type))
         {
             required=null;
             return required;
@@ -231,4 +231,36 @@ public class PojoSchema {
         System.out.println(JSON.toJSONString(schema));
     }
 
+
+    public static enum Type {
+        string("string", "字符"),
+        integer("integer", "整型"),
+        number("number", "数值"),
+        object("object", "对象"),
+        array("array", "数组");
+        public final String code;
+        public final String name;
+
+        private Type(String code, String name) {
+            this.code = code;
+            this.name = name;
+        }
+
+        public String getCode() {
+            return code;
+        }
+
+        public String getName() {
+            return name;
+        }
+
+        @Override
+        public String toString() {
+            return "Type{" +
+                    "code='" + code + '\'' +
+                    ", name='" + name + '\'' +
+                    '}';
+        }
+    }
+
 }