anyline-master.zip

package org.anyline.entity; import com.fasterxml.jackson.annotation.JsonInclude; import com.fasterxml.jackson.databind.JsonNode; import org.anyline.entity.adapter.KeyAdapter.KEY_CASE; import org.anyline.entity.data.Column; import org.anyline.util.*; import org.anyline.util.regular.Regular; import org.anyline.util.regular.RegularUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.Serializable; import java.math.BigDecimal; import java.util.*; public class DataSet implements Collection<DataRow>, Serializable { private static final long serialVersionUID = 6443551515441660101L; protected static final Logger log = LoggerFactory.getLogger(DataSet.class); private LinkedHashMap<String, Column> metadatas= null ; // 数据类型相关(需要开启ConfigTable.IS_AUTO_CHECK_METADATA) private boolean result = true ; // 执行结果 private String code = null ; // code private Exception exception = null ; // 异常 private String message = null ; // 提示信息 private PageNavi navi = null ; // 分页 private List<String> head = null ; // 表头 private List<DataRow> rows = null ; // 数据 private List<String> primaryKeys = null ; // 主键 private String datalink = null ; // 数据连接 private String dataSource = null ; // 数据源(表|视图|XML定义SQL) private String schema = null ; // private String table = null ; // private long createTime = 0 ; // 创建时间 private long expires = -1 ; // 过期时间(毫秒) 从创建时刻计时expires毫秒后过期 private boolean isFromCache = false ; // 是否来自缓存 private boolean isAsc = false ; // private boolean isDesc = false ; // private Map<String, Object> tags = new HashMap<>() ; // 标签 /** * 创建索引 * * @param key key * @return DataSet * crateIndex("ID"); * crateIndex("ID:ASC"); */ public DataSet creatIndex(String key) { return this; } public DataSet() { rows = new ArrayList<DataRow>(); createTime = System.currentTimeMillis(); } public DataSet(List<Map<String, Object>> list) { rows = new ArrayList<DataRow>(); if (null == list) return; for (Map<String, Object> map : list) { DataRow row = new DataRow(map); rows.add(row); } } public static DataSet build(Collection<?> list, String ... fields) { return parse(list, fields); } /** * list解析成DataSet * @param list list * @param fields 如果list是二维数据 * fields 下标对应的属性(字段/key)名称 如"ID","CODE","NAME" * 如果不输入则以下标作为DataRow的key 如row.put("0","100").put("1","A01").put("2","张三"); * 如果属性数量超出list长度,取null值存入DataRow * * 如果list是一组数组 * fileds对应条目的属性值 如果不输入 则以条目的属性作DataRow的key 如"USER_ID:id","USER_NM:name" * * @return DataSet */ public static DataSet parse(Collection<?> list, String ... fields) { DataSet set = new DataSet(); if (null != list) { for (Object obj : list) { DataRow row = null; if(obj instanceof Collection){ row = DataRow.parseList((Collection)obj, fields); }else { row = DataRow.parse(obj, fields); } set.add(row); } } return set; } public static DataSet parseJson(KEY_CASE keyCase, String json) { if (null != json) { try { return parseJson(keyCase, BeanUtil.JSON_MAPPER.readTree(json)); } catch (Exception e) { } } return null; } public static DataSet parseJson(String json) { return parseJson(KEY_CASE.CONFIG, json); } public static DataSet parseJson(KEY_CASE keyCase, JsonNode json) { DataSet set = new DataSet(); if (null != json) { if (json.isArray()) { Iterator<JsonNode> items = json.iterator(); while (items.hasNext()) { JsonNode item = items.next(); set.add(DataRow.parseJson(keyCase, item)); } } } return set; } public static DataSet parseJson(JsonNode json) { return parseJson(KEY_CASE.CONFIG, json); } public DataSet setMetadatas(LinkedHashMap metadatas){ this.metadatas = metadatas; return this; } public LinkedHashMap<String, Column> getMetadatas(){ return metadatas; } public Column getMetadata(String column){ if(null == metadatas){ return null; } return metadatas.get(column.toUpperCase()); } public String getMetadataTypeName(String column){ Column col = getMetadata(column); if(null != col){ return col.getTypeName(); } return null; } public Integer getMetadataType(String column){ Column col = getMetadata(column); if(null != col){ return col.getType(); } return null; } public String getMetadataFullType(String column){ Column col = getMetadata(column); if(null != col){ return col.getFullType(); } return null; } public String getMetadataClassName(String column){ Column col = getMetadata(column); if(null != col){ return col.getClassName(); } return null; } public DataSet Camel(){ for(DataRow row:rows){ row.Camel(); } return this; } public DataSet camel(){ for(DataRow row:rows){ row.camel(); } return this; } public DataSet setIsNew(boolean bol) { for (DataRow row : rows) { row.setIsNew(bol); } return this; } /** * 移除每个条目中指定的key * * @param keys keys * @return DataSet */ public DataSet remove(String... keys) { for (DataRow row : rows) { for (String key : keys) { row.remove(key); } } return this; } public DataSet trim(){ for(DataRow row:rows){ row.trim(); } return this; } /** * 添加主键 * * @param applyItem 是否应用到集合中的DataRow 默认true * @param pks pks * @return DataSet */ public DataSet addPrimaryKey(boolean applyItem, String... pks) { if (null != pks) { List<String> list = new ArrayList<>(); for (String pk : pks) { list.add(pk); } addPrimaryKey(applyItem, list); } return this; } public DataSet addPrimaryKey(String... pks) { return addPrimaryKey(true, pks); } public DataSet addPrimaryKey(boolean applyItem, Collection<String> pks) { if (null == primaryKeys) { primaryKeys = new ArrayList<>(); } if (null == pks) { return this; } for (String pk : pks) { if (BasicUtil.isEmpty(pk)) { continue; } pk = key(pk); if (!primaryKeys.contains