使用jdbc时将数据从结果集中映射到实体的方法
最常用做法
使用ResultSet提供的getXXX方法手动填写对应的字段名获取对应数据，并set到对应的实体中
while (resultSet.next()) {
User user = new User();
user.setAddress(resultSet.getString("address"));
}
使用java反射技巧
什么是反射
JAVA反射机制是在运行状态中，对于任意一个类，都能够知道这个类的所有属性和方法；对于任意一个对象，都能够调用它的任意一个方法和属性；这种动态获取的信息以及动态调用对象的方法的功能称为java语言的反射机制。
核心思路：
使用要映射的JavaBean class对象，获取声明的所有字段名称。根据JavaBean规范，所有字段都提供了get set方法，所以字段名称拼接上get、set即可得到对应的方法名。使用对应的set方法，将从resultSet中获取到的值，通过反射调用对应的set方法。将值设置到JavaBean中。
核心代码块如下--参考https://blog.csdn.net/a975261294/article/details/70049963
/**
* 把ResultSet的结果放到java对象中
*
* @param <T>
* @param rs
* ResultSet
* @param obj
* java类的class
* @return
*/
public static <T> ArrayList<T> putResult(ResultSet rs, Class<T> obj) {
try {
ArrayList<T> arrayList = new ArrayList<T>();
ResultSetMetaData metaData = rs.getMetaData();
/**
* 获取总列数
*/
int count = metaData.getColumnCount();
while (rs.next()) {
/**
* 创建对象实例
*/
T newInstance = obj.newInstance();
for (int i = 1; i <= count; i++) {
/**
* 给对象的某个属性赋值
*/
String name = metaData.getColumnName(i).toLowerCase();
// 改变列名格式成java命名格式--不做介绍
name = toJavaField(name);
// 首字母大写
String substring = name.substring(0, 1);
String replace = name.replaceFirst(substring, substring.toUpperCase());
// 获取字段类型
Class<?> type = obj.getDeclaredField(name).getType();
Method method = obj.getMethod("set" + replace, type);
/**
* 判断读取数据的类型--这里可以根据需要自己处理
*/
if(type.isAssignableFrom(String.class)){
method.invoke(newInstance, rs.getString(i));
}else if(type.isAssignableFrom(int.class) || type.isAssignableFrom(Integer.class)){
method.invoke(newInstance, rs.getInt(i));
}else if(type.isAssignableFrom(Boolean.class) || type.isAssignableFrom(boolean.class)){
method.invoke(newInstance, rs.getBoolean(i));
}else if(type.isAssignableFrom(Date.class)){
method.invoke(newInstance, rs.getDate(i));
}
}
arrayList.add(newInstance);
}
return arrayList;
} catch (InstantiationException | IllegalAccessException | SQLException | SecurityException
| NoSuchMethodException | IllegalArgumentException | InvocationTargetException
| NoSuchFieldException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
进阶-使用java内省机制处理(反射的特殊应用)
什么是java的内省
- 内省（Introspector）是Java语言对Bean类属性、事件的一种缺省处理方法。
- 例如类A中有属性name,那我们可以通过getName,setName来得到其值或者设置新的值。
- 通过getName/setName来访问name属性，这就是默认的规则。
- Java中提供了一套API用来访问某个属性的getter/setter方法，通过这些API可以使你不需要了解这个规则，
- 这些API存放于包java.beans中。
属性描述器-PropertyDescriptor
- 一般的做法是通过类Introspector来获取某个对象的BeanInfo信息，
- 然后通过BeanInfo来获取属性的描述器（PropertyDescriptor），
- 通过这个属性描述器就可以获取某个属性对应的getter/setter方法，
- 然后我们就可以通过反射机制来调用这些方法。
通过使用java内省机制提供的属性描述器。我们可以根据字段名称直接调用其对应的get、set方法。核心代码如下
public static <T> List<T> parseDto(ResultSet resultSet, Class<T> tClass) throws SQLException, InstantiationException, IllegalAccessException, IntrospectionException, InvocationTargetException {
List<T> result = new ArrayList<>();
Field[] declaredFields = tClass.getDeclaredFields();
List<String> fileds = Arrays.stream(declaredFields).map(Field::getName).map(String::toString).
collect(Collectors.toList());
ResultSetMetaData metaData = resultSet.getMetaData();
int columnCount = metaData.getColumnCount();
while (resultSet.next()) {
T t = tClass.newInstance();
for (int i = 1; i < columnCount+1; i++) {
String columnName = metaData.getColumnName(i);
Object value = resultSet.getObject(i);
String methodName = lineToHump(columnName);
if(!fileds.contains(methodName)){
continue;
}
setValue(t, methodName, value);
}
result.add(t);
}
return result;
}
private static void setValue(Object object, String filedName, Object value) throws IntrospectionException, InvocationTargetException, IllegalAccessException {
PropertyDescriptor proDescriptor = new PropertyDescriptor(filedName, object.getClass());
Method writeMethod = proDescriptor.getWriteMethod();
//todo 判断类型
writeMethod.invoke(object, value);
}
spring提供的实体处理器
BeanPropertyRowMapper beanPropertyRowMapper = new BeanPropertyRowMapper<>(TSummary.class);
TSummary tSummary = beanPropertyRowMapper.mapRow(rs, rs.getRow());
底层实现就是上述介绍的java内省
大批量数据查询的优化思路
查询
通常做法
使用sql或者框架执行一次sql。然后拿到对应的集合做业务处理。
弊端-大批量的数据查询往往会有sql执行时间快，但是拿到数据时间长的问题。方法级层面则体现在获取数据时间长。
fetchSize参数介绍
原理：通过JDBC取数据时，默认是10条数据取一次，即fetch size为10，如果增大这个数字可以减少客户端与oracle的往返，减少响应时间，网上有建议这个数字不要超过100，要不然对中间件内存消耗大（没有做过实验）。
jdbc的使用方式
Statement statement = connection.createStatement();
statement.setFetchSize(100);
ResultSet resultSet = statement.executeQuery("select * from user");
mybatis中的使用方式
<!--mybatis 提供fetchSize参数，直接在select标签中设置即可-->
<select id="selectAll" resultMap="BaseResultMap" fetchSize="1000">
select ID, AGE, NAME
from IDSUSER.DEMO
</select>
入库
通常做法
循环执行保存方法。
弊端-会反复获取释放连接，浪费资源。数据库压力比较大
进阶-批量执行
使用jdbc
Connection connection = sessionFactory.openSession().getConnection();
String sql = "insert into IDSUSER.DEMO (ID, AGE, NAME) values (?,?,?)";
try {
connection.setAutoCommit(false);
PreparedStatement preparedStatement = connection.prepareStatement(sql);
for (Demo demo : demos) {
maxId = maxId.add(new BigDecimal(1));
demo.setId(maxId);
preparedStatement.setBigDecimal(1,demo.getId());
preparedStatement.setString(2,demo.getAge());
preparedStatement.setString(3,demo.getName());
preparedStatement.addBatch();
}
preparedStatement.executeBatch();
connection.commit();
} catch (SQLException e) {
try {
connection.rollback();
connection.close();
} catch (SQLException ex) {
ex.printStackTrace();
}
}
使用框架封装
SqlSession sqlSession = sessionFactory.openSession(ExecutorType.BATCH, false);
DemoMapper mapper = sqlSession.getMapper(DemoMapper.class);
maxId = mapper.getMaxId();
demos.forEach(e -> {
maxId = maxId.add(new BigDecimal(1));
e.setId(maxId);
mapper.insert(e);
});
sqlSession.commit();
sqlSession.clearCache();
sqlSession.close();
return demos.size();
多线程
上述批量执行的方法可以封装到单独的方法然后使用并行流执行。效率会更快。
