Inheritance diagram for Deveel.Data.Client.DeveelDbConnection:

Public Member Functions
new DeveelDbTransaction	BeginTransaction (IsolationLevel isolationLevel)

override void	Close ()

override void	ChangeDatabase (string databaseName)

override void	Open ()

new DeveelDbCommand	CreateCommand ()

Protected Member Functions
override DbTransaction	BeginDbTransaction (IsolationLevel isolationLevel)

override DbCommand	CreateDbCommand ()

override void	Dispose (bool disposing)

Package Functions
	DeveelDbConnection (IClientConnector connector, DeveelDbConnectionStringBuilder settings)

void	ChangeState (ConnectionState newState)

void	EndState ()

void	CommitTransaction (int commitId)

void	RollbackTransaction (int commitId)

IQueryResponse[]	ExecuteQuery (int commitId, SqlQuery query)

QueryResultPart	RequestResultPart (int resultId, int rowIndex, int rowCount)

void	DisposeResult (int resultId)

Properties
ConnectionClient	Client `[get, set]`

LocalRowCache	RowCache `[get, private set]`

override string	ConnectionString `[get, set]`

DeveelDbConnectionStringBuilder	Settings `[get, set]`

override string	Database `[get]`

override ConnectionState	State `[get]`

override string	DataSource `[get]`

override string	ServerVersion `[get]`

override int	ConnectionTimeout `[get]`

DeveelDbTransaction	Transaction `[get, set]`

Private Member Functions
void	AssertClosed ()

void	AssertFetching ()

int	BeginServerTransaction (IsolationLevel isolationLevel)

Private Attributes
DeveelDbConnectionStringBuilder	connectionString

ConnectionState	state

ConnectionState	oldState

readonly object	stateLock = new object()

string	serverVersion

string	dataSource

Dictionary< string, DeveelDbDataReader >	openReaders

Detailed Description

Definition at line 28 of file DeveelDbConnection.cs.

Constructor & Destructor Documentation

Deveel.Data.Client.DeveelDbConnection.DeveelDbConnection	(	IClientConnector	connector,
		DeveelDbConnectionStringBuilder	settings
	)

inlinepackage

Definition at line 40 of file DeveelDbConnection.cs.

                                                                                                           {
             Client = new ConnectionClient(connector,settings);
             connectionString = settings;
             RowCache = new LocalRowCache(this);
         }

Member Function Documentation

void Deveel.Data.Client.DeveelDbConnection.AssertClosed ( )

inlineprivate

Definition at line 187 of file DeveelDbConnection.cs.

                                     {
             if (state != ConnectionState.Closed)
                 throw new InvalidOperationException("The connection is not closed.");
         }

void Deveel.Data.Client.DeveelDbConnection.AssertFetching ( )

inlineprivate

Definition at line 192 of file DeveelDbConnection.cs.

                                       {
             if (state != ConnectionState.Fetching)
                 throw new InvalidOperationException("The connection is not fetching data.");
         }

override DbTransaction Deveel.Data.Client.DeveelDbConnection.BeginDbTransaction ( IsolationLevel isolationLevel )

inlineprotected

Definition at line 64 of file DeveelDbConnection.cs.

                                                                                            {
             return BeginTransaction(isolationLevel);
         }

int Deveel.Data.Client.DeveelDbConnection.BeginServerTransaction ( IsolationLevel isolationLevel )

inlineprivate

Definition at line 211 of file DeveelDbConnection.cs.

                                                                           {
             lock (this) {
                 try {
                     return Client.BeginTransaction(isolationLevel);
                 } catch (Exception ex) {
                     throw new DeveelDbException("Could not begin a transaction.", ex);
                 }
             }
         }

new DeveelDbTransaction Deveel.Data.Client.DeveelDbConnection.BeginTransaction ( IsolationLevel isolationLevel )

inline

Definition at line 50 of file DeveelDbConnection.cs.

                                                                                        {
             if (Transaction != null)
                 throw new DeveelDbException("A transaction is already open on this connection.");
 
             if (isolationLevel == IsolationLevel.Unspecified)
                 isolationLevel = IsolationLevel.Serializable;
 
             if (isolationLevel != IsolationLevel.Serializable)
                 throw new NotSupportedException(String.Format("Isolation Level '{0}' is not supported yet.", isolationLevel));
 
             var commitId = BeginServerTransaction(isolationLevel);
             return new DeveelDbTransaction(this, isolationLevel, commitId);
         }

override void Deveel.Data.Client.DeveelDbConnection.ChangeDatabase ( string databaseName )

inline

Definition at line 98 of file DeveelDbConnection.cs.

                                                                  {
             throw new NotImplementedException();
         }

void Deveel.Data.Client.DeveelDbConnection.ChangeState ( ConnectionState newState )

inlinepackage

Definition at line 197 of file DeveelDbConnection.cs.

                                                             {
             lock (stateLock) {
                 if (state != newState)
                     OnStateChange(new StateChangeEventArgs(state, newState));
 
                 oldState = state;
                 state = newState;
             }
         }

override void Deveel.Data.Client.DeveelDbConnection.Close ( )

inline

Definition at line 68 of file DeveelDbConnection.cs.

                                      {
             lock (this) {
                 try {
                     if (State == ConnectionState.Closed)
                         return;
 
                     if (openReaders != null) {
                         foreach (var reader in openReaders.Values) {
                             reader.Close();
                         }
 
                         openReaders.Clear();
                         openReaders = null;
                     }
 
 
                     if (Transaction != null) {
                         Transaction.Rollback();
                         Transaction = null;
                     }
 
                     Client.Disconnect();
                 } catch (Exception ex) {
                     throw new DeveelDbException("An error occurred while closing the connection.", ex);
                 } finally {
                     ChangeState(ConnectionState.Closed);
                 }
             }
         }

void Deveel.Data.Client.DeveelDbConnection.CommitTransaction ( int commitId )

inlinepackage

Definition at line 221 of file DeveelDbConnection.cs.

                                                       {
             lock (this) {
                 try {
                     Client.CommitTransaction(commitId);
                 } catch (Exception ex) {
                     throw new DeveelDbException(String.Format("Could not COMMIT transaction '{0}' on the server.", commitId), ex);
                 }   
             }
         }

new DeveelDbCommand Deveel.Data.Client.DeveelDbConnection.CreateCommand ( )

inline

Definition at line 183 of file DeveelDbConnection.cs.

                                                    {
             return new DeveelDbCommand(this);
         }

override DbCommand Deveel.Data.Client.DeveelDbConnection.CreateDbCommand ( )

inlineprotected

Definition at line 179 of file DeveelDbConnection.cs.

                                                        {
             return CreateCommand();
         }

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

inlineprotected

Definition at line 265 of file DeveelDbConnection.cs.

                                                         {
             if (disposing) {
                 Close();
 
                 if (Client != null)
                     Client.Dispose();
             }
 
             Client = null;
 
             base.Dispose(disposing);
         }

void Deveel.Data.Client.DeveelDbConnection.DisposeResult ( int resultId )

inlinepackage

Definition at line 257 of file DeveelDbConnection.cs.

                                                   {
             try {
                 Client.DisposeResult(resultId);
             } catch (Exception ex) {
                 throw new DeveelDbException(String.Format("The remote result '{0}' could not be disposed.", resultId), ex);
             }
         }

void Deveel.Data.Client.DeveelDbConnection.EndState ( )

inlinepackage

Definition at line 207 of file DeveelDbConnection.cs.

                                  {
             ChangeState(oldState);
         }

IQueryResponse [] Deveel.Data.Client.DeveelDbConnection.ExecuteQuery	(	int	commitId,
		SqlQuery	query
	)

inlinepackage

Definition at line 241 of file DeveelDbConnection.cs.

                                                                              {
             try {
                 return Client.ExecuteQuery(commitId, query);
             } catch (Exception ex) {
                 throw new DeveelDbException("An error occurred while executing a query.", ex);
             }
         }

override void Deveel.Data.Client.DeveelDbConnection.Open ( )

inline

Definition at line 102 of file DeveelDbConnection.cs.

                                     {
             lock (this) {
                 if (State == ConnectionState.Open)
                     return;
 
                 if (State != ConnectionState.Closed)
                     return;
 
                 try {
                     ChangeState(ConnectionState.Connecting);
 
                     Client.Connect();
                     Client.Authenticate();
 
                     serverVersion = Client.ServerVersion;
                 } catch (Exception) {
                     ChangeState(ConnectionState.Broken);
 
                     // TODO: throw a specialized exception
                     throw;
                 }
 
                 ChangeState(ConnectionState.Open);
             }
         }

QueryResultPart Deveel.Data.Client.DeveelDbConnection.RequestResultPart	(	int	resultId,
		int	rowIndex,
		int	rowCount
	)

inlinepackage

Definition at line 249 of file DeveelDbConnection.cs.

                                                                                              {
             try {
                 return Client.GetResultPart(resultId, rowIndex, rowCount);
             } catch (Exception ex) {
                 throw new DeveelDbException(String.Format("Could not retrieve part of the result '{0}' from the server.", resultId), ex);
             }
         }

void Deveel.Data.Client.DeveelDbConnection.RollbackTransaction ( int commitId )

inlinepackage

Definition at line 231 of file DeveelDbConnection.cs.

                                                         {
             lock (this) {
                 try {
                     Client.RollbackTransaction(commitId);
                 } catch (Exception ex) {
                     throw new DeveelDbException(String.Format("Could not ROLLBACK transaction '{0}' on the server.", commitId), ex);
                 }               
             }
         }

Member Data Documentation

DeveelDbConnectionStringBuilder Deveel.Data.Client.DeveelDbConnection.connectionString

private

Definition at line 29 of file DeveelDbConnection.cs.

string Deveel.Data.Client.DeveelDbConnection.dataSource

private

Definition at line 36 of file DeveelDbConnection.cs.

ConnectionState Deveel.Data.Client.DeveelDbConnection.oldState

private

Definition at line 32 of file DeveelDbConnection.cs.

Dictionary<string, DeveelDbDataReader> Deveel.Data.Client.DeveelDbConnection.openReaders

private

Definition at line 38 of file DeveelDbConnection.cs.

string Deveel.Data.Client.DeveelDbConnection.serverVersion

private

Definition at line 35 of file DeveelDbConnection.cs.

ConnectionState Deveel.Data.Client.DeveelDbConnection.state

private

Definition at line 31 of file DeveelDbConnection.cs.

readonly object Deveel.Data.Client.DeveelDbConnection.stateLock = new object()

private

Definition at line 33 of file DeveelDbConnection.cs.

Property Documentation

ConnectionClient Deveel.Data.Client.DeveelDbConnection.Client

getsetprivate

Definition at line 46 of file DeveelDbConnection.cs.

override string Deveel.Data.Client.DeveelDbConnection.ConnectionString

getset

Definition at line 128 of file DeveelDbConnection.cs.

override int Deveel.Data.Client.DeveelDbConnection.ConnectionTimeout

get

Definition at line 173 of file DeveelDbConnection.cs.

override string Deveel.Data.Client.DeveelDbConnection.Database

get

Definition at line 142 of file DeveelDbConnection.cs.

override string Deveel.Data.Client.DeveelDbConnection.DataSource

get

Definition at line 154 of file DeveelDbConnection.cs.

LocalRowCache Deveel.Data.Client.DeveelDbConnection.RowCache

getprivate setpackage

Definition at line 48 of file DeveelDbConnection.cs.

override string Deveel.Data.Client.DeveelDbConnection.ServerVersion

get

Definition at line 169 of file DeveelDbConnection.cs.

DeveelDbConnectionStringBuilder Deveel.Data.Client.DeveelDbConnection.Settings

getsetpackage

Definition at line 133 of file DeveelDbConnection.cs.

override ConnectionState Deveel.Data.Client.DeveelDbConnection.State

get

Definition at line 146 of file DeveelDbConnection.cs.

DeveelDbTransaction Deveel.Data.Client.DeveelDbConnection.Transaction

getsetpackage

Definition at line 177 of file DeveelDbConnection.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/DeveelDbConnection.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