dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix transactionalCache.getOrFetchFromDB

Browse Source
This commit is contained in:
ViacheslavKlimov 2024-08-21 12:42:20 +03:00
parent 25e351146c
commit 92c09243ef
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
common/cache/src/main/java/org/thingsboard/server/cache/TbTransactionalCache.java vendored
View File

@ -53,7 +53,7 @@ public interface TbTransactionalCache<K extends Serializable, V extends Serializ
if (putToCache) { if (putToCache) {
return getAndPutInTransaction(key, dbCall, cacheNullValue); return getAndPutInTransaction(key, dbCall, cacheNullValue);
} else { } else {
TbCacheValueWrapper<V> cacheValueWrapper = get(key); TbCacheValueWrapper<V> cacheValueWrapper = get(key, true);
if (cacheValueWrapper != null) { if (cacheValueWrapper != null) {
return cacheValueWrapper.get(); return cacheValueWrapper.get();
} }
@ -92,7 +92,7 @@ public interface TbTransactionalCache<K extends Serializable, V extends Serializ
if (putToCache) { if (putToCache) {
return getAndPutInTransaction(key, dbCall, cacheValueToResult, dbValueToCacheValue, cacheNullValue); return getAndPutInTransaction(key, dbCall, cacheValueToResult, dbValueToCacheValue, cacheNullValue);
} else { } else {
TbCacheValueWrapper<V> cacheValueWrapper = get(key); TbCacheValueWrapper<V> cacheValueWrapper = get(key, true);
if (cacheValueWrapper != null) { if (cacheValueWrapper != null) {
var cacheValue = cacheValueWrapper.get(); var cacheValue = cacheValueWrapper.get();
return cacheValue == null ? null : cacheValueToResult.apply(cacheValue); return cacheValue == null ? null : cacheValueToResult.apply(cacheValue);