fix Db.updateEntitiesBatch更新部分字段时报错的问题

This commit is contained in:
tangxin 2024-01-03 16:48:33 +08:00
parent 2d9d05b6e5
commit 434b948b8a
2 changed files with 25 additions and 12 deletions

View File

@ -245,9 +245,13 @@ public class RowSqlProvider {
Object entity = ProviderUtil.getEntity(params); Object entity = ProviderUtil.getEntity(params);
FlexAssert.notNull(entity, "entity can not be null"); FlexAssert.notNull(entity, "entity can not be null");
Class<?> entityClass = entity.getClass();
//如果是代理mybatis代理对象
if(entity instanceof ProxyObject){
entityClass = entityClass.getSuperclass();
}
// Mapper 是通用 Mapper 无法通过 ProviderContext 获取直接使用 TableInfoFactory // Mapper 是通用 Mapper 无法通过 ProviderContext 获取直接使用 TableInfoFactory
TableInfo tableInfo = TableInfoFactory.ofEntityClass(ClassUtil.getUsefulClass(entity.getClass())); TableInfo tableInfo = TableInfoFactory.ofEntityClass(entityClass);
// 执行 onUpdate 监听器 // 执行 onUpdate 监听器
tableInfo.invokeOnUpdateListener(entity); tableInfo.invokeOnUpdateListener(entity);

View File

@ -82,10 +82,12 @@ public class DbTest {
Map map2 = Db.selectFirstAndSecondColumnsAsMap("select * from tb_account"); Map map2 = Db.selectFirstAndSecondColumnsAsMap("select * from tb_account");
System.out.println(map); System.out.println(map);
System.out.println(map2); System.out.println(map2);
assert map.equals(map2);
} }
@Test @Test
public void test03() { public void test03() {
try {
Account account = UpdateEntity.of(Account.class, 1); Account account = UpdateEntity.of(Account.class, 1);
account.setAge(1); account.setAge(1);
List<Account> accounts = new ArrayList<>(); List<Account> accounts = new ArrayList<>();
@ -95,6 +97,13 @@ public class DbTest {
UpdateWrapper updateWrapper = UpdateWrapper.of(account2); UpdateWrapper updateWrapper = UpdateWrapper.of(account2);
updateWrapper.setRaw("age", "age+1"); updateWrapper.setRaw("age", "age+1");
accounts.add(account2); accounts.add(account2);
Account account3 = new Account();
account3.setId(3L);
account3.setAge(4);
accounts.add(account3);
Db.updateEntitiesBatch(accounts); Db.updateEntitiesBatch(accounts);
}catch (Exception e){
assert false;
}
} }
} }