table-cache: remove getFirstLevelCache from table

ydb-platform · Apr 8, 2024 · 6fbd377 · 6fbd377
1 parent 977e279
commit 6fbd377
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 22 deletions.
diff --git a/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java b/repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java
@@ -534,11 +534,6 @@ private <ID extends Entity.Id<T>> boolean readTableFilter(T e, ReadTableParams<I
         return true;
     }
 
-    @Override
-    public FirstLevelCache getFirstLevelCache() {
-        return transaction.getTransactionLocal().firstLevelCache();
-    }
-
     @Nullable
     @Override
     public T postLoad(T entity) {

diff --git a/repository-ydb-v1/src/main/java/tech/ydb/yoj/repository/ydb/table/YdbTable.java b/repository-ydb-v1/src/main/java/tech/ydb/yoj/repository/ydb/table/YdbTable.java
@@ -461,11 +461,6 @@ public <ID extends Id<T>> void migrate(ID id) {
         executor.getTransactionLocal().projectionCache().save(entityToSave);
     }
 
-    @Override
-    public FirstLevelCache getFirstLevelCache() {
-        return executor.getTransactionLocal().firstLevelCache();
-    }
-
     @Override
     @NonNull
     public T postLoad(T e) {

diff --git a/repository-ydb-v2/src/main/java/tech/ydb/yoj/repository/ydb/table/YdbTable.java b/repository-ydb-v2/src/main/java/tech/ydb/yoj/repository/ydb/table/YdbTable.java
@@ -16,7 +16,6 @@
 import tech.ydb.yoj.repository.db.Tx;
 import tech.ydb.yoj.repository.db.ViewSchema;
 import tech.ydb.yoj.repository.db.bulk.BulkParams;
-import tech.ydb.yoj.repository.db.cache.FirstLevelCache;
 import tech.ydb.yoj.repository.db.cache.TransactionLocal;
 import tech.ydb.yoj.repository.db.readtable.ReadTableParams;
 import tech.ydb.yoj.repository.db.statement.Changeset;
@@ -461,11 +460,6 @@ public <ID extends Id<T>> void migrate(ID id) {
         executor.getTransactionLocal().projectionCache().save(entityToSave);
     }
 
-    @Override
-    public FirstLevelCache getFirstLevelCache() {
-        return executor.getTransactionLocal().firstLevelCache();
-    }
-
     @Override
     @NonNull
     public T postLoad(T e) {

diff --git a/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java b/repository/src/main/java/tech/ydb/yoj/repository/db/Table.java
@@ -5,7 +5,6 @@
 import tech.ydb.yoj.databind.expression.FilterExpression;
 import tech.ydb.yoj.databind.expression.OrderExpression;
 import tech.ydb.yoj.repository.db.bulk.BulkParams;
-import tech.ydb.yoj.repository.db.cache.FirstLevelCache;
 import tech.ydb.yoj.repository.db.list.ListRequest;
 import tech.ydb.yoj.repository.db.list.ListResult;
 import tech.ydb.yoj.repository.db.list.ViewListResult;
@@ -158,10 +157,6 @@ default <ID extends Entity.Id<T>> Stream<ID> readTableIds() {
         return readTableIds(ReadTableParams.getDefault());
     }
 
-    default FirstLevelCache getFirstLevelCache() {
-        return null;
-    }
-
     @NonNull
     default <X extends Exception> T find(Entity.Id<T> id, Supplier<? extends X> throwIfAbsent) throws X {
         T found = find(id);
@@ -276,7 +271,7 @@ default <ID extends Entity.Id<T>> List<T> find(Set<ID> ids) {
         }
 
         var orderBy = EntityExpressions.defaultOrder(getType());
-        var cache = getFirstLevelCache();
+        var cache = Tx.Current.get().getRepositoryTransaction().getTransactionLocal().firstLevelCache();
         var isPartialIdMode = ids.iterator().next().isPartial();
 
         var foundInCache = ids.stream()