|
|
@@ -35,7 +35,7 @@ import com.pub.system.SystemCache;
|
|
|
public class BaseDAO {
|
|
|
@Autowired
|
|
|
private JdbcTemplate jdbcTemplate = null;
|
|
|
-
|
|
|
+
|
|
|
|
|
|
/**
|
|
|
* 除了null,有值就更新
|
|
|
@@ -111,7 +111,7 @@ public class BaseDAO {
|
|
|
}
|
|
|
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 根据字段更新,设置了null也会更新
|
|
|
* @param vo
|
|
|
@@ -147,7 +147,7 @@ public class BaseDAO {
|
|
|
}
|
|
|
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 除了null,有值就更新
|
|
|
* @param vo
|
|
|
@@ -231,7 +231,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("更新数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 除了null,有值就更新
|
|
|
* @param vo
|
|
|
@@ -246,7 +246,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("更新数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 根据字段更新Array,设置了null也会更新
|
|
|
* @param vo
|
|
|
@@ -269,7 +269,7 @@ public class BaseDAO {
|
|
|
public void updateSQL(String sql) {
|
|
|
jdbcTemplate.update(sql);
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 插入数据
|
|
|
* @param vo
|
|
|
@@ -320,7 +320,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("插入数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 插入数据(wy)
|
|
|
* @param vo
|
|
|
@@ -330,7 +330,6 @@ public class BaseDAO {
|
|
|
// 设置创建时间为当前时间
|
|
|
if (vo.getAttribute(Fields.CREATE_TIME) == null) {
|
|
|
vo.setAttribute(Fields.CREATE_TIME, new Timestamp(System.currentTimeMillis()));
|
|
|
-
|
|
|
}
|
|
|
String tableName = vo.getTableName();
|
|
|
Map<String, Integer> types = getColumnTypes(tableName);
|
|
|
@@ -354,7 +353,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("插入数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 插入数组
|
|
|
* @param vo
|
|
|
@@ -467,7 +466,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("查询数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 根据条件进行查询所有数据(wy)
|
|
|
* @param <T>
|
|
|
@@ -511,7 +510,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("查询数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 根据条件进行查询所有数据不关心删除标记(wy)
|
|
|
* @param <T>
|
|
|
@@ -556,7 +555,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("查询数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 根据条件进行查询分页数据
|
|
|
* @param <T>
|
|
|
@@ -710,7 +709,7 @@ public class BaseDAO {
|
|
|
String sql = getQueryByPK(vo, tableName, fieldNames, pk);
|
|
|
|
|
|
if (sql == null) {
|
|
|
- return null;
|
|
|
+ return null;
|
|
|
}
|
|
|
list = jdbcTemplate.query(sql, new RowMapper<SuperVO>() {
|
|
|
@Override
|
|
|
@@ -730,7 +729,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("查询数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 根据键名查询
|
|
|
* @author wy
|
|
|
@@ -748,7 +747,7 @@ public class BaseDAO {
|
|
|
String[] fieldNames = getValidNames(vo, types);
|
|
|
String sql = getQueryByKey(vo, tableName, fieldNames, keyName, k);
|
|
|
if (sql == null) {
|
|
|
- return null;
|
|
|
+ return null;
|
|
|
}
|
|
|
list = jdbcTemplate.query(sql, new RowMapper<SuperVO>() {
|
|
|
@Override
|
|
|
@@ -986,7 +985,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("删除数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 根据键名删除数据
|
|
|
* @param clazz
|
|
|
@@ -1046,7 +1045,7 @@ public class BaseDAO {
|
|
|
throw new BusinessException("删除数据异常", e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 删除一个List
|
|
|
* @param delList
|
|
|
@@ -1135,7 +1134,7 @@ public class BaseDAO {
|
|
|
}
|
|
|
return null;
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 获得查询SQL(wy)
|
|
|
* @param tableName
|
|
|
@@ -1164,7 +1163,7 @@ public class BaseDAO {
|
|
|
}
|
|
|
return null;
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 获得查询SQL不关心删除标记(wy)
|
|
|
* @param tableName
|
|
|
@@ -1215,7 +1214,7 @@ public class BaseDAO {
|
|
|
}
|
|
|
return null;
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 根据键名获得查询语句
|
|
|
* @author wy
|
|
|
@@ -1372,7 +1371,7 @@ public class BaseDAO {
|
|
|
buffer.append(" where " + vo.getPKFieldName() + "=?");
|
|
|
return buffer.toString();
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 获得更新SQL
|
|
|
* @author wy
|