Spring data Couchbase 生成的查询方法不是线程安全的答案

【问题标题】：Spring data Couchbase generated query method not thread safeSpring data Couchbase 生成的查询方法不是线程安全的
【发布时间】：2019-07-03 20:37:32
【问题描述】：

当我扩展 CouchbaseRepository 接口以执行 findByField exp findByProvider --> 生成的方法不是线程安全的：

我的界面：

public interface WarehouseRepository extends CouchbaseRepository<WarehouseEntity, String> {

    List<WarehouseEntity> findByProvider(String provider);

}

我创建了一个线程池来测试它：

int threads = 3;
ExecutorService service = Executors.newFixedThreadPool(threads);
Collection<Future<Boolean>> futures = new ArrayList<>(threads);
for (int thread = 0; thread < threads; ++thread) {
    String provider ="P1";
    if(thread == 0)
        provider =  "P1";
    if (thread == 1)
        provider =  "P2";
    if(thread == 2)
        provider =  "P3";
    String expectedProvider = provider;
    Callable<Boolean> booleanSupplier = () -> {
        String foundProvider = warehouseService.findByProvider(expectedProvider).get(0).getProvider().toString();
        System.out.println("expectedProvider = " + expectedProvider  + " foundProvider = " + foundProvider);
        return expectedProvider.equals(foundProvider);//should never get false
    };

    futures.add(service.submit(booleanSupplier));
}
Set<Boolean> foundProviders = new HashSet<>();
for (Future<Boolean> future: futures) {
    foundProviders.add(future.get());
}
if (1 != foundProviders.size()) {
    System.out.println("got bad provider response for my query");
}

这是我的一次处决的结果：

2019/07/03 13:30:39.056 DEBUG Executing N1QL query: {\"args\":[\"P1\"],\"statement\":\"SELECT META(`oms`).id AS _ID, META(`oms`).cas AS _CAS, `oms`.* FROM `oms` WHERE (`provider` = $1) AND `_class` = \\"com.cmt.WarehouseEntity\\"\",\"scan_consistency\":\"statement_plus\"}
2019/07/03 13:30:39.058 DEBUG Executing N1QL query: {\"args\":[\"P3\"],\"statement\":\"SELECT META(`oms`).id AS _ID, META(`oms`).cas AS _CAS, `oms`.* FROM `oms` WHERE (`provider` = $1) AND `_class` = \\"com.cmt.WarehouseEntity\\"\",\"scan_consistency\":\"statement_plus\"}
2019/07/03 13:30:39.056 DEBUG Executing N1QL query: {\"args\":[\"P1\"],\"statement\":\"SELECT META(`oms`).id AS _ID, META(`oms`).cas AS _CAS, `oms`.* FROM `oms` WHERE (`provider` = $1) AND `_class` = \\"com.cmt.WarehouseEntity\\"\",\"scan_consistency\":\"statement_plus\"}
expectedProvider = P2 foundProvider = P1
expectedProvider = P3 foundProvider = P3
expectedProvider = P1 foundProvider = P1
got bad provider for my query

对于第一行中的查询expectedProvider = P2 foundProvider = P1，我们得到仓库p1的结果，用于查询找到仓库p2

但是当我将@Query 添加到我的方法中时，它变成了神奇的线程安全。

@Query("#{#n1ql.selectEntity} WHERE #{#n1ql.filter} AND $1 = provider")
List<WarehouseEntity> findByProvider(String provider);

这怎么可能？

谢谢

【问题讨论】：

标签： multithreading couchbase n1ql spring-data-couchbase

【解决方案1】：

这个问题似乎是 this change 在 2018 年 11 月提出的。

将您的 spring-data-couchbase 降级到 3.1.2.RELEASE。

【讨论】：

欢迎来到 SO！我们感谢您的意见，但请稍微编辑您的答案，例如通过引用更改的作用并解释它解决问题的原因。
这就是我所做的更改，我降级了spring数据版本以使其工作。我还在他们的 repo 中链接了一个提交，它破坏了线程安全，它解释了为什么 3.1.2 是最后一个按预期工作的。我不完全确定您的期望是什么？