解决shardingJDBC不⽀持批量导⼊问题
⽬录
sharding JDBC 不⽀持批量导⼊
sharding-jdbc不⽀持多条sql语句批量更新
修改思路
sharding JDBC 不⽀持批量导⼊
package com.ydmes.service.impl.log;
import com.ity.log.BarTraceBackLog;
import org.springframework.beans.BeansException;
import t.ApplicationContext;
import t.ApplicationContextAware;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Component;
import ansaction.TransactionDefinition;
import ansaction.TransactionStatus;
import ansaction.support.DefaultTransactionDefinition;
import java.util.List;
@Component
public class BarTraceBackLogBatchServiceImpl implements ApplicationContextAware {
springframework事务
private static ApplicationContext applicationContext;
public void batchInsertBarTraceBackLogs(List<BarTraceBackLog> barTraceBackLogs) {
DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
definition.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
DataSourceTransactionManager transactionManager = (DataSourceTransactionManager)
TransactionStatus transactionStatus = Transaction(definition);
for (BarTraceBackLog barTraceBackLog : barTraceBackLogs) {
//UserDao有create⽅法，单条插⼊
}
transactionManagermit(transactionStatus);
}
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.applicationContext = applicationContext;
}
}
sharding-jdbc不⽀持多条sql语句批量更新
今天项⽬有个刷数据的需求，单条数据修改太慢，想着写个批量update，三两下把sql写好了，发现分表不⽀持，sharding-jdbc只会把我第⼀个表名填充成正确表名，后⾯的表名都没有修改。
mybastis如下：
<update id="batchUpdate" >
<foreach collection="userList" item="item" index="index" separator=";">
update t_user_data set `province_id`=#{item.provinceId} where member_id = #{berId}
</foreach>
</update>
sql如下：
update t_user_data_1 set `province_id`=?,`region_id`=? where member_id = ? ;
update t_user_data set `province_id`=?,`region_id`=? where member_id = ? ;
由此可见，这多条sql语句更新是不⽀持的。
修改思路
既然表名不⽀持⾃动多个，那我就⾃⼰替换表名，
先在代码中根据表的分表规则得到表名，在赋值在每个sql语句上
代码如下：
userData1.setTableName("t_user_data_" + MemberId() % 8);
⽐如我这张表分了⼋个表，则按8取余这样每个条数据都对应好了表名，mybastis如下：
<update id="batchUpdate" >
<foreach collection="userList" item="item" index="index" separator=";">
update ${item.tableName} set `province_id`=#{item.provinceId} where member_id = #{berId} </foreach>
</update>
这⾥需要注意⼀下：表名和列名需要⽤${}来传⼊，参数才⽤#{}。
最终sql如下：
update t_user_data_1 set `province_id`=?,`region_id`=? where member_id = ? ;
update t_user_data_2 set `province_id`=?,`region_id`=? where member_id = ? ;
这样便解决了批量更新问题。
以上为个⼈经验，希望能给⼤家⼀个参考，也希望⼤家多多⽀持。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。