Skip to content

Commit 6fbd377

Browse files
author
Alexander Lavrukov
committed
table-cache: remove getFirstLevelCache from table
1 parent 977e279 commit 6fbd377

File tree

4 files changed

+1
-22
lines changed
  • repository/src/main/java/tech/ydb/yoj/repository/db
  • repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory
  • repository-ydb-v1/src/main/java/tech/ydb/yoj/repository/ydb/table
  • repository-ydb-v2/src/main/java/tech/ydb/yoj/repository/ydb/table

4 files changed

+1
-22
lines changed

repository-inmemory/src/main/java/tech/ydb/yoj/repository/test/inmemory/InMemoryTable.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -534,11 +534,6 @@ private <ID extends Entity.Id<T>> boolean readTableFilter(T e, ReadTableParams<I
534534
return true;
535535
}
536536

537-
@Override
538-
public FirstLevelCache getFirstLevelCache() {
539-
return transaction.getTransactionLocal().firstLevelCache();
540-
}
541-
542537
@Nullable
543538
@Override
544539
public T postLoad(T entity) {

repository-ydb-v1/src/main/java/tech/ydb/yoj/repository/ydb/table/YdbTable.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -461,11 +461,6 @@ public <ID extends Id<T>> void migrate(ID id) {
461461
executor.getTransactionLocal().projectionCache().save(entityToSave);
462462
}
463463

464-
@Override
465-
public FirstLevelCache getFirstLevelCache() {
466-
return executor.getTransactionLocal().firstLevelCache();
467-
}
468-
469464
@Override
470465
@NonNull
471466
public T postLoad(T e) {

repository-ydb-v2/src/main/java/tech/ydb/yoj/repository/ydb/table/YdbTable.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
import tech.ydb.yoj.repository.db.Tx;
1717
import tech.ydb.yoj.repository.db.ViewSchema;
1818
import tech.ydb.yoj.repository.db.bulk.BulkParams;
19-
import tech.ydb.yoj.repository.db.cache.FirstLevelCache;
2019
import tech.ydb.yoj.repository.db.cache.TransactionLocal;
2120
import tech.ydb.yoj.repository.db.readtable.ReadTableParams;
2221
import tech.ydb.yoj.repository.db.statement.Changeset;
@@ -461,11 +460,6 @@ public <ID extends Id<T>> void migrate(ID id) {
461460
executor.getTransactionLocal().projectionCache().save(entityToSave);
462461
}
463462

464-
@Override
465-
public FirstLevelCache getFirstLevelCache() {
466-
return executor.getTransactionLocal().firstLevelCache();
467-
}
468-
469463
@Override
470464
@NonNull
471465
public T postLoad(T e) {

repository/src/main/java/tech/ydb/yoj/repository/db/Table.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
import tech.ydb.yoj.databind.expression.FilterExpression;
66
import tech.ydb.yoj.databind.expression.OrderExpression;
77
import tech.ydb.yoj.repository.db.bulk.BulkParams;
8-
import tech.ydb.yoj.repository.db.cache.FirstLevelCache;
98
import tech.ydb.yoj.repository.db.list.ListRequest;
109
import tech.ydb.yoj.repository.db.list.ListResult;
1110
import tech.ydb.yoj.repository.db.list.ViewListResult;
@@ -158,10 +157,6 @@ default <ID extends Entity.Id<T>> Stream<ID> readTableIds() {
158157
return readTableIds(ReadTableParams.getDefault());
159158
}
160159

161-
default FirstLevelCache getFirstLevelCache() {
162-
return null;
163-
}
164-
165160
@NonNull
166161
default <X extends Exception> T find(Entity.Id<T> id, Supplier<? extends X> throwIfAbsent) throws X {
167162
T found = find(id);
@@ -276,7 +271,7 @@ default <ID extends Entity.Id<T>> List<T> find(Set<ID> ids) {
276271
}
277272

278273
var orderBy = EntityExpressions.defaultOrder(getType());
279-
var cache = getFirstLevelCache();
274+
var cache = Tx.Current.get().getRepositoryTransaction().getTransactionLocal().firstLevelCache();
280275
var isPartialIdMode = ids.iterator().next().isPartial();
281276

282277
var foundInCache = ids.stream()

0 commit comments

Comments
 (0)