CJDBCversion1.0.4: クラス org.objectweb.cjdbc.controller.cache.result.schema.CacheDatabaseTable

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

00064 { 00065 // Clone the name and the columns 00066 name = databaseTable.getName(); 00067 ArrayList origColumns = databaseTable.getColumns(); 00068 int size = origColumns.size(); 00069 columns = new ArrayList(size); 00070 for (int i = 0; i < size; i++) 00071 columns.add(new CacheDatabaseColumn(((DatabaseColumn) origColumns.get(i)) 00072 .getName())); 00073 00074 // Create an empty cache 00075 cacheEntries = new ArrayList(); 00076 pkCacheEntries = new HashMap(); 00077 }

00173 { 00174 if (!(other instanceof CacheDatabaseTable)) 00175 return false; 00176 00177 CacheDatabaseTable t = (CacheDatabaseTable) other; 00178 return t.getName().equals(name) && t.getColumns().equals(columns); 00179 }

00155 { 00156 for (Iterator i = columns.iterator(); i.hasNext();) 00157 { 00158 CacheDatabaseColumn c = (CacheDatabaseColumn) i.next(); 00159 if (columnName.compareToIgnoreCase(c.getName()) == 0) 00160 return c; 00161 } 00162 return null; 00163 }

00280 { 00281 String result = "Table " + name + ": "; 00282 int size = columns.size(); 00283 for (int i = 0; i < size; i++) 00284 { 00285 CacheDatabaseColumn c = (CacheDatabaseColumn) columns.get(i); 00286 if (longFormat) 00287 result += "\n"; 00288 result += c.getInformation(); 00289 if (!longFormat && (i < size - 1)) 00290 result += ","; 00291 } 00292 return result; 00293 }

00241 { 00242 synchronized (this) 00243 { 00244 for (Iterator i = cacheEntries.iterator(); i.hasNext();) 00245 ((ResultCacheEntry) i.next()).invalidate(); 00246 cacheEntries.clear(); 00247 00248 for (int i = 0; i < columns.size(); i++) 00249 ((CacheDatabaseColumn) columns.get(i)).invalidateAll(); 00250 } 00251 synchronized (pkCacheEntries) 00252 { // All pk cache entries have been invalidated as a side effect by the 00253 // above loop. 00254 pkCacheEntries.clear(); 00255 } 00256 }

00263 { 00264 for (Iterator i = cacheEntries.iterator(); i.hasNext();) 00265 { 00266 ResultCacheEntry qce = (ResultCacheEntry) i.next(); 00267 if (qce.getRequest().getCacheAbility() != RequestType.UNIQUE_CACHEABLE) 00268 qce.invalidate(); 00269 } 00270 cacheEntries.clear(); 00271 }

00110 { 00111 if (t == null) 00112 return; 00113 00114 ArrayList otherColumns = t.getColumns(); 00115 if (otherColumns == null) 00116 return; 00117 00118 int size = otherColumns.size(); 00119 for (int i = 0; i < size; i++) 00120 { 00121 CacheDatabaseColumn c = (CacheDatabaseColumn) otherColumns.get(i); 00122 CacheDatabaseColumn original = getColumn(c.getName()); 00123 if (original == null) 00124 addColumn(c); 00125 else 00126 { 00127 if (!original.equals(c)) 00128 throw new SQLException("Column " + c.getName() 00129 + " definition mismatch."); 00130 } 00131 } 00132 }


Public メソッド
	CacheDatabaseTable (DatabaseTable databaseTable)
String	getName ()
void	addColumn (CacheDatabaseColumn column)
void	mergeColumns (CacheDatabaseTable t) throws SQLException
ArrayList	getColumns ()
CacheDatabaseColumn	getColumn (String columnName)
boolean	equals (Object other)
synchronized void	addCacheEntry (CacheEntry ce)
void	addPkCacheEntry (String pk, CacheEntry ce)
ResultCacheEntry	getPkResultCacheEntry (String pk)
void	removePkResultCacheEntry (Object pk)
void	invalidateAll ()
synchronized void	invalidateAllExceptPk ()
String	getInformation (boolean longFormat)
Private 変数
String	name
ArrayList	columns
ArrayList	cacheEntries
HashMap	pkCacheEntries

クラス org.objectweb.cjdbc.controller.cache.result.schema.CacheDatabaseTable

説明

Public メソッド

Private 変数

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

メソッド

変数