评分

提问MYSQL Order By 字段内容重复，可能导致数据重复出现，无法复现？

1764

目前我存在一个线上的问题，经排查发现可能是是由于查询时order by根据更新时间排序，但是更新时间都是同一时间导致。

网上大量重复资源，感觉最靠谱的一个如下：

https://www.cnblogs.com/codingchangeworld/p/15834849.html

为了验证是因为这个原因导致的数据重复创建如下测试DEMO，但无法复现场景，求大佬教教我该怎么复现

/**
     * mysql 排序字段相同时，排序返回是否有序，如果发生乱序，那么set肯定会重复
     * 例如： id=1  page=1    id=1 page=3 相同id在第一页和第三页同时出现
     */
    @Test
    public void pageBySameTimeSortTest(){
        IPage<IbcUsdTrade> page = new Page<>();
        Map<Long,Long> trades = new HashMap<>();
        LambdaQueryWrapper<IbcUsdTrade> wrapper = new LambdaQueryWrapper<>();
//        wrapper.eq(IbcUsdTrade::getRecUpdateTime,"2022-11-21 12:33:06");
        wrapper.orderByAsc(IbcUsdTrade::getRecUpdateTime);
        page.setSize(10);
        boolean flag = false;
        for (int i = 1; i <= 50;) {
            page.setCurrent(i++);
            IPage<IbcUsdTrade> result = ibcUsdTradeMapper.selectPage(page, wrapper);
            List<IbcUsdTrade> records = result.getRecords();
            for (int i1 = 0; i1 < records.size(); i1++) {
                if (trades.containsKey(records.get(i1).getId())) {
                    flag = true;
                    System.out.print("位置两个id不相同"+records.get(i1).getId()+","+trades.get(records.get(i1).getId())+","+page.getCurrent());
                    break;
                }
                trades.put(records.get(i1).getId(),page.getCurrent());
            }
            Assert.isTrue(!flag,"存在不相同的数");
        }


    }

Java

评分

欢迎为Ta评分

回答4

只看作者

最新最热

- 水边0
  最大的可能性，不是order by的问题，而是你在打开当前页与翻到下一页的这段时间内，来了一条新记录，这样，你打开下一页时，下一页的第一条记录，就是之前看过的最后一条记录了。如果猜不到原因，确实难以复现。其实多打打日志也能发现，每次翻页都把显示的数据打印到日志里，进行对比就知道了。
  1年前回复
- Aura0
  你好，这是我根据你的代码改写的一个简单地测试demo，发现并无问题。建议可以输出你的SQL日志去数据库执行一遍观察结果
  2年前回复

用户555766000
这个问题是存在一定偶发性的，最简单的判断方法就是在分页的临界点放置两条order条件一样的数据，就会有概率在第一页最后一条跟第二页第一条出现同一数据，相同order条件一样的数据多反而可能不是很好找
2年前回复

用户17435062作者0

你好我使用你讲到的方式测试过了，而且用到了死循环调用了十分中左右依旧没有看到所谓的随机排序，经过我多次debuger都发现他是按照固定的id顺序排列的，不过还是谢谢你的回答


public void pageBySameTimeSortTest(){
        IPage page = new Page();
        LambdaQueryWrapper wrapper = new LambdaQueryWrapper();
//        wrapper.eq(IbcUsdTrade::getRecUpdateTime,"2022-11-21 12:33:06");
        wrapper.orderByAsc(IbcUsdTrade::getRecUpdateTime);
        page.setSize(10);
        boolean flag = false;
        while (true){
            Map trades = new HashMap();

            for (int i = 1; i <= 2;) {
                page.setCurrent(i++);
                IPage result = ibcUsdTradeMapper.selectPage(page, wrapper);
                List records = result.getRecords();
                for (int i1 = 0; i1 < records.size(); i1++) {
                    if (trades.containsKey(records.get(i1).getId())) {
                        flag = true;
                        System.out.print("位置两个id不相同"+records.get(i1).getId()+","+trades.get(records.get(i1).getId())+","+page.getCurrent());
                        break;
                    }
                    trades.put(records.get(i1).getId(),page.getCurrent());
                }
                Assert.isTrue(!flag,"存在不相同的数");
            }
        }
    }

2年前@用户55576600