Inheritance diagram for Deveel.Data.Protocol.QueryResult:

Public Member Functions
QueryResultColumn	GetColumn (int columnOffset)

void	LockRoot ()

void	Release ()

void	Dispose ()

DataObject	GetValue (int rowIndex, int columnIndex)

	QueryResult (SqlQuery query, Table result)
	Constructs the result set. More...

StreamableObject	GetRef (long id)
	Returns a IRef that has been cached in this table object by its identifier value. More...

void	RemoveRef (long id)
	Removes a IRef that has been cached in this table object by its identifier value. More...

void	Dispose ()
	Disposes this object. More...

TObject	GetCellContents (int column, int row)
	Gets the cell contents of the cell at the given row/column. More...

void	LockRoot (int key)
	Locks the root of the result set. More...

Package Functions
	QueryResult (SqlQuery query, ITable result)

Properties
SqlQuery	Query `[get, private set]`

ITable	Result `[get, private set]`

int	RowCount `[get]`
	Returns the row count. More...

int	ColumnCount `[get]`
	Returns the column count. More...

QueryResultColumn[]	Fields `[get]`
	Returns the QueryResultColumn array of all the columns in the result. More...

Private Member Functions
void	FormColumns (ITable result)

void	UnlockRoot (int key)
	Unlocks the root of the result set. More...

Private Attributes
QueryResultColumn[]	columns

bool	resultIsSimpleEnum

IList< int >	rowIndexMap
	The IList<T> that contains the row index into the table for each row of the result. More...

int	locked
	Incremented when we Lock roots. More...

SqlQuery	query
	The SqlQuery that was executed to produce this result. More...

Table	result
	The table that is the result. More...

QueryResultColumn[]	colDesc
	A set of QueryResultColumn that describes each column in the ResultSet. More...

readonly bool	resultIsSimpleEnum
	Set to true if the result table has a SimpleRowEnumerator, therefore guarenteeing we do not need to store a row lookup list. More...

readonly int	resultRowCount
	The number of rows in the result. More...

readonly Dictionary< long, StreamableObject >	streamableBlobMap
	A Dictionary<TKey,TValue> of blob_reference_id values to IRef objects used to handle and streamable objects in this result. More...

Detailed Description

Definition at line 25 of file QueryResult.cs.

Constructor & Destructor Documentation

Deveel.Data.Protocol.QueryResult.QueryResult	(	SqlQuery	query,
		ITable	result
	)

inlinepackage

Definition at line 33 of file QueryResult.cs.

                                                             {
             Query = query;
             Result = result;
             FormColumns(Result);
 
             locked = 0;
         }

Deveel.Data.Protocol.QueryResult.QueryResult	(	SqlQuery	query,
		Table	result
	)

inline

Constructs the result set.

Parameters

query
result

Definition at line 72 of file QueryResult.old.cs.

                                                          {
             this.query = query;
             this.result = result;
             streamableBlobMap = new Dictionary<long, StreamableObject>();
 
             resultRowCount = result.RowCount;
 
             // HACK: Read the contents of the first row so that we can pick up
             //   any errors with reading, and also to fix the 'uniquekey' bug
             //   that causes a new transaction to be started if 'uniquekey' is
             //   a column and the value is resolved later.
             IRowEnumerator rowEnum = result.GetRowEnumerator();
             if (rowEnum.MoveNext()) {
                 int rowIndex = rowEnum.RowIndex;
                 for (int c = 0; c < result.ColumnCount; ++c) {
                     result.GetCell(c, rowIndex);
                 }
             }
 
             // If simple enum, note it here
             resultIsSimpleEnum = (rowEnum is SimpleRowEnumerator);
             rowEnum = null;
 
             // Build 'row_index_map' if not a simple enum
             if (!resultIsSimpleEnum) {
                 rowIndexMap = new List<int>(result.RowCount);
 
                 IRowEnumerator en = result.GetRowEnumerator();
                 while (en.MoveNext()) {
                     rowIndexMap.Add(en.RowIndex);
                 }
             }
 
             // This is a safe operation provides we are shared.
             // Copy all the TableField columns from the table to our own
             // QueryResultColumn array, naming each column by what is returned from
             // the 'GetResolvedVariable' method.
             int colCount = result.ColumnCount;
             colDesc = new QueryResultColumn[colCount];
             for (int i = 0; i < colCount; ++i) {
                 VariableName v = result.GetResolvedVariable(i);
                 string fieldName;
                 if (v.TableName == null) {
                     // This means the column is an alias
                     fieldName = String.Format("@a{0}", v.Name);
                 } else {
                     // This means the column is an schema/table/column reference
                     fieldName = String.Format("@f{0}", v);
                 }
 
                 colDesc[i] = new QueryResultColumn(fieldName, result.GetColumnInfo(i));
             }
 
             locked = 0;
         }

Member Function Documentation

void Deveel.Data.Protocol.QueryResult.Dispose ( )

inline

Definition at line 119 of file QueryResult.cs.

                               {
             if (locked > 0) {
                 Release();
             }
 
             Result = null;
             Query = null;
             columns = null;
             rowIndexMap = null;
         }

void Deveel.Data.Protocol.QueryResult.Dispose ( )

inline

Disposes this object.

Definition at line 154 of file QueryResult.old.cs.

                               {
             while (locked > 0) {
                 UnlockRoot(-1);
             }
             result = null;
             rowIndexMap = null;
             colDesc = null;
         }

void Deveel.Data.Protocol.QueryResult.FormColumns ( ITable result )

inlineprivate

Definition at line 41 of file QueryResult.cs.

                                                 {
             // HACK: Read the contents of the first row so that we can pick up
             //   any errors with reading, and also to fix the 'uniquekey' bug
             //   that causes a new transaction to be started if 'uniquekey' is
             //   a column and the value is resolved later.
             var columnCount = result.TableInfo.ColumnCount;
             using (var rowEnum = result.GetEnumerator()) {
                 if (rowEnum.MoveNext()) {
                     int rowIndex = rowEnum.Current.RowId.RowNumber;
                     for (int c = 0; c < columnCount; ++c) {
                         result.GetValue(rowIndex, c);
                     }
                 }
 
                 // If simple enum, note it here
                 resultIsSimpleEnum = (rowEnum is SimpleRowEnumerator);
             }
 
             // Build 'row_index_map' if not a simple enum
             if (!resultIsSimpleEnum) {
                 rowIndexMap = new List<int>(result.RowCount);
 
                 var en = result.GetEnumerator();
                 while (en.MoveNext()) {
                     rowIndexMap.Add(en.Current.RowId.RowNumber);
                 }
             }
 
             // This is a safe operation provides we are shared.
             // Copy all the TableField columns from the table to our own
             // QueryResultColumn array, naming each column by what is returned from
             // the 'GetResolvedVariable' method.
             int colCount = result.TableInfo.ColumnCount;
             columns = new QueryResultColumn[colCount];
             for (int i = 0; i < colCount; ++i) {
                 var v = result.GetResolvedColumnName(i);
                 string fieldName;
                 if (v.ParentName == null) {
                     // This means the column is an alias
                     fieldName = String.Format("@a{0}", v.Name);
                 } else {
                     // This means the column is an schema/table/column reference
                     fieldName = String.Format("@f{0}", v);
                 }
 
                 columns[i] = new QueryResultColumn(fieldName, result.TableInfo[i]);
             }
         }

TObject Deveel.Data.Protocol.QueryResult.GetCellContents	(	int	column,
		int	row
	)

inline

Gets the cell contents of the cell at the given row/column.

Parameters

column
row

Safe only if roots are locked.

Returns

Definition at line 172 of file QueryResult.old.cs.

                                                             {
             if (locked <= 0)
                 throw new Exception("Table roots not locked!");
 
             int realRow = resultIsSimpleEnum ? row : rowIndexMap[row];
             TObject tob = result.GetCell(column, realRow);
 
             // If this is a large object reference then cache it so a streamable
             // object can reference it via this result.
             if (tob.Object is IRef) {
                 var reference = (IRef) tob.Object;
                 streamableBlobMap[reference.Id] = 
                     new StreamableObject(reference.Type, reference.RawSize, reference.Id);
             }
 
             return tob;
         }

QueryResultColumn Deveel.Data.Protocol.QueryResult.GetColumn ( int columnOffset )

inline

Definition at line 102 of file QueryResult.cs.

                                                              {
             if (columnOffset < 0 || columnOffset >= ColumnCount)
                 throw new ArgumentOutOfRangeException("columnOffset");
 
             return columns[columnOffset];
         }

StreamableObject Deveel.Data.Protocol.QueryResult.GetRef ( long id )

inline

Returns a IRef that has been cached in this table object by its identifier value.

Parameters

id

Returns

Definition at line 134 of file QueryResult.old.cs.

                                                 {
             StreamableObject reference;
             if (!streamableBlobMap.TryGetValue(id, out reference))
                 return null;
 
             return reference;
         }

DataObject Deveel.Data.Protocol.QueryResult.GetValue	(	int	rowIndex,
		int	columnIndex
	)

inline

Definition at line 130 of file QueryResult.cs.

                                                                   {
             if (locked <= 0)
                 throw new Exception("Table roots not locked!");
 
             int realRow = resultIsSimpleEnum ? rowIndex : rowIndexMap[rowIndex];
             var obj = Result.GetValue(realRow, columnIndex);
 
             // TODO: support large object references
 
             return obj;
         }

void Deveel.Data.Protocol.QueryResult.LockRoot ( )

inline

Definition at line 109 of file QueryResult.cs.

                                {
             Result.Lock();
             locked++;
         }

void Deveel.Data.Protocol.QueryResult.LockRoot ( int key )

inline

Locks the root of the result set.

Parameters

key

Definition at line 215 of file QueryResult.old.cs.

                                       {
             result.LockRoot(key);
             ++locked;
         }

void Deveel.Data.Protocol.QueryResult.Release ( )

inline

Definition at line 114 of file QueryResult.cs.

                               {
             Result.Release();
             --locked;
         }

void Deveel.Data.Protocol.QueryResult.RemoveRef ( long id )

inline

Removes a IRef that has been cached in this table object by its identifier value.

Parameters

id

Definition at line 147 of file QueryResult.old.cs.

                                        {
             streamableBlobMap.Remove(id);
         }

void Deveel.Data.Protocol.QueryResult.UnlockRoot ( int key )

inlineprivate

Unlocks the root of the result set.

Parameters

key

Definition at line 224 of file QueryResult.old.cs.

                                          {
             result.UnlockRoot(key);
             --locked;
         }

Member Data Documentation

QueryResultColumn [] Deveel.Data.Protocol.QueryResult.colDesc

private

A set of QueryResultColumn that describes each column in the ResultSet.

Definition at line 36 of file QueryResult.old.cs.

QueryResultColumn [] Deveel.Data.Protocol.QueryResult.columns

private

Definition at line 26 of file QueryResult.cs.

int Deveel.Data.Protocol.QueryResult.locked

private

Incremented when we Lock roots.

Definition at line 31 of file QueryResult.cs.

SqlQuery Deveel.Data.Protocol.QueryResult.query

private

The SqlQuery that was executed to produce this result.

Definition at line 26 of file QueryResult.old.cs.

Table Deveel.Data.Protocol.QueryResult.result

private

The table that is the result.

Definition at line 31 of file QueryResult.old.cs.

bool Deveel.Data.Protocol.QueryResult.resultIsSimpleEnum

private

Definition at line 28 of file QueryResult.cs.

readonly bool Deveel.Data.Protocol.QueryResult.resultIsSimpleEnum

private

Set to true if the result table has a SimpleRowEnumerator, therefore guarenteeing we do not need to store a row lookup list.

Definition at line 48 of file QueryResult.old.cs.

readonly int Deveel.Data.Protocol.QueryResult.resultRowCount

private

The number of rows in the result.

Definition at line 53 of file QueryResult.old.cs.

IList< int > Deveel.Data.Protocol.QueryResult.rowIndexMap

private

The IList<T> that contains the row index into the table for each row of the result.

Definition at line 29 of file QueryResult.cs.

readonly Dictionary<long, StreamableObject> Deveel.Data.Protocol.QueryResult.streamableBlobMap

private

A Dictionary<TKey,TValue> of blob_reference_id values to IRef objects used to handle and streamable objects in this result.

Definition at line 64 of file QueryResult.old.cs.

Property Documentation

int Deveel.Data.Protocol.QueryResult.ColumnCount

get

Returns the column count.

Definition at line 98 of file QueryResult.cs.

QueryResultColumn [] Deveel.Data.Protocol.QueryResult.Fields

get

Returns the QueryResultColumn array of all the columns in the result.

Definition at line 207 of file QueryResult.old.cs.

SqlQuery Deveel.Data.Protocol.QueryResult.Query

getprivate set

Definition at line 90 of file QueryResult.cs.

ITable Deveel.Data.Protocol.QueryResult.Result

getprivate set

Definition at line 92 of file QueryResult.cs.

int Deveel.Data.Protocol.QueryResult.RowCount

get

Returns the row count.

Definition at line 94 of file QueryResult.cs.

The documentation for this class was generated from the following files:

/var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Protocol/QueryResult.cs
/var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Protocol/QueryResult.old.cs

Public Member Functions

Package Functions

Properties

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

Property Documentation