Inheritance diagram for Deveel.Data.Client.DeveelDbCommand:

Public Member Functions
	DeveelDbCommand ()

	DeveelDbCommand (DeveelDbConnection connection)

	DeveelDbCommand (string commandText)

	DeveelDbCommand (DeveelDbConnection connection, string commandText)

override void	Prepare ()

override void	Cancel ()

new DeveelDbParameter	CreateParameter ()

new DeveelDbDataReader	ExecuteReader (CommandBehavior behavior)

new DeveelDbDataReader	ExecuteReader ()

override int	ExecuteNonQuery ()

override object	ExecuteScalar ()

Protected Member Functions
override DbParameter	CreateDbParameter ()

override DbDataReader	ExecuteDbDataReader (CommandBehavior behavior)

override void	Dispose (bool disposing)

Package Functions
bool	NextResult ()

Properties
LocalQueryResult	CurrentResult `[get]`

override string	CommandText `[get, set]`

override int	CommandTimeout `[get, set]`

override CommandType	CommandType `[get, set]`

override UpdateRowSource	UpdatedRowSource `[get, set]`

override DbConnection	DbConnection `[get, set]`

new DeveelDbConnection	Connection `[get, set]`

override DbParameterCollection	DbParameterCollection `[get]`

new DeveelDbParameterCollection	Parameters `[get]`

override DbTransaction	DbTransaction `[get, set]`

new DeveelDbTransaction	Transaction `[get, set]`

override bool	DesignTimeVisible `[get, set]`

Private Member Functions
QueryParameterDirection	GetParamDirection (SysParameterDirection direction)

QueryParameter	PrepareParameter (DeveelDbParameter parameter)

void	ExecuteQuery ()

void	CreateResults (IQueryResponse[] response)

SqlQuery	CreateQuery ()

void	PrepareCommand ()

void	AssertConnectionOpen ()

Private Attributes
int	timeout

DeveelDbConnection	connection

DeveelDbTransaction	transaction

bool	prepared

List< QueryParameter >	preparedParameters

DeveelDbParameterCollection	parameters

int	resultIndex

LocalQueryResult[]	results

Detailed Description

Definition at line 31 of file DeveelDbCommand.cs.

Constructor & Destructor Documentation

Deveel.Data.Client.DeveelDbCommand.DeveelDbCommand ( )

inline

Definition at line 44 of file DeveelDbCommand.cs.

45 : this((DeveelDbConnection)null) {

46 }

Deveel.Data.Client.DeveelDbCommand.DeveelDbCommand ( DeveelDbConnection connection )

inline

Definition at line 48 of file DeveelDbCommand.cs.

49 : this(connection, null) {

50 }

Deveel.Data.Client.DeveelDbCommand.connection

DeveelDbConnection connection

Definition: DeveelDbCommand.cs:33

Deveel.Data.Client.DeveelDbCommand.DeveelDbCommand ( string commandText )

inline

Definition at line 52 of file DeveelDbCommand.cs.

53 : this(null, commandText) {

54 }

Deveel.Data.Client.DeveelDbCommand.DeveelDbCommand	(	DeveelDbConnection	connection,
		string	commandText
	)

inline

Definition at line 56 of file DeveelDbCommand.cs.

                                                                                   {
             Connection = connection;
             CommandText = commandText;
 
             parameters = new DeveelDbParameterCollection(this);
         }

Member Function Documentation

void Deveel.Data.Client.DeveelDbCommand.AssertConnectionOpen ( )

inlineprivate

Definition at line 294 of file DeveelDbCommand.cs.

                                             {
             if (Connection == null)
                 throw new DeveelDbException("The command is not associated to any connection.");
 
             if (Connection.State == ConnectionState.Closed) {
                 try {
                     Connection.Open();
                 } catch (DeveelDbException) {
                     throw;
                 } catch (Exception ex) {
                     throw new DeveelDbException("Failed to open the underlying connection", ex);
                 }
             }
         }

override void Deveel.Data.Client.DeveelDbCommand.Cancel ( )

inline

Definition at line 260 of file DeveelDbCommand.cs.

                                       {
             try {
                 if (results != null) {
                     foreach (var result in results) {
                         connection.DisposeResult(result.ResultId);
                     }
                 }
             } finally {
                 connection.EndState();
             }
         }

override DbParameter Deveel.Data.Client.DeveelDbCommand.CreateDbParameter ( )

inlineprotected

Definition at line 286 of file DeveelDbCommand.cs.

                                                            {
             return CreateParameter();
         }

new DeveelDbParameter Deveel.Data.Client.DeveelDbCommand.CreateParameter ( )

inline

Definition at line 290 of file DeveelDbCommand.cs.

                                                        {
             return new DeveelDbParameter();
         }

SqlQuery Deveel.Data.Client.DeveelDbCommand.CreateQuery ( )

inlineprivate

Definition at line 139 of file DeveelDbCommand.cs.

                                        {
             QueryParameter[] queryParameters;
             if (prepared && preparedParameters != null) {
                 queryParameters = preparedParameters.ToArray();
             } else {
                 queryParameters = new QueryParameter[parameters.Count];
                 for (int i = 0; i < parameters.Count; i++) {
                     var parameter = parameters[i];
                     var queryParam = PrepareParameter(parameter);
                     queryParameters[i] = queryParam;
                 }
             }
 
             var query = new SqlQuery(CommandText);
 
             // now verify all parameter names are consistent
             foreach (var parameter in queryParameters) {
                 if (connection.Settings.ParameterStyle == QueryParameterStyle.Marker) {
                     if (!String.IsNullOrEmpty(parameter.Name) &&
                         parameter.Name != QueryParameter.Marker)
                         throw new InvalidOperationException();
                 } else if (connection.Settings.ParameterStyle == QueryParameterStyle.Named) {
                     if (String.IsNullOrEmpty(parameter.Name))
                         throw new InvalidOperationException("Named parameters must have a name defined.");
 
                     if (parameter.Name == QueryParameter.Marker)
                         throw new InvalidOperationException();
                     if (parameter.Name.Length <= 1)
                         throw new InvalidOperationException();
                     if (!Char.IsLetter(parameter.Name[0]) &&
                         parameter.Name[0] != QueryParameter.NamePrefix)
                         throw new InvalidOperationException();
                 }
 
                 query.Parameters.Add(parameter);
             }
 
             return query;
         }

void Deveel.Data.Client.DeveelDbCommand.CreateResults ( IQueryResponse[] response )

inlineprivate

Definition at line 105 of file DeveelDbCommand.cs.

                                                               {
             results = new LocalQueryResult[response.Length];
 
             for (int i = 0; i < response.Length; i++) {
                 var r = response[i];
                 var columns = new QueryResultColumn[r.ColumnCount];
                 for (int j = 0; j < columns.Length; j++) {
                     columns[j] = r.GetColumn(j);
                 }
 
                 var result = new LocalQueryResult(connection);
                 result.QueryTime = r.QueryTimeMillis;
 
                 result.Setup(r.ResultId, columns, r.RowCount);
                 result.SetFetchSize(connection.Settings.FetchSize);
                 result.SetMaxRowCount(connection.Settings.MaxFetchSize);
 
                 // Does the result set contain large objects?  We can't cache a
                 // result that contains binary data.
 
                 bool hasLargeObject = result.HasLargeObject;
 
                 // If the result row count < 40 then download and store locally in the
                 // result set and dispose the resources on the server.
                 if (!hasLargeObject && result.RowCount < 40) {
                     result.DownloadAndClose();
                 } else {
                     result.Download(0, System.Math.Min(10, result.RowCount));
                 }
 
                 results[i] = result;
             }
         }

override void Deveel.Data.Client.DeveelDbCommand.Dispose ( bool disposing )

inlineprotected

Definition at line 384 of file DeveelDbCommand.cs.

                                                         {
             if (disposing) {
                 if (results != null) {
                     foreach (var result in results) {
                         result.Dispose();
                     }
                 }
 
                 if (parameters != null) {
                     foreach (IDbDataParameter parameter in parameters) {
                         if (parameter.Value is IDisposable) {
                             try {
                                 ((IDisposable)parameter.Value).Dispose();
                             } catch (Exception) {                               
                             }
                         }
                     }
 
                     parameters.Clear();
                 }
 
                 if (preparedParameters != null) {
                     foreach (var parameter in preparedParameters) {
                         if (parameter.Value is IDisposable) {
                             try {
                                 ((IDisposable)parameter.Value).Dispose();
                             } catch (Exception) {
                             }
                         }
                     }
                 }
             }
 
             preparedParameters = null;
             parameters = null;
             results = null;
 
             base.Dispose(disposing);
         }

override DbDataReader Deveel.Data.Client.DeveelDbCommand.ExecuteDbDataReader ( CommandBehavior behavior )

inlineprotected

Definition at line 309 of file DeveelDbCommand.cs.

                                                                                       {
             return ExecuteReader(behavior);
         }

override int Deveel.Data.Client.DeveelDbCommand.ExecuteNonQuery ( )

inline

Definition at line 335 of file DeveelDbCommand.cs.

                                               {
             try {
                 AssertConnectionOpen();
 
                 connection.ChangeState(ConnectionState.Executing);
 
                 ExecuteQuery();
 
                 if (results == null || results.Length == 0)
                     return -1;
 
                 var result = results[0];
                 if (!result.IsUpdate)
                     return -1;
 
                 return result.AffectedRows;
             } catch (Exception ex) {
                 throw new DeveelDbException("An error occurred while executing the non-query command.", ex);
             } finally {
                 connection.EndState();
             }
         }

void Deveel.Data.Client.DeveelDbCommand.ExecuteQuery ( )

inlineprivate

Definition at line 97 of file DeveelDbCommand.cs.

                                     {
             var query = CreateQuery();
 
             int commitId = Transaction != null ? Transaction.CommitId : -1;
             var response = connection.ExecuteQuery(commitId, query);
             CreateResults(response);
         }

new DeveelDbDataReader Deveel.Data.Client.DeveelDbCommand.ExecuteReader ( CommandBehavior behavior )

inline

Definition at line 313 of file DeveelDbCommand.cs.

                                                                               {
             try {
                 AssertConnectionOpen();
 
                 if (connection.State == ConnectionState.Fetching)
                     throw new InvalidOperationException("Another reader is already open for the connection.");
 
                 if (connection.State != ConnectionState.Open)
                     throw new InvalidOperationException("The connection is not open.");
 
                 ExecuteQuery();
 
                 return new DeveelDbDataReader(this, behavior);
             } catch (Exception ex) {
                 throw new DeveelDbException("An error occurred when executing the reader.", ex);
             }
         }

new DeveelDbDataReader Deveel.Data.Client.DeveelDbCommand.ExecuteReader ( )

inline

Definition at line 331 of file DeveelDbCommand.cs.

                                                       {
             return ExecuteReader(CommandBehavior.Default);
         }

override object Deveel.Data.Client.DeveelDbCommand.ExecuteScalar ( )

inline

Definition at line 358 of file DeveelDbCommand.cs.

                                                {
             try {
                 AssertConnectionOpen();
 
                 connection.ChangeState(ConnectionState.Executing);
 
                 ExecuteQuery();
 
                 if (results == null || results.Length == 0)
                     return null;
 
                 var result = results[0];
                 if (!result.First())
                     return null;
 
                 if (result.RowCount == 0)
                     return null;
 
                 return result.GetRuntimeValue(0);
             } catch (Exception ex) {
                 throw new DeveelDbException("Error when selecting a scalar value.", ex);
             } finally {
                 connection.EndState();
             }
         }

QueryParameterDirection Deveel.Data.Client.DeveelDbCommand.GetParamDirection ( SysParameterDirection direction )

inlineprivate

Definition at line 63 of file DeveelDbCommand.cs.

                                                                                            {
             if (direction == SysParameterDirection.Input)
                 return QueryParameterDirection.In;
             if (direction == SysParameterDirection.Output)
                 return QueryParameterDirection.Out;
             if (direction == SysParameterDirection.InputOutput)
                 return QueryParameterDirection.InOut;
 
             throw new NotSupportedException();
         }

bool Deveel.Data.Client.DeveelDbCommand.NextResult ( )

inlinepackage

Definition at line 272 of file DeveelDbCommand.cs.

                                    {
             // If we are at the end then return false
             if (results == null ||
                 resultIndex + 1 >= results.Length) {
                 return false;
             }
 
             // Move to the next result set.
             ++resultIndex;
 
             // We successfully moved to the next result
             return true;
         }

override void Deveel.Data.Client.DeveelDbCommand.Prepare ( )

inline

Definition at line 179 of file DeveelDbCommand.cs.

                                        {
             if (!prepared) {
                 try {
                     PrepareCommand();
                 } finally {
                     prepared = true;
                 }
             }
         }

void Deveel.Data.Client.DeveelDbCommand.PrepareCommand ( )

inlineprivate

Definition at line 189 of file DeveelDbCommand.cs.

                                       {
             
         }

QueryParameter Deveel.Data.Client.DeveelDbCommand.PrepareParameter ( DeveelDbParameter parameter )

inlineprivate

Definition at line 74 of file DeveelDbCommand.cs.

                                                                              {
             // TODO: If we have a Value that is a Stream object, upload it and get 
             //       back the object ID to replace the value
 
             var name = parameter.ParameterName;
             if (String.IsNullOrEmpty(name))
                 name = QueryParameter.Marker;
 
             var meta = new [] {
                 new DataTypeMeta("MaxSize", parameter.Size.ToString()),
                 new DataTypeMeta("Precision", parameter.Precision.ToString()), 
                 new DataTypeMeta("Scale", parameter.Scale.ToString()),
                 new DataTypeMeta("Locale", parameter.Locale) 
             };
 
             var dataType = SqlType.Resolve(parameter.SqlType, meta);
             var value = dataType.CreateFrom(parameter.Value);
 
             var queryParameter = new QueryParameter(name, dataType, value);
             queryParameter.Direction = GetParamDirection(parameter.Direction);
             return queryParameter;
         }

Member Data Documentation

DeveelDbConnection Deveel.Data.Client.DeveelDbCommand.connection

private

Definition at line 33 of file DeveelDbCommand.cs.

DeveelDbParameterCollection Deveel.Data.Client.DeveelDbCommand.parameters

private

Definition at line 39 of file DeveelDbCommand.cs.

bool Deveel.Data.Client.DeveelDbCommand.prepared

private

Definition at line 36 of file DeveelDbCommand.cs.

List<QueryParameter> Deveel.Data.Client.DeveelDbCommand.preparedParameters

private

Definition at line 37 of file DeveelDbCommand.cs.

int Deveel.Data.Client.DeveelDbCommand.resultIndex

private

Definition at line 41 of file DeveelDbCommand.cs.

LocalQueryResult [] Deveel.Data.Client.DeveelDbCommand.results

private

Definition at line 42 of file DeveelDbCommand.cs.

int Deveel.Data.Client.DeveelDbCommand.timeout

private

Definition at line 32 of file DeveelDbCommand.cs.

DeveelDbTransaction Deveel.Data.Client.DeveelDbCommand.transaction

private

Definition at line 34 of file DeveelDbCommand.cs.

Property Documentation

override string Deveel.Data.Client.DeveelDbCommand.CommandText

getset

Definition at line 204 of file DeveelDbCommand.cs.

override int Deveel.Data.Client.DeveelDbCommand.CommandTimeout

getset

Definition at line 206 of file DeveelDbCommand.cs.

override CommandType Deveel.Data.Client.DeveelDbCommand.CommandType

getset

Definition at line 218 of file DeveelDbCommand.cs.

new DeveelDbConnection Deveel.Data.Client.DeveelDbCommand.Connection

getset

Definition at line 227 of file DeveelDbCommand.cs.

LocalQueryResult Deveel.Data.Client.DeveelDbCommand.CurrentResult

getpackage

Definition at line 193 of file DeveelDbCommand.cs.

override DbConnection Deveel.Data.Client.DeveelDbCommand.DbConnection

getsetprotected

Definition at line 222 of file DeveelDbCommand.cs.

override DbParameterCollection Deveel.Data.Client.DeveelDbCommand.DbParameterCollection

getprotected

Definition at line 232 of file DeveelDbCommand.cs.

override DbTransaction Deveel.Data.Client.DeveelDbCommand.DbTransaction

getsetprotected

Definition at line 240 of file DeveelDbCommand.cs.

override bool Deveel.Data.Client.DeveelDbCommand.DesignTimeVisible

getset

Definition at line 258 of file DeveelDbCommand.cs.

new DeveelDbParameterCollection Deveel.Data.Client.DeveelDbCommand.Parameters

get

Definition at line 236 of file DeveelDbCommand.cs.

new DeveelDbTransaction Deveel.Data.Client.DeveelDbCommand.Transaction

getset

Definition at line 245 of file DeveelDbCommand.cs.

override UpdateRowSource Deveel.Data.Client.DeveelDbCommand.UpdatedRowSource

getset

Definition at line 220 of file DeveelDbCommand.cs.

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

/var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Client/DeveelDbCommand.cs

Public Member Functions

Protected Member Functions

Package Functions

Properties

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

Property Documentation