CJDBCversion1.0rc6: org.objectweb.cjdbc.controller.virtualdatabase.ControllerResultSet class Reference

Build a C-JDBC ResultSet from a database specific ResultSet. The metadata can be retrieved from the MetadataCache if provided. If a metadata cache is provided but the data is not in the cache, the MetadataCache is updated accordingly. The remaining code is a straightforward copy of both metadata and data.

00080   {
00081     try
00082     {
00083       if (rs == null)
00084         throw new SQLException("Null ResultSet");
00085 
00086       // This is already a result coming from another controller.
00087       //if (rs instanceof org.objectweb.cjdbc.driver.ResultSet)
00088       //  return (org.objectweb.cjdbc.driver.ResultSet) rs;
00089 
00090       // Build the ResultSet metaData
00091       int nbColumn;
00092       if (metadataCache != null)
00093         fields = metadataCache.getMetadata(request);
00094 
00095       if (fields == null)
00096       { // Metadata Cache miss
00097         // Build the fields from the MetaData
00098         java.sql.ResultSetMetaData metaData = rs.getMetaData();
00099         if (metaData == null)
00100           throw new SQLException("unable to fetch metadata");
00101         nbColumn = metaData.getColumnCount();
00102         fields = new Field[nbColumn];
00103         for (int i = 0; i < nbColumn; i++)
00104         {
00105           // 1st column is 1
00106           String columnName = metaData.getColumnName(i + 1);
00107           if (metadataCache != null)
00108           { // Check Field cache
00109             fields[i] = metadataCache.getField(columnName);
00110             if (fields[i] != null)
00111               continue; // Cache hit
00112           }
00113           // Field cache miss
00114           String tableName = null;
00115           try
00116           {
00117             tableName = metaData.getTableName(i + 1);
00118           }
00119           catch (Exception ignore)
00120           {
00121           }
00122           int columnDisplaySize = 0;
00123           try
00124           {
00125             columnDisplaySize = metaData.getColumnDisplaySize(i + 1);
00126           }
00127           catch (Exception ignore)
00128           {
00129           }
00130           int columnType = -1;
00131           try
00132           {
00133             columnType = metaData.getColumnType(i + 1);
00134           }
00135           catch (Exception ignore)
00136           {
00137           }
00138           String columnTypeName = null;
00139           try
00140           {
00141             columnTypeName = metaData.getColumnTypeName(i + 1);
00142           }
00143           catch (Exception ignore)
00144           {
00145           }
00146           String columnClassName = null;
00147           try
00148           {
00149             columnClassName = metaData.getColumnClassName(i + 1);
00150           }
00151           catch (Exception ignore)
00152           {
00153           }
00154           boolean isAutoIncrement = false;
00155           try
00156           {
00157             isAutoIncrement = metaData.isAutoIncrement(i + 1);
00158           }
00159           catch (Exception ignore)
00160           {
00161           }
00162           boolean isCaseSensitive = false;
00163           try
00164           {
00165             isCaseSensitive = metaData.isCaseSensitive(i + 1);
00166           }
00167           catch (Exception ignore)
00168           {
00169           }
00170           boolean isCurrency = false;
00171           try
00172           {
00173             isCurrency = metaData.isCurrency(i + 1);
00174           }
00175           catch (Exception ignore)
00176           {
00177           }
00178           int isNullable = ResultSetMetaData.columnNullableUnknown;
00179           try
00180           {
00181             isNullable = metaData.isNullable(i + 1);
00182           }
00183           catch (Exception ignore)
00184           {
00185           }
00186           boolean isReadOnly = false;
00187           try
00188           {
00189             isReadOnly = metaData.isReadOnly(i + 1);
00190           }
00191           catch (Exception ignore)
00192           {
00193           }
00194           boolean isWritable = false;
00195           try
00196           {
00197             isWritable = metaData.isWritable(i + 1);
00198           }
00199           catch (Exception ignore)
00200           {
00201           }
00202           boolean isDefinitelyWritable = false;
00203           try
00204           {
00205             isReadOnly = metaData.isDefinitelyWritable(i + 1);
00206           }
00207           catch (Exception ignore)
00208           {
00209           }
00210           boolean isSearchable = false;
00211           try
00212           {
00213             isSearchable = metaData.isSearchable(i + 1);
00214           }
00215           catch (Exception ignore)
00216           {
00217           }
00218           boolean isSigned = false;
00219           try
00220           {
00221             isSigned = metaData.isSigned(i + 1);
00222           }
00223           catch (Exception ignore)
00224           {
00225           }
00226           int precision = 0;
00227           try
00228           {
00229             precision = metaData.getPrecision(i + 1);
00230           }
00231           catch (Exception ignore)
00232           {
00233           }
00234           int scale = 0;
00235           try
00236           {
00237             scale = metaData.getScale(i + 1);
00238           }
00239           catch (Exception ignore)
00240           {
00241           }
00242           fields[i] = new Field(tableName, columnName, columnDisplaySize,
00243               columnType, columnTypeName, columnClassName, isAutoIncrement,
00244               isCaseSensitive, isCurrency, isNullable, isReadOnly, isWritable,
00245               isDefinitelyWritable, isSearchable, isSigned, precision, scale);
00246 
00247           if (metadataCache != null)
00248             // Add field to cache
00249             metadataCache.addField(columnName, fields[i]);
00250         }
00251       }
00252       else
00253         nbColumn = fields.length;
00254 
00255       // Build the ResultSet data
00256       if (rs.next())
00257       {
00258         if (request instanceof SelectRequest)
00259         {
00260           SelectRequest select = (SelectRequest) request;
00261           cursorName = select.getCursorName();
00262           fetchSize = select.getFetchSize();
00263         }
00264         maxRows = request.getMaxRows();
00265         if (maxRows == 0)
00266           maxRows = Integer.MAX_VALUE; // Infinite number of rows
00267 
00268         // Note that fetchData updates the data field
00269         dbResultSet = rs;
00270         fetchData();
00271         if (hasMoreData && (cursorName == null))
00272           cursorName = String.valueOf(dbResultSet.hashCode());
00273       }
00274       else
00275       {
00276         hasMoreData = false;
00277         dbResultSet = null;
00278         dbResultSetClosed = true;
00279         rs.close();
00280       }
00281     }
00282     catch (SQLException e)
00283     {
00284       throw new SQLException("Error while building C-JDBC ResultSet (" + e
00285           + ")");
00286     }
00287   }


Public メソッド
	ControllerResultSet (AbstractRequest request, java.sql.ResultSet rs, MetadataCache metadataCache) throws SQLException
ArrayList	fetchData () throws SQLException
ArrayList	getData ()
Field[]	getFields ()
String	getCursorName ()
boolean	hasMoreData ()
void	closeResultSet ()
Private 変数
ArrayList	data = null
Field[]	fields = null
String	cursorName = null
int	fetchSize = 0
ResultSet	dbResultSet = null
boolean	dbResultSetClosed = true
boolean	hasMoreData = false
int	maxRows = 0

クラス org.objectweb.cjdbc.controller.virtualdatabase.ControllerResultSet

説明

Public メソッド

Private 変数

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

メソッド

変数