shardingjdbc 强制路由走主库查询实时数据 避免主从同步数据延迟


@Bean
public shardingsphere.demo.entity.Order order(){
shardingsphere.demo.entity.Order order=new Order();
order.setId(new Random(100).nextLong());
order.setOrderId(101);
order.setUserId(6);
orderMapper.insert(order);

order.setId(new Random(100).nextLong());
order.setOrderId(102);
order.setUserId(5);
orderMapper.insert(order);


HintManager.getInstance().setMasterRouteOnly(); //-----------------------------------核心 跟pagehelper 分页插件类似 只作用于最近的一条查询语句,
List<Order> byUserId = orderMapper.findByUserId(5);


HintManager.getInstance().setMasterRouteOnly();
List<Order> b2 = orderMapper.findByUserId(6);

List<Long> longs=new ArrayList<>();
longs.add(5L);
longs.add(6L);

HintManager.getInstance().setMasterRouteOnly();
List<Order> bys = orderMapper.findBys(longs);

Map map=new HashMap<>();
map.put("min",5);
map.put("max",6);
//orderMapper.findByUserIdBetween(map);
return order;
}


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM