lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
RedKale
2016-04-12 20:46:18 +08:00
parent feb0378ab9
commit 30874394af
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/org/redkale/source/DataDefaultSource.java
View File

@@ -1164,7 +1164,10 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
public <T> T find(Class<T> clazz, final SelectColumn selects, Serializable pk) { public <T> T find(Class<T> clazz, final SelectColumn selects, Serializable pk) {
final EntityInfo<T> info = loadEntityInfo(clazz); final EntityInfo<T> info = loadEntityInfo(clazz);
final EntityCache<T> cache = info.getCache(); final EntityCache<T> cache = info.getCache();
if (cache != null && cache.isFullLoaded()) return cache.find(selects, pk); if (cache != null) {
T rs = cache.find(selects, pk);
if (cache.isFullLoaded() || rs != null) return rs;
}
final Connection conn = createReadSQLConnection(); final Connection conn = createReadSQLConnection();
try { try {
@@ -1273,7 +1276,10 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
public <T> boolean exists(Class<T> clazz, Serializable pk) { public <T> boolean exists(Class<T> clazz, Serializable pk) {
final EntityInfo<T> info = loadEntityInfo(clazz); final EntityInfo<T> info = loadEntityInfo(clazz);
final EntityCache<T> cache = info.getCache(); final EntityCache<T> cache = info.getCache();
if (cache != null && cache.isFullLoaded()) return cache.exists(pk); if (cache != null) {
boolean rs = cache.exists(pk);
if (rs || cache.isFullLoaded()) return rs;
}
final Connection conn = createReadSQLConnection(); final Connection conn = createReadSQLConnection();
try { try {
@@ -1675,11 +1681,11 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
private <T> Sheet<T> querySheet(final boolean readcache, final boolean needtotal, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) { private <T> Sheet<T> querySheet(final boolean readcache, final boolean needtotal, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
final EntityInfo<T> info = loadEntityInfo(clazz); final EntityInfo<T> info = loadEntityInfo(clazz);
final EntityCache<T> cache = info.getCache(); final EntityCache<T> cache = info.getCache();
if (readcache && cache != null) { if (readcache && cache != null && cache.isFullLoaded()) {
if (node == null || node.isCacheUseable(this)) { if (node == null || node.isCacheUseable(this)) {
if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(clazz.getSimpleName() + " cache query predicate = " + (node == null ? null : node.createPredicate(cache))); if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(clazz.getSimpleName() + " cache query predicate = " + (node == null ? null : node.createPredicate(cache)));
Sheet<T> sheet = cache.querySheet(needtotal, selects, flipper, node); Sheet<T> sheet = cache.querySheet(needtotal, selects, flipper, node);
if (!sheet.isEmpty() || info.isVirtualEntity() || cache.isFullLoaded()) return sheet; if (!sheet.isEmpty() || info.isVirtualEntity()) return sheet;
} }
} }
final Connection conn = createReadSQLConnection(); final Connection conn = createReadSQLConnection();