Deveel.Data.Client.ConnectionClient Class Reference

Inheritance diagram for Deveel.Data.Client.ConnectionClient:

Public Member Functions
	ConnectionClient (DeveelDbConnectionStringBuilder settings)
	ConnectionClient (IClientConnector connector, DeveelDbConnectionStringBuilder settings)
void	Connect ()
void	Disconnect ()
bool	Authenticate ()
IQueryResponse[]	ExecuteQuery (int commitId, SqlQuery query)
QueryResultPart	GetResultPart (int resultId, int rowIndex, int count)
void	DisposeResult (int resultId)
int	BeginTransaction (System.Data.IsolationLevel isolationLevel)
int	BeginTransaction (IsolationLevel isolationLevel)
void	CommitTransaction (int transactionId)
void	RollbackTransaction (int transactionId)
void	DisposeLargeObject (long objId)
void	Dispose ()

Properties
DeveelDbConnectionStringBuilder	Settings [get, private set]
IClientConnector	Connector [get, private set]
bool	OwnsConnector [get, set]
IMessageProcessor	Processor [get, private set]
bool	IsClosed [get, private set]
string	ServerVersion [get, private set]

Private Member Functions
	~ConnectionClient ()
IClientConnector	CreateNetworkConnector ()
IClientConnector	CreateConnector ()
IMessage	SendMessage (IMessage message)
ConnectionEndPoint	MakeRemoteEndPoint ()
IsolationLevel	MapIsolationLevel (System.Data.IsolationLevel isolationLevel)
void	Dispose (bool disposing)

Private Attributes
ConnectionEndPoint	remoteEndPoint
IDictionary< string, object >	serverMetadata

Detailed Description

Definition at line 30 of file ConnectionClient.cs.

Constructor & Destructor Documentation

Deveel.Data.Client.ConnectionClient.ConnectionClient ( DeveelDbConnectionStringBuilder  settings )

inline

Definition at line 43 of file ConnectionClient.cs.

                                                                          {
            Settings = settings;
        }

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

inline

Definition at line 47 of file ConnectionClient.cs.

                                                                                                      {
            if (connector == null)
                throw new ArgumentNullException("connector");

            Settings = settings;
            Connector = connector;
            Processor = connector.CreateProcessor();
            OwnsConnector = false;
        }

Deveel.Data.Client.ConnectionClient.~ConnectionClient ( )

inlineprivate

Definition at line 57 of file ConnectionClient.cs.

                            {
            Dispose(false);
        }

Member Function Documentation

bool Deveel.Data.Client.ConnectionClient.Authenticate ( )

inline

Definition at line 202 of file ConnectionClient.cs.

                                   {
            var response = SendMessage(new AuthenticateRequest(Settings.Schema, Settings.UserName, Settings.Password))
                as AuthenticateResponse;

            if (response == null)
                throw new InvalidOperationException();

            return response.Authenticated;
        }

int Deveel.Data.Client.ConnectionClient.BeginTransaction ( System.Data.IsolationLevel  isolationLevel )

inline

Definition at line 243 of file ConnectionClient.cs.

                                                                               {
            var isolation = MapIsolationLevel(isolationLevel);
            return BeginTransaction(isolation);
        }

int Deveel.Data.Client.ConnectionClient.BeginTransaction ( IsolationLevel  isolationLevel )

inline

Definition at line 261 of file ConnectionClient.cs.

                                                                   {
            var response = SendMessage(new BeginRequest(isolationLevel))
                as BeginResponse;

            if (response == null)
                throw new InvalidOperationException();

            return response.CommitId;
        }

void Deveel.Data.Client.ConnectionClient.CommitTransaction ( int  transactionId )

inline

Definition at line 271 of file ConnectionClient.cs.

                                                         {
            var response = SendMessage(new CommitRequest(transactionId))
                as AcknowledgeResponse;

            if (response == null)
                throw new InvalidOperationException();

            if (!response.State)
                throw new DeveelDbServerException("Unable to commit the transaction on the server.", -1, -1);
        }

void Deveel.Data.Client.ConnectionClient.Connect ( )

inline

Definition at line 157 of file ConnectionClient.cs.

                              {
            if (Connector == null) {
                Connector = CreateConnector();
                Processor = Connector.CreateProcessor();
            }

            remoteEndPoint = MakeRemoteEndPoint();

            var request = new ConnectRequest(Connector.LocalEndPoint, remoteEndPoint) {
                DatabaseName = Settings.Database,
                Timeout = Settings.QueryTimeout,
                IgnoreIdentifiersCase = Settings.IgnoreIdentifiersCase,
                ParameterStyle = Settings.ParameterStyle,
                AutoCommit = Settings.AutoCommit
            };

            var response = SendMessage(request) as ConnectResponse;
            if (response == null)
                throw new ProtocolException("The returned message is invalid");

            if (!response.Opened)
                throw new DeveelDbServerException("Was not able to open the connection on the server.", -1, -1);

            if (response.IsEncryted)
                Connector.SetEncrypton(response.EncryptionData);

            IsClosed = false;
            ServerVersion = response.Version;
        }

IClientConnector Deveel.Data.Client.ConnectionClient.CreateConnector ( )

inlineprivate

Definition at line 69 of file ConnectionClient.cs.

                                                   {
            if (Connector != null)
                return Connector;

            IConfiguration configuration = null;

            /*
            TODO:
            if (IsInMemory(Settings.DataSource) && controlDatabase == null) {
                if (controlSystem == null)
                    controlSystem = CreateEmbeddedControlSystem();

                // TODO: handle the case the connection string does not specify a database name
                var databaseName = Settings.Database;
                if (String.IsNullOrEmpty(databaseName))
                    throw new InvalidOperationException();

                Configuration = new Configuration(controlSystem.Config);
                Configuration.DatabaseName(databaseName);

                var defaultSchema = Settings.Schema;
                if (!String.IsNullOrEmpty(defaultSchema))
                    Configuration.DefaultSchema(defaultSchema);

                controlDatabase = controlSystem.ControlDatabase(databaseName);
            } else if (IsInFileSystem(Settings) && controlDatabase == null) {
                if (controlSystem == null)
                    controlSystem = CreateEmbeddedControlSystem();

                // TODO: handle the case the connection string does not specify a database name
                var databaseName = Settings.Database;
                if (String.IsNullOrEmpty(databaseName))
                    throw new InvalidOperationException();

                Configuration = new Configuration(controlSystem.Config);
                Configuration.StorageSystem(ConfigDefaultValues.FileStorageSystem);

                var dbPath = settings.DataSource;
                if (String.Equals(dbPath, "local", StringComparison.OrdinalIgnoreCase))
                    dbPath = settings.Path;
                if (String.IsNullOrEmpty(dbPath))
                    dbPath = databaseName;

                Configuration.DatabasePath(dbPath);

                var defaultSchema = settings.Schema;
                if (!String.IsNullOrEmpty(defaultSchema))
                    Configuration.DefaultSchema(defaultSchema);


                controlDatabase = controlSystem.ControlDatabase(databaseName);
            } else if (controlDatabase == null) {
                return CreateNetworkConnector();
            }

            if (controlDatabase != null)
                return CreateLocalDatabaseConnector(Configuration);

            throw new InvalidOperationException("Unable to create a connector to the database");
            */

            throw new NotImplementedException();
        }

IClientConnector Deveel.Data.Client.ConnectionClient.CreateNetworkConnector ( )

inlineprivate

Definition at line 65 of file ConnectionClient.cs.

                                                          {
            throw new NotSupportedException();
        }

void Deveel.Data.Client.ConnectionClient.Disconnect ( )

inline

Definition at line 187 of file ConnectionClient.cs.

                                 {
            try {
                var response = SendMessage(new CloseRequest())
                    as AcknowledgeResponse;

                if (response == null)
                    throw new InvalidOperationException();

                if (!response.State)
                    throw new DeveelDbServerException("Unable to close the connection on the server.", -1, -1);
            } finally {
                IsClosed = true;
            }
        }

void Deveel.Data.Client.ConnectionClient.Dispose ( )

inline

Definition at line 305 of file ConnectionClient.cs.

                              {
            Dispose(true);
            GC.SuppressFinalize(this);
        }

void Deveel.Data.Client.ConnectionClient.Dispose ( bool  disposing )

inlineprivate

Definition at line 310 of file ConnectionClient.cs.

                                             {
            if (disposing) {
                if (OwnsConnector && Connector != null) {
                    Connector.Dispose();
                }
            }

            Connector = null;
        }

void Deveel.Data.Client.ConnectionClient.DisposeLargeObject ( long  objId )

inline

Definition at line 294 of file ConnectionClient.cs.

                                                   {
            var response = SendMessage(new LargeObjectDisposeRequest(objId))
                as AcknowledgeResponse;

            if (response == null)
                throw new InvalidOperationException();

            if (!response.State)
                throw new InvalidOperationException("Unable to dispose the large object on the server.");
        }

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

inline

Definition at line 232 of file ConnectionClient.cs.

                                                {
            var response = SendMessage(new DisposeResultRequest(resultId))
                as AcknowledgeResponse;

            if (response == null)
                throw new InvalidOperationException();

            if (!response.State)
                throw new DeveelDbServerException(null, -1, -1);
        }

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

inline

Definition at line 212 of file ConnectionClient.cs.

                                                                           {
            var response = SendMessage(new QueryExecuteRequest(commitId, query))
                as QueryExecuteResponse;

            if (response == null)
                throw new InvalidOperationException();

            return response.QueryResponse;
        }

QueryResultPart Deveel.Data.Client.ConnectionClient.GetResultPart ( int  resultId, int  rowIndex, int  count  )

inline

Definition at line 222 of file ConnectionClient.cs.

                                                                                    {
            var response = SendMessage(new QueryResultPartRequest(resultId, rowIndex, count))
                as QueryResultPartResponse;

            if (response == null)
                throw new InvalidOperationException();

            return response.Part;
        }

ConnectionEndPoint Deveel.Data.Client.ConnectionClient.MakeRemoteEndPoint ( )

inlineprivate

Definition at line 146 of file ConnectionClient.cs.

                                                        {
            var properties = new Dictionary<string, object>();
            var en = ((IDictionary)Settings).GetEnumerator();
            while (en.MoveNext()) {
                var current = en.Entry;
                properties.Add((string)current.Key, current.Value);
            }

            return Connector.MakeEndPoint(properties);
        }

IsolationLevel Deveel.Data.Client.ConnectionClient.MapIsolationLevel ( System.Data.IsolationLevel  isolationLevel )

inlineprivate

Definition at line 248 of file ConnectionClient.cs.

                                                                                            {
            if (isolationLevel == System.Data.IsolationLevel.Serializable)
                return IsolationLevel.Serializable;
            if (isolationLevel == System.Data.IsolationLevel.Snapshot)
                return IsolationLevel.Snapshot;
            if (isolationLevel == System.Data.IsolationLevel.ReadCommitted)
                return IsolationLevel.ReadCommitted;
            if (isolationLevel == System.Data.IsolationLevel.ReadUncommitted)
                return IsolationLevel.ReadUncommitted;

            throw new NotSupportedException(String.Format("Isolation Level '{0}' not supported by DeveelDB", isolationLevel));
        }

void Deveel.Data.Client.ConnectionClient.RollbackTransaction ( int  transactionId )

inline

Definition at line 282 of file ConnectionClient.cs.

                                                           {
            var response = SendMessage(new RollbackRequest(transactionId))
                as AcknowledgeResponse;

            if (response == null)
                throw new InvalidOperationException();

            if (!response.State)
                throw new DeveelDbServerException("Unable to rollback the transaction on the server.", -1, -1);

        }

IMessage Deveel.Data.Client.ConnectionClient.SendMessage ( IMessage  message )

inlineprivate

Definition at line 133 of file ConnectionClient.cs.

                                                       {
            var envelope = Connector.CreateEnvelope(serverMetadata, message);
            var response = Processor.ProcessMessage(envelope);
            if (response == null)
                throw new InvalidOperationException("The processor returned no response.");

            if (response.Error != null)
                throw new DeveelDbServerException(response.Error.ErrorMessage, response.Error.ErrorClass, response.Error.ErrorCode);

            serverMetadata = response.Metadata;
            return response.Message;
        }

Member Data Documentation

ConnectionEndPoint Deveel.Data.Client.ConnectionClient.remoteEndPoint

private

Definition at line 33 of file ConnectionClient.cs.

IDictionary<string, object> Deveel.Data.Client.ConnectionClient.serverMetadata

private

Definition at line 41 of file ConnectionClient.cs.

Property Documentation

IClientConnector Deveel.Data.Client.ConnectionClient.Connector

getprivate set

Definition at line 35 of file ConnectionClient.cs.

bool Deveel.Data.Client.ConnectionClient.IsClosed

getprivate set

Definition at line 61 of file ConnectionClient.cs.

bool Deveel.Data.Client.ConnectionClient.OwnsConnector

getsetprivate

Definition at line 37 of file ConnectionClient.cs.

IMessageProcessor Deveel.Data.Client.ConnectionClient.Processor

getprivate set

Definition at line 39 of file ConnectionClient.cs.

string Deveel.Data.Client.ConnectionClient.ServerVersion

getprivate set

Definition at line 63 of file ConnectionClient.cs.

DeveelDbConnectionStringBuilder Deveel.Data.Client.ConnectionClient.Settings

getprivate set

Definition at line 31 of file ConnectionClient.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/ConnectionClient.cs