CJDBCversion1.0.4: クラス org.objectweb.cjdbc.controller.cache.parsing.ParsingCache

00208 { 00209 if (request.isParsed()) 00210 return; 00211 00212 // Check cache 00213 String instanciatedSQL = request.getSQL(); 00214 AbstractRequest parsedRequest = (AbstractRequest) cache 00215 .get(instanciatedSQL); 00216 00217 if (parsedRequest == null) 00218 { // Cache miss 00219 String sqlSkeleton = request.getSqlSkeleton(); 00220 String sql; 00221 if (sqlSkeleton != null) 00222 { // Missed with instanciated query, try with skeleton 00223 sql = sqlSkeleton; 00224 parsedRequest = (AbstractRequest) cache.get(sql); 00225 if (parsedRequest != null) 00226 { // Cache hit with skeleton 00227 request.cloneParsing(parsedRequest); 00228 return; 00229 } 00230 } 00231 else 00232 sql = instanciatedSQL; 00233 00234 // Full cache miss. Note that the underlying cache Hashtable is 00235 // synchronized and we usually do not need to synchronize on it. 00236 // As we will have to add a cache entry, check if the cache size is ok 00237 // else remove the first entry of the hashtable. 00238 while (cache.size() > maxNbOfEntries) 00239 { // Remove first entry from Hashtable. We need to synchronize here to be 00240 // sure that we are not trying to concurrently remove the first cache 00241 // entry. 00242 synchronized (cache) 00243 { 00244 try 00245 { 00246 cache.remove(cache.keys().nextElement()); 00247 } 00248 catch (Exception ignore) 00249 { 00250 break; 00251 } 00252 } 00253 } 00254 00255 // Both skeleton and instanciated missed 00256 if (backgroundParsing) 00257 { 00258 // Find the parsing thread and request (note that Hasthtable is 00259 // synchronized) 00260 CurrentlyParsingEntry cpe = (CurrentlyParsingEntry) currentlyParsing 00261 .get(sql); 00262 if (cpe != null) 00263 { 00264 ParserThread pt = cpe.getParserThread(); 00265 try 00266 { 00267 if (pt != null) 00268 { 00269 // Wait for completion 00270 pt.join(); 00271 synchronized (currentlyParsing) 00272 { 00273 currentlyParsing.remove(sql); 00274 } 00275 00276 // Update cache 00277 if ((granularity != ParsingGranularities.COLUMN_UNIQUE) 00278 || (sqlSkeleton == null)) 00279 // No skeleton or no uniqueness criteria, add the query 00280 cache.put(instanciatedSQL, cpe.getRequest()); 00281 else 00282 { // We have a skeleton and COLUMN_UNIQUE parsing 00283 if (request.getCacheAbility() != RequestType.UNIQUE_CACHEABLE) 00284 // It is NOT UNIQUE, add the skeleton 00285 cache.put(sqlSkeleton, cpe.getRequest()); 00286 else 00287 // It is UNIQUE, add the instanciated query 00288 cache.put(instanciatedSQL, cpe.getRequest()); 00289 } 00290 } 00291 } 00292 catch (InterruptedException failed) 00293 { 00294 throw new SQLException(Translate.get( 00295 "cache.parsing.failed.join.parser.thread", new String[]{ 00296 "" + request.getId(), failed.getMessage()})); 00297 } 00298 } 00299 } 00300 // Parse it now because we didn't parse in background or 00301 // backgroundParsing has failed for any obscure reason. 00302 request.parse(requestManager.getDatabaseSchema(), granularity, 00303 caseSensitiveParsing); 00304 00305 // Update cache 00306 if ((sqlSkeleton != null) 00307 && (granularity == ParsingGranularities.COLUMN_UNIQUE) 00308 && (request.getCacheAbility() == RequestType.UNIQUE_CACHEABLE)) 00309 // If this is a unique request, we must put the instanciated query in 00310 // the cache to retrieve the exact pk value. 00311 cache.put(instanciatedSQL, request); 00312 else 00313 cache.put(sql, request); 00314 } 00315 else 00316 // Cache hit 00317 request.cloneParsing(parsedRequest); 00318 }


Public メソッド
	ParsingCache (int size, boolean backgroundParsing)
int	getGranularity ()
void	setGranularity (int granularity)
RequestManager	getRequestManager ()
void	setRequestManager (RequestManager requestManager)
void	getParsingFromCache (AbstractRequest request)
void	getParsingFromCacheAndParseIfMissing (AbstractRequest request) throws SQLException
boolean	isBackgroundParsing ()
void	setBackgroundParsing (boolean backgroundParsing)
void	setCaseSensitiveParsing (boolean isCaseSensitiveParsing)
boolean	isCaseSensitiveParsing ()
String	getXml ()
Private 変数
Hashtable	cache
Hashtable	currentlyParsing
RequestManager	requestManager
int	granularity
int	maxNbOfEntries
boolean	backgroundParsing
boolean	caseSensitiveParsing

クラス org.objectweb.cjdbc.controller.cache.parsing.ParsingCache

説明

Public メソッド

Private 変数

コンストラクタとデストラクタ

メソッド

変数