nutz现在支持保存list数据的时候，原来有的就更新没有的就插入操作吗。
13 回复
@SuppressWarnings("unchecked")
public static <T> T insertOrUpdate(Dao dao, T obj) {
if (obj == null)
return null;
Entity<T> en = (Entity<T>) dao.getEntity(obj.getClass());
if (en.getPkType() == PkType.UNKNOWN)
throw new IllegalArgumentException("no support , without pks");
boolean doInsert = false;
switch (en.getPkType()) {
case ID:
Number n = (Number) en.getIdField().getValue(obj);
if (n == null || n.intValue() == 0)
doInsert = true;
break;
case NAME:
if (null == en.getNameField().getValue(obj))
doInsert = false;
break;
case COMPOSITE:
doInsert = true;
for(MappingField mf :en.getCompositePKFields()) {
Object v = mf.getValue(obj);
if (v != null) {
if (v instanceof Number && ((Number)v).intValue() != 0) {
continue;
}
doInsert = true;
}
}
case UNKNOWN:
throw Lang.impossible();
}
if (doInsert) {
return dao.insert(obj);
} else{
dao.update(obj);
return obj;
}
}
如果指定某个属性,这样写应该更好
/**
* 更新或插入对象
* @param dao Dao实例
* @param list 需要操作的列表
* @param field 作为判定依据的属性名称
*/
public static <T> void insertOrUpdate(Dao dao, List<T> list, String field) {
Entity<? extends Object> en = dao.getEntity(list.get(0).getClass());
MappingField mf = en.getField(field);
for (T t : list) {
Object val = mf.getValue(t);
// 如果对应的属性不为null,且不为0,到数据库检查一下是否存在
if (val != null && !(val instanceof Number && ((Number)val).intValue() == 0)) {
// count一下就知道是否存在了
if (dao.count(t.getClass(), Cnd.where(field, "=", val)) != 0) {
dao.update(t); // 存在,更新之
continue;
}
}
dao.insert(t);
}
}
添加回复
请先登陆