| | |
|---|
| | | Assert.notNull(tableInfo, "error: can not execute. because can not find cache of TableInfo for entity!"); |
|---|
| | | String keyProperty = tableInfo.getKeyProperty(); |
|---|
| | | Assert.notEmpty(keyProperty, "error: can not execute. because can not find column for id from entity!"); |
|---|
| | | return SqlHelper.saveOrUpdateBatch(this.currentModelClass(), getClass(), log, entityList, batchSize, (sqlSession, entity) -> { |
|---|
| | | return SqlHelper.saveOrUpdateBatch(this.currentModelClass(), this.currentMapperClass(), log, entityList, batchSize, (sqlSession, entity) -> { |
|---|
| | | Object idVal = tableInfo.getPropertyValue(entity, keyProperty); |
|---|
| | | String sqlStatement = SqlHelper.getSqlStatement(this.currentMapperClass(), SqlMethod.INSERT_ONE); |
|---|
| | | String sqlStatement = SqlHelper.getSqlStatement(this.currentMapperClass(), SqlMethod.SELECT_BY_ID); |
|---|
| | | return StringUtils.checkValNull(idVal) |
|---|
| | | || CollectionUtils.isEmpty(sqlSession.selectList(sqlStatement, entity)); |
|---|
| | | }, (sqlSession, entity) -> { |
|---|
