Skip to content

C
common
Commit 59d59db7 authored by 张永's avatar 张永
Browse files
Options

Merge branch 'master' of http://gitlab.egolm.com/key/common.git

parents 4a9692aa 4152889d
Show whitespace changes
Inline Side-by-side
Showing with 328 additions and 454 deletions
src/main/java/com/egolm/common/DateUtil.java
View file @ 59d59db7
package com.egolm.common;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
......
src/main/java/com/egolm/common/jdbc/dialect/AbstractDialect.java deleted 100644 → 0
View file @ 4a9692aa
package com.egolm.common.jdbc.dialect;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import com.egolm.common.ReflexUtil;
import com.egolm.common.StringUtil;
import com.egolm.common.jdbc.dialect.bean.Desc;
import com.egolm.common.jdbc.dialect.bean.Sql;
/**
* JDBC方言抽象类
* @author 曲欣亮
* @since 2014-03-14
*/
public abstract class AbstractDialect implements Dialect {
public Sql argsInsert(Object obj) {
Class<?> clz = obj.getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] fields = i_table.getFieldNames();
String[] columns = i_table.getColumnNames();
List<String> names = new ArrayList<String>();
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < fields.length; i++) {
Object objArg = ReflexUtil.readField(fields[i], obj);
if(objArg != null) {
names.add(columns[i]);
if(objArg != null && objArg instanceof Date) {
objArg = new Timestamp(((Date)objArg).getTime());
}
args.add(objArg);
}
}
String sql = "insert into " + table_name + StringUtil.join(getColumnRight() + ", " + getColumnLeft(), " (" + getColumnLeft(), getColumnRight() + ") ", names) + "values" + StringUtil.join("?", ", ", names.size(), " (", ")");
return new Sql(sql, args.toArray());
}
public Sql batchInsert(Object[] objs) {
if(objs.length > 0) {
Class<?> clz = objs[0].getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] fields = i_table.getFieldNames();
String[] columns = i_table.getColumnNames();
String[] pks = i_table.getFieldPkNames();
List<String> names = new ArrayList<String>();
Object[][] vals = new Object[objs.length][];
String expk = null;
for(String pk : pks) {
Object objArg = ReflexUtil.readField(pk, objs[0]);
if(objArg == null) {
expk = pk;
}
}
for(int k = 0; k < objs.length; k++) {
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < fields.length; i++) {
if(!fields[i].equals(expk)) {
if(k == 0) {
names.add(columns[i]);
}
Object objArg = ReflexUtil.readField(fields[i], objs[k]);
if(objArg != null && objArg instanceof Date) {
objArg = new Timestamp(((Date)objArg).getTime());
}
args.add(objArg);
}
}
vals[k] = args.toArray();
}
String sql = "insert into " + table_name + StringUtil.join(getColumnRight() + ", " + getColumnLeft(), " (" + getColumnLeft(), getColumnRight() + ") ", names) + " values" + StringUtil.join("?", ", ", names.size(), " (", ")");
return new Sql(sql, vals);
} else {
throw new RuntimeException("DataArray can't be null");
}
}
public Sql batchInsert(String table_name, List<Map<String, Object>> objs) {
List<String> names = new ArrayList<String>();
Object[][] vals = new Object[objs.size()][];
for(int i = 0; i < objs.size(); i++) {
Map<String, Object> map = objs.get(i);
List<Object> valsAry = new ArrayList<Object>();
for(String key : map.keySet()) {
if(i == 0) {
names.add(key);
}
valsAry.add(map.get(key));
}
vals[i] = valsAry.toArray();
}
String sql = "insert into " + table_name + StringUtil.join(getColumnRight() + ", " + getColumnLeft(), " (" + getColumnLeft(), getColumnRight() + ") ", names) + " values" + StringUtil.join("?", ", ", names.size(), " (", ")");
return new Sql(sql, vals);
}
public Sql argsDelete(Object obj) {
Class<?> clz = obj.getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] pk_fields = i_table.getFieldPkNames();
String[] pk_columns = i_table.getColumnPkNames();
String[] strs = new String[pk_fields.length];
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < pk_fields.length; i++) {
Object arg = ReflexUtil.readField(pk_fields[i], obj);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if(arg == null) {
strs[i] = getColumnLeft() + pk_columns[i] + getColumnRight() + " is null";
} else {
strs[i] = getColumnLeft() + pk_columns[i] + getColumnRight() + " = ?";
args.add(arg);
}
}
String sql = "delete from " + table_name + StringUtil.join(" and ", " where ", "", strs);
return new Sql(sql, args.toArray());
}
public Sql batchDelete(Object[] objs) {
if(objs.length > 0) {
Class<?> clz = objs[0].getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] pk_fields = i_table.getFieldPkNames();
String[] pk_columns = i_table.getColumnPkNames();
Object[][] vals = new Object[objs.length][];
for(int k = 0; k < objs.length; k++) {
Object obj = objs[k];
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < pk_fields.length; i++) {
Object arg = ReflexUtil.readField(pk_fields[i], obj);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
args.add(arg);
}
vals[k] = args.toArray();
}
String sql = "delete from " + table_name + StringUtil.join(getColumnRight() + " = ? and " + getColumnLeft(), " where " + getColumnLeft(), getColumnRight() + " = ?", pk_columns);
return new Sql(sql, vals);
} else {
throw new RuntimeException("DataArray can't be null");
}
}
public Sql argsUpdate(Object obj) {
Class<?> clz = obj.getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] pk_fields = i_table.getFieldPkNames();
String[] pk_columns = i_table.getColumnPkNames();
String[] fields = i_table.getFieldNames();
String[] columns = i_table.getColumnNames();
List<Object> args = new ArrayList<Object>();
List<String> strs = new ArrayList<String>();
List<String> vals = new ArrayList<String>();
for (int i = 0; i < fields.length; i++) {
Object arg = ReflexUtil.readField(fields[i], obj);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if (!StringUtil.contains(pk_columns, columns[i])) {
vals.add(getColumnLeft() + columns[i] + getColumnRight() + " = ?");
args.add(arg);
}
}
for (int i = 0; i < pk_fields.length; i++) {
Object arg = ReflexUtil.readField(pk_fields[i], obj);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if (arg == null) {
strs.add(getColumnLeft() + pk_columns[i] + getColumnRight() + " is null");
} else {
strs.add(getColumnLeft() + pk_columns[i] + getColumnRight() + " = ?");
args.add(arg);
}
}
String sql = "update " + table_name + StringUtil.join(", ", " set ", vals) + StringUtil.join(" and ", " where ", strs);
return new Sql(sql, args.toArray());
}
public Sql argsInsert(String tableName, Map<String, Object> objMap) {
String table_name = tableName;
Set<String> keySet = objMap.keySet();
String[] setArray = keySet.toArray(new String[keySet.size()]);
String[] fields = setArray;
String[] columns = setArray;
List<String> names = new ArrayList<String>();
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < fields.length; i++) {
Object objArg = objMap.get(fields[i]);
if(objArg != null && objArg instanceof Date) {
objArg = new Timestamp(((Date)objArg).getTime());
}
if(objArg != null) {
names.add(columns[i]);
args.add(objArg);
}
}
String sql = "insert into " + table_name + StringUtil.join(getColumnRight() + ", " + getColumnLeft(), " (" + getColumnLeft(), getColumnRight() + ") ", names) + "values" + StringUtil.join("?", ", ", names.size(), " (", ")");
return new Sql(sql, args.toArray());
}
public Sql argsDelete(String tableName, String columnName, Object columnValue) {
if(columnValue != null && columnValue instanceof Date) {
columnValue = new Timestamp(((Date)columnValue).getTime());
}
String sql = "delete from " + tableName + " where " + getColumnLeft() + columnName + getColumnRight() + " = ?";
return new Sql(sql, new Object[]{columnValue});
}
public Sql argsDelete(String tableName, Map<String, Object> objMap) {
Set<String> keySet = objMap.keySet();
String[] setArray = keySet.toArray(new String[keySet.size()]);
String[] columns = setArray;
String[] args = new String[columns.length];
Object[] objs = new Object[columns.length];
for(int i = 0; i < columns.length; i++) {
args[i] = getColumnLeft() + columns[i] + getColumnRight() + " = ?";
Object objArg = objMap.get(columns[i]);
if(objArg != null && objArg instanceof Date) {
objArg = new Timestamp(((Date)objArg).getTime());
}
objs[i] = objArg;
}
String sql = "delete from " + tableName + StringUtil.join(" and ", " where ", "", args);
return new Sql(sql, objs);
}
public Sql argsUpdate(String tableName, String[] columnNames, Map<String, Object> objMap) {
String table_name = tableName;
String[] pk_fields = columnNames;
String[] pk_columns = columnNames;
Set<String> keySet = objMap.keySet();
String[] setArray = keySet.toArray(new String[keySet.size()]);
String[] fields = setArray;
String[] columns = setArray;
List<Object> args = new ArrayList<Object>();
List<String> strs = new ArrayList<String>();
List<String> vals = new ArrayList<String>();
for(int i = 0; i < fields.length; i++) {
Object arg = objMap.get(fields[i]);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if(!StringUtil.contains(pk_columns, columns[i])) {
vals.add(getColumnLeft() + columns[i] + getColumnRight() + " = ?");
args.add(arg);
}
}
for(int i = 0; i < pk_fields.length; i++) {
Object arg = objMap.get(pk_fields[i]);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if(arg == null) {
strs.add(getColumnLeft() + pk_columns[i] + getColumnRight() + " is null");
} else {
strs.add(getColumnLeft() + pk_columns[i] + getColumnRight() + " = ?");
args.add(arg);
}
}
String sql = "update " + table_name + StringUtil.join(", ", " set ", vals) + StringUtil.join(" and ", " where ", strs);
return new Sql(sql, args.toArray());
}
public boolean hasPkValue(Object obj) {
Class<?> clz = obj.getClass();
Desc i_table = new Desc(clz);
String[] pks = i_table.getFieldPkNames();
for(String pk : pks) {
if(ReflexUtil.readField(pk, obj) == null) {
return false;
}
}
return true;
}
public Map<String, Object> getPkValue(Object obj) {
Class<?> clz = obj.getClass();
Desc desc = new Desc(clz);
return getFieldValue(desc.getFieldPkNames());
}
public Map<String, Object> getFieldValue(Object obj, String... fields) {
Map<String, Object> pkMap = new HashMap<String, Object>();
for(String field : fields) {
Object value = ReflexUtil.readField(field, obj);
pkMap.put(field, value);
}
return pkMap;
}
public Map<String, Object> getColumnValueByField(Object obj, String... fields) {
Desc i_table = new Desc(obj.getClass());
String[] columns = i_table.getColumnsByFidlds(fields);
Map<String, Object> pkMap = new HashMap<String, Object>();
for(int i = 0; i < fields.length; i++) {
Object value = ReflexUtil.readField(fields[i], obj);
pkMap.put(columns[i], value);
}
return pkMap;
}
public Desc getDesc(Class<?> clz) {
return new Desc(clz);
}
public Sql argsQuery(String tableName, Map<String, Object> objMap) {
List<String> wheres = new ArrayList<String>();
List<Object> args = new ArrayList<Object>();
for(String key : objMap.keySet()) {
wheres.add(getColumnLeft() + key + getColumnRight() + " = ?");
args.add(objMap.get(key));
}
String sql = "select * from " + tableName + StringUtil.join(" and ", " where ", "", wheres);
return new Sql(sql, args.toArray());
}
public Map<String, Object> fieldsToColumns(Class<?> type, Map<String, Object> byFields) {
Desc desc = new Desc(type);
String[] fieldNames = desc.getFieldNames();
String[] columnNames = desc.getColumnNames();
Map<String, Object> byColumns = new HashMap<String, Object>();
for(int i = 0; i < fieldNames.length; i++) {
String fieldName = fieldNames[i];
String columnName = columnNames[i];
if(byFields.containsKey(fieldName)) {
byColumns.put(columnName, byFields.get(fieldName));
}
}
return byColumns;
}
}
src/main/java/com/egolm/common/jdbc/dialect/Dialect.java
View file @ 59d59db7
package com.egolm.common.jdbc.dialect;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import com.egolm.common.ReflexUtil;
import com.egolm.common.StringUtil;
import com.egolm.common.jdbc.Page;
import com.egolm.common.jdbc.dialect.bean.Desc;
import com.egolm.common.jdbc.dialect.bean.Sql;
......@@ -14,127 +21,339 @@ import com.egolm.common.jdbc.dialect.bean.Sql;
*/
public interface Dialect {
/**
* 生成分页查询SQL语句
* @param sql 原SQL
* @param page 分页工具类
* @return
*/
public String limit(String sql, Page page);
/**
* 生成统计数据条数的SQL
* @param sql 原SQL语句（要统计数据条数的SQL语句）
* @return
*/
public String count(String sql);
/**
* 生成插入SQL语句
* @param obj 要插入的对象
* @return
*/
public Sql argsInsert(Object obj);
public String ifExists(String tableName);
/**
* 生成插入SQL语句
* @param tableName 表名
* @param objMap 要插入的对象
* @return
*/
public Sql argsInsert(String tableName, Map<String, Object> objMap);
public String ifNotExists(String tableName);
/**
* 生成插入SQL语句
* @param obj
* @return
*/
public Sql batchInsert(Object[] obj);
public String selectDate();
public Sql batchInsert(String tableName, List<Map<String, Object>> objs);
public String getColumnLeft();
/**
* 生成删除SQL语句
* @param obj 要删除的对象
* @return
*/
public Sql argsDelete(Object obj);
public String getColumnRight();
public Sql batchDelete(Object[] obj);
default Sql argsInsert(Object obj) {
Class<?> clz = obj.getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] fields = i_table.getFieldNames();
String[] columns = i_table.getColumnNames();
List<String> names = new ArrayList<String>();
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < fields.length; i++) {
Object objArg = ReflexUtil.readField(fields[i], obj);
if(objArg != null) {
names.add(columns[i]);
if(objArg != null && objArg instanceof Date) {
objArg = new Timestamp(((Date)objArg).getTime());
}
args.add(objArg);
}
}
String sql = "insert into " + table_name + StringUtil.join(getColumnRight() + ", " + getColumnLeft(), " (" + getColumnLeft(), getColumnRight() + ") ", names) + "values" + StringUtil.join("?", ", ", names.size(), " (", ")");
return new Sql(sql, args.toArray());
}
/**
* 生成删除SQL语句
* @param tableName
* @param columnName
* @param columnValue
* @return
*/
public Sql argsDelete(String tableName, String columnName, Object columnValue);
default Sql batchInsert(Object[] objs) {
if(objs.length > 0) {
Class<?> clz = objs[0].getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] fields = i_table.getFieldNames();
String[] columns = i_table.getColumnNames();
String[] pks = i_table.getFieldPkNames();
List<String> names = new ArrayList<String>();
Object[][] vals = new Object[objs.length][];
String expk = null;
for(String pk : pks) {
Object objArg = ReflexUtil.readField(pk, objs[0]);
if(objArg == null) {
expk = pk;
}
}
for(int k = 0; k < objs.length; k++) {
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < fields.length; i++) {
if(!fields[i].equals(expk)) {
if(k == 0) {
names.add(columns[i]);
}
Object objArg = ReflexUtil.readField(fields[i], objs[k]);
if(objArg != null && objArg instanceof Date) {
objArg = new Timestamp(((Date)objArg).getTime());
}
args.add(objArg);
}
}
vals[k] = args.toArray();
}
String sql = "insert into " + table_name + StringUtil.join(getColumnRight() + ", " + getColumnLeft(), " (" + getColumnLeft(), getColumnRight() + ") ", names) + " values" + StringUtil.join("?", ", ", names.size(), " (", ")");
return new Sql(sql, vals);
} else {
throw new RuntimeException("DataArray can't be null");
}
}
/**
* 生成删除SQL语句
* @param tableName
* @param objMap
* @return
*/
public Sql argsDelete(String tableName, Map<String, Object> objMap);
default Sql batchInsert(String table_name, List<Map<String, Object>> objs) {
List<String> names = new ArrayList<String>();
Object[][] vals = new Object[objs.size()][];
for(int i = 0; i < objs.size(); i++) {
Map<String, Object> map = objs.get(i);
List<Object> valsAry = new ArrayList<Object>();
for(String key : map.keySet()) {
if(i == 0) {
names.add(key);
}
valsAry.add(map.get(key));
}
vals[i] = valsAry.toArray();
}
String sql = "insert into " + table_name + StringUtil.join(getColumnRight() + ", " + getColumnLeft(), " (" + getColumnLeft(), getColumnRight() + ") ", names) + " values" + StringUtil.join("?", ", ", names.size(), " (", ")");
return new Sql(sql, vals);
}
/**
* 生成更新SQL语句（根据ID更新）
* @param obj 要更新的对象
* @return
*/
public Sql argsUpdate(Object obj);
/**
* 生成更新SQL语句
* @param tableName
* @param columnNames
* @param objMap
* @return
*/
public Sql argsUpdate(String tableName, String[] columnNames, Map<String, Object> objMap);
default Sql argsDelete(Object obj) {
Class<?> clz = obj.getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] pk_fields = i_table.getFieldPkNames();
String[] pk_columns = i_table.getColumnPkNames();
String[] strs = new String[pk_fields.length];
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < pk_fields.length; i++) {
Object arg = ReflexUtil.readField(pk_fields[i], obj);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if(arg == null) {
strs[i] = getColumnLeft() + pk_columns[i] + getColumnRight() + " is null";
} else {
strs[i] = getColumnLeft() + pk_columns[i] + getColumnRight() + " = ?";
args.add(arg);
}
}
String sql = "delete from " + table_name + StringUtil.join(" and ", " where ", "", strs);
return new Sql(sql, args.toArray());
}
public Sql argsQuery(String tableName, Map<String, Object> objMap);
default Sql batchDelete(Object[] objs) {
if(objs.length > 0) {
Class<?> clz = objs[0].getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] pk_fields = i_table.getFieldPkNames();
String[] pk_columns = i_table.getColumnPkNames();
Object[][] vals = new Object[objs.length][];
for(int k = 0; k < objs.length; k++) {
Object obj = objs[k];
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < pk_fields.length; i++) {
Object arg = ReflexUtil.readField(pk_fields[i], obj);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
args.add(arg);
}
vals[k] = args.toArray();
}
String sql = "delete from " + table_name + StringUtil.join(getColumnRight() + " = ? and " + getColumnLeft(), " where " + getColumnLeft(), getColumnRight() + " = ?", pk_columns);
return new Sql(sql, vals);
} else {
throw new RuntimeException("DataArray can't be null");
}
}
public String ifExists(String tableName);
default Sql argsUpdate(Object obj) {
Class<?> clz = obj.getClass();
Desc i_table = new Desc(clz);
String table_name = i_table.getName();
String[] pk_fields = i_table.getFieldPkNames();
String[] pk_columns = i_table.getColumnPkNames();
String[] fields = i_table.getFieldNames();
String[] columns = i_table.getColumnNames();
List<Object> args = new ArrayList<Object>();
List<String> strs = new ArrayList<String>();
List<String> vals = new ArrayList<String>();
for (int i = 0; i < fields.length; i++) {
Object arg = ReflexUtil.readField(fields[i], obj);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if (!StringUtil.contains(pk_columns, columns[i])) {
vals.add(getColumnLeft() + columns[i] + getColumnRight() + " = ?");
args.add(arg);
}
}
for (int i = 0; i < pk_fields.length; i++) {
Object arg = ReflexUtil.readField(pk_fields[i], obj);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if (arg == null) {
strs.add(getColumnLeft() + pk_columns[i] + getColumnRight() + " is null");
} else {
strs.add(getColumnLeft() + pk_columns[i] + getColumnRight() + " = ?");
args.add(arg);
}
}
String sql = "update " + table_name + StringUtil.join(", ", " set ", vals) + StringUtil.join(" and ", " where ", strs);
return new Sql(sql, args.toArray());
}
public String ifNotExists(String tableName);
default Sql argsInsert(String tableName, Map<String, Object> objMap) {
String table_name = tableName;
Set<String> keySet = objMap.keySet();
String[] setArray = keySet.toArray(new String[keySet.size()]);
String[] fields = setArray;
String[] columns = setArray;
List<String> names = new ArrayList<String>();
List<Object> args = new ArrayList<Object>();
for(int i = 0; i < fields.length; i++) {
Object objArg = objMap.get(fields[i]);
if(objArg != null && objArg instanceof Date) {
objArg = new Timestamp(((Date)objArg).getTime());
}
if(objArg != null) {
names.add(columns[i]);
args.add(objArg);
}
}
String sql = "insert into " + table_name + StringUtil.join(getColumnRight() + ", " + getColumnLeft(), " (" + getColumnLeft(), getColumnRight() + ") ", names) + "values" + StringUtil.join("?", ", ", names.size(), " (", ")");
return new Sql(sql, args.toArray());
}
/**
* 生成建表SQL语句
* @param clzz
* @return
*/
public String[] sqlTable(Class<?>... claz);
default Sql argsDelete(String tableName, String columnName, Object columnValue) {
if(columnValue != null && columnValue instanceof Date) {
columnValue = new Timestamp(((Date)columnValue).getTime());
}
String sql = "delete from " + tableName + " where " + getColumnLeft() + columnName + getColumnRight() + " = ?";
return new Sql(sql, new Object[]{columnValue});
}
/**
* 判断主键字段是否有值
* @Description
* @param obj
* @return
* @author 曲欣亮
* @date 2016年7月13日
* @since 2016年7月13日
* @return boolean
* @throws
*/
public boolean hasPkValue(Object obj);
default Sql argsDelete(String tableName, Map<String, Object> objMap) {
Set<String> keySet = objMap.keySet();
String[] setArray = keySet.toArray(new String[keySet.size()]);
String[] columns = setArray;
String[] args = new String[columns.length];
Object[] objs = new Object[columns.length];
for(int i = 0; i < columns.length; i++) {
args[i] = getColumnLeft() + columns[i] + getColumnRight() + " = ?";
Object objArg = objMap.get(columns[i]);
if(objArg != null && objArg instanceof Date) {
objArg = new Timestamp(((Date)objArg).getTime());
}
objs[i] = objArg;
}
String sql = "delete from " + tableName + StringUtil.join(" and ", " where ", "", args);
return new Sql(sql, objs);
}
public Map<String, Object> getPkValue(Object obj);
default Sql argsUpdate(String tableName, String[] columnNames, Map<String, Object> objMap) {
String table_name = tableName;
String[] pk_fields = columnNames;
String[] pk_columns = columnNames;
Set<String> keySet = objMap.keySet();
String[] setArray = keySet.toArray(new String[keySet.size()]);
String[] fields = setArray;
String[] columns = setArray;
List<Object> args = new ArrayList<Object>();
List<String> strs = new ArrayList<String>();
List<String> vals = new ArrayList<String>();
for(int i = 0; i < fields.length; i++) {
Object arg = objMap.get(fields[i]);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if(!StringUtil.contains(pk_columns, columns[i])) {
vals.add(getColumnLeft() + columns[i] + getColumnRight() + " = ?");
args.add(arg);
}
}
for(int i = 0; i < pk_fields.length; i++) {
Object arg = objMap.get(pk_fields[i]);
if(arg != null && arg instanceof Date) {
arg = new Timestamp(((Date)arg).getTime());
}
if(arg == null) {
strs.add(getColumnLeft() + pk_columns[i] + getColumnRight() + " is null");
} else {
strs.add(getColumnLeft() + pk_columns[i] + getColumnRight() + " = ?");
args.add(arg);
}
}
String sql = "update " + table_name + StringUtil.join(", ", " set ", vals) + StringUtil.join(" and ", " where ", strs);
return new Sql(sql, args.toArray());
}
public Map<String, Object> getFieldValue(Object obj, String... field);
default boolean hasPkValue(Object obj) {
Class<?> clz = obj.getClass();
Desc i_table = new Desc(clz);
String[] pks = i_table.getFieldPkNames();
for(String pk : pks) {
if(ReflexUtil.readField(pk, obj) == null) {
return false;
}
}
return true;
}
public Map<String, Object> getColumnValueByField(Object obj, String... field);
default Map<String, Object> getPkValue(Object obj) {
Class<?> clz = obj.getClass();
Desc desc = new Desc(clz);
return getFieldValue(desc.getFieldPkNames());
}
public Desc getDesc(Class<?> clz);
default Map<String, Object> getFieldValue(Object obj, String... fields) {
Map<String, Object> pkMap = new HashMap<String, Object>();
for(String field : fields) {
Object value = ReflexUtil.readField(field, obj);
pkMap.put(field, value);
}
return pkMap;
}
public Map<String, Object> fieldsToColumns(Class<?> type, Map<String, Object> byFields);
default Map<String, Object> getColumnValueByField(Object obj, String... fields) {
Desc i_table = new Desc(obj.getClass());
String[] columns = i_table.getColumnsByFidlds(fields);
Map<String, Object> pkMap = new HashMap<String, Object>();
for(int i = 0; i < fields.length; i++) {
Object value = ReflexUtil.readField(fields[i], obj);
pkMap.put(columns[i], value);
}
return pkMap;
}
public String selectDate();
default Desc getDesc(Class<?> clz) {
return new Desc(clz);
}
public String getColumnLeft();
default Sql argsQuery(String tableName, Map<String, Object> objMap) {
List<String> wheres = new ArrayList<String>();
List<Object> args = new ArrayList<Object>();
for(String key : objMap.keySet()) {
wheres.add(getColumnLeft() + key + getColumnRight() + " = ?");
args.add(objMap.get(key));
}
String sql = "select * from " + tableName + StringUtil.join(" and ", " where ", "", wheres);
return new Sql(sql, args.toArray());
}
public String getColumnRight();
default Map<String, Object> fieldsToColumns(Class<?> type, Map<String, Object> byFields) {
Desc desc = new Desc(type);
String[] fieldNames = desc.getFieldNames();
String[] columnNames = desc.getColumnNames();
Map<String, Object> byColumns = new HashMap<String, Object>();
for(int i = 0; i < fieldNames.length; i++) {
String fieldName = fieldNames[i];
String columnName = columnNames[i];
if(byFields.containsKey(fieldName)) {
byColumns.put(columnName, byFields.get(fieldName));
}
}
return byColumns;
}
}
src/main/java/com/egolm/common/jdbc/dialect/MySqlDialect.java
View file @ 59d59db7
......@@ -14,7 +14,7 @@ import com.egolm.common.jdbc.dialect.bean.Desc;
* @author 曲欣亮
* @since 2012-12-14
*/
public class MySqlDialect extends AbstractDialect {
public class MySqlDialect implements Dialect {
public static final String FMT_MYSQL_TIME = "%Y-%m-%d %H:%i:%s";
public static final String FMT_MYSQL_DATE = "%Y-%m-%d";
......
src/main/java/com/egolm/common/jdbc/dialect/OracleDialect.java
View file @ 59d59db7
......@@ -13,7 +13,7 @@ import com.egolm.common.jdbc.dialect.bean.Desc;
* @author 曲欣亮
* @since 2012-12-14
*/
public class OracleDialect extends AbstractDialect {
public class OracleDialect implements Dialect {
public static final String FMT_ORACLE_TIME = "yyyy-mm-dd hh24:mi:ss";
public static final String FMT_ORACLE_DATE = "yyyy-mm-dd";
......
src/main/java/com/egolm/common/jdbc/dialect/SqlServerDialect.java
View file @ 59d59db7
......@@ -14,7 +14,7 @@ import com.egolm.common.jdbc.dialect.bean.Desc;
* @author 曲欣亮
* @since 2012-12-14
*/
public class SqlServerDialect extends AbstractDialect {
public class SqlServerDialect implements Dialect {
public static final String FMT_SQLSERVER_TIME = "120";
public static final String FMT_SQLSERVER_DATE = "23";
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment