Inheritance diagram for Deveel.Data.Protocol.ServerConnector:

Classes
class	DirectStreamableObjectChannel

class	QueryResponse

class	ServerMessageProcessor

class	TriggerChannel

Public Member Functions
void	Dispose ()

abstract ConnectionEndPoint	MakeEndPoint (IDictionary< string, object > properties)

ILargeObjectChannel	CreateObjectChannel (long objectId)

ITriggerChannel	CreateTriggerChannel (string triggerName, string objectName, TriggerEventType eventType)

abstract ConnectionEndPoint	MakeEndPoint (IDictionary< string, object > properties)

void	Dispose ()

Protected Member Functions
	ServerConnector (IDatabaseHandler databaseHandler)

virtual void	Dispose (bool disposing)

void	SetAutoCommit (bool value)

void	SetParameterStyle (QueryParameterStyle parameterStyle)

void	SetIgnoreIdentifiersCase (bool value)

void	ChangeState (ConnectorState newState)

void	OpenConnector (ConnectionEndPoint remoteEndPoint, string databaseName)

virtual void	OnConnectorOpen ()

void	CloseConnector ()

virtual void	OnCloseConnector ()

virtual EncryptionData	GetEncryptionData ()

virtual bool	Authenticate (string defaultSchema, string username, string password)

virtual bool	OnAuthenticated (User user)

IQueryResponse[]	ExecuteQuery (long commitId, string text, IEnumerable< QueryParameter > parameters)

virtual IQueryResponse[]	ExecuteQuery (IQuery context, string text, IEnumerable< QueryParameter > parameters)

IQueryResponse[]	CoreExecuteQuery (IQuery context, string text, IEnumerable< QueryParameter > parameters)

int	BeginTransaction ()

abstract IServerMessageEnvelope	CreateEnvelope (IDictionary< string, object > metadata, IMessage message)

virtual IMessage	GetMessage (IMessageEnvelope envelope)

void	CommitTransaction (int commitId)

void	RollbackTransaction (int commitId)

QueryResultPart	GetResultPart (int resultId, int startRow, int countRows)

QueryResult	GetResult (int resultId)

	ServerConnector (IDatabaseHandler handler)

void	ChangeState (ConnectorState newState)

void	OpenConnector (ConnectionEndPoint remoteEndPoint, string databaseName)

virtual void	OnConnectorOpen ()

void	SetAutoCommit (bool state)

void	SetIgnoreIdentifiersCase (bool state)

void	SetParameterStyle (ParameterStyle style)

void	CloseConnector ()

virtual void	OnCloseConnector ()

virtual EncryptionData	GetEncryptionData ()

virtual AuthenticatedSession	OnAuthenticate (string defaultSchema, string username, string password)

virtual void	OnTriggerFired (string triggerName, string triggerSource, TriggerEventType eventType, int count)

int	BeginTransaction ()

virtual bool	Authenticate (string defaultSchema, string username, string password)

long	CreateStreamableObject (ReferenceType referenceType, long length)

IQueryResponse[]	CoreExecuteQuery (string text, IEnumerable< SqlQueryParameter > parameters)

virtual IQueryResponse[]	ExecuteQuery (string text, IEnumerable< SqlQueryParameter > parameters)

QueryResultPart	GetResultPart (int resultId, int startRow, int countRows)

void	DisposeResult (int resultId)

void	CommitTransaction (int transactionId)

void	RollbackTransaction (int transactionId)

abstract IServerMessageEnvelope	CreateEnvelope (IDictionary< string, object > metadata, IMessage message)

virtual IMessage	GetMessage (IMessageEnvelope envelope)

virtual IStreamableObjectChannel	CreateObjectChannel (long objectId)

virtual ITriggerChannel	CreateTriggerChannel (string triggerName, string objectName, TriggerEventType eventType)

virtual void	Dispose (bool disposing)

Properties
IDatabaseHandler	DatabaseHandler `[get, private set]`

IDatabase	Database `[get, private set]`

abstract ConnectionEndPoint	LocalEndPoint `[get]`

ConnectionEndPoint	RemoteEndPoint `[get, private set]`

User	User `[get, private set]`

IDictionary< string, object >	Metadata `[get, private set]`

ConnectorState	CurrentState `[get, private set]`

AuthenticatedSession	Session `[get, protected set]`

ILogger	Logger `[get]`

Properties inherited from Deveel.Data.Protocol.IConnector
ConnectorState	CurrentState `[get]`

ConnectionEndPoint	LocalEndPoint `[get]`

Private Member Functions
	~ServerConnector ()

void	AssertNotDisposed ()

void	AssertAuthenticated ()

void	ClearResults ()

IQuery	OpenQueryContext (long commitId)

IQuery	CreateQueryContext ()

void	DisposeResult (int resultId)

int	AddResult (QueryResult result)

IMessageProcessor IConnector.	CreateProcessor ()

IMessageEnvelope IConnector.	CreateEnvelope (IDictionary< string, object > metadata, IMessage message)

ObjectId	CreateLargeObject (long objectLength)

void	AssertNotDisposed ()

void	AssertAuthenticated ()

IRef	GetObjectRef (long objectId)

int	AddResult (QueryResult result)

QueryResult	GetResult (int resultId)

void	ClearResults ()

IMessageProcessor IConnector.	CreateProcessor ()

IMessageEnvelope IConnector.	CreateEnvelope (IDictionary< string, object > metadata, IMessage message)

IStreamableObjectChannel IConnector.	CreateObjectChannel (long objectId)

void	DisposeChannel (long objId)

IRef	CompleteStream (long objId)

ITriggerChannel IConnector.	CreateTriggerChannel (string triggerName, string objectName, TriggerEventType eventType)

void	DisposeTriggerChannel (long id)

Private Attributes
bool	autoCommit

QueryParameterStyle	parameterStyle

bool	ignoreIdentifiersCase

Dictionary< int, QueryResult >	resultMap

int	uniqueResultId

readonly Dictionary< long, IRef >	blobIdMap

ParameterStyle	parameterStyle

int	triggerId

Dictionary< int, TriggerChannel >	triggerChannels

readonly object	triggerLock = new object()

readonly Dictionary< int, QueryResult >	resultMap

Detailed Description

Definition at line 31 of file ServerConnector.cs.

Constructor & Destructor Documentation

Deveel.Data.Protocol.ServerConnector.ServerConnector ( IDatabaseHandler databaseHandler )

inlineprotected

Definition at line 39 of file ServerConnector.cs.

                                                                     {
             DatabaseHandler = databaseHandler;
 
             resultMap = new Dictionary<int, QueryResult>();
             uniqueResultId = -1;
         }

Deveel.Data.Protocol.ServerConnector.~ServerConnector ( )

inlineprivate

Definition at line 46 of file ServerConnector.cs.

                            {
             Dispose(false);
         }

Deveel.Data.Protocol.ServerConnector.ServerConnector ( IDatabaseHandler handler )

inlineprotected

Definition at line 41 of file ServerConnector.old.cs.

                                                             {
             if (handler == null)
                 throw new ArgumentNullException("handler");
 
             DatabaseHandler = handler;
             resultMap = new Dictionary<int, QueryResult>();
             blobIdMap = new Dictionary<long, IRef>();
             uniqueResultId = 1;
         }

Member Function Documentation

int Deveel.Data.Protocol.ServerConnector.AddResult ( QueryResult result )

inlineprivate

Definition at line 367 of file ServerConnector.cs.

                                                   {
             result.LockRoot();
 
             int resultId;
 
             lock (resultMap) {
                 resultId = ++uniqueResultId;
                 resultMap[resultId] = result;
             }
 
             return resultId;
         }

int Deveel.Data.Protocol.ServerConnector.AddResult ( QueryResult result )

inlineprivate

Definition at line 410 of file ServerConnector.old.cs.

                                                   {
             // Lock the roots of the result set.
             result.LockRoot(-1); // -1 because lock_key not implemented
 
             // Make a new result id
             int resultId;
             // This ensures this block can handle concurrent updates.
             lock (resultMap) {
                 resultId = ++uniqueResultId;
                 // Add the result to the map.
                 resultMap[resultId] = result;
             }
 
             return resultId;
         }

void Deveel.Data.Protocol.ServerConnector.AssertAuthenticated ( )

inlineprivate

Definition at line 77 of file ServerConnector.old.cs.

                                            {
             if (CurrentState != ConnectorState.Authenticated)
                 throw new InvalidOperationException("The connector is not authenticated.");
         }

void Deveel.Data.Protocol.ServerConnector.AssertAuthenticated ( )

inlineprivate

Definition at line 85 of file ServerConnector.cs.

                                            {
             if (CurrentState != ConnectorState.Authenticated)
                 throw new InvalidOperationException("The connector is not authenticated.");
 
             if (User == null)
                 throw new InvalidOperationException("The connector is authenticated but no user is set.");
         }

void Deveel.Data.Protocol.ServerConnector.AssertNotDisposed ( )

inlineprivate

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

                                          {
             if (CurrentState == ConnectorState.Disposed)
                 throw new ObjectDisposedException(GetType().AssemblyQualifiedName);
         }

void Deveel.Data.Protocol.ServerConnector.AssertNotDisposed ( )

inlineprivate

Definition at line 80 of file ServerConnector.cs.

                                          {
             if (CurrentState == ConnectorState.Disposed)
                 throw new ObjectDisposedException(GetType().AssemblyQualifiedName);
         }

virtual bool Deveel.Data.Protocol.ServerConnector.Authenticate	(	string	defaultSchema,
		string	username,
		string	password
	)

inlineprotectedvirtual

Definition at line 158 of file ServerConnector.cs.

                                                                                                     {
             if (CurrentState == ConnectorState.Authenticated)
                 throw new InvalidOperationException("Already authenticated.");
 
             // TODO: get the default schema from server configuration
             if (String.IsNullOrEmpty(defaultSchema))
                 defaultSchema = "SA";
 
             // TODO: Log a debug information
 
             // TODO: Log an information about the logging user...
 
             try {
                 var user = Database.Authenticate(username, password);
                 if (user == null)
                     return false;
 
                 if (!OnAuthenticated(user))
                     return false;
 
                 User = user;
 
                 // TODO: Accept more connection settings and store them here...
                 Metadata = new Dictionary<string, object> {
                     { "IgnoreIdentifiersCase", ignoreIdentifiersCase },
                     { "ParameterStyle", parameterStyle },
                     { "DefaultSchema", defaultSchema }
                 };
 
                 ChangeState(ConnectorState.Authenticated);
 
                 return true;
             } catch (Exception) {
                 // TODO: throw server error
                 throw;
             }
         }

virtual bool Deveel.Data.Protocol.ServerConnector.Authenticate	(	string	defaultSchema,
		string	username,
		string	password
	)

inlineprotectedvirtual

Definition at line 199 of file ServerConnector.old.cs.

                                                                                                     {
             if (CurrentState == ConnectorState.Authenticated &&
                 Session != null)
                 throw new InvalidOperationException("Already authenticated.");
 
             if (Logger.IsInterestedIn(LogLevel.Debug)) {
                 // Output the instruction to the _queries log.
                 Logger.DebugFormat(this, "[CLIENT] [{0}] - Log in", username);
             }
 
             if (Logger.IsInterestedIn(LogLevel.Info)) {
                 Logger.InfoFormat(this, "Authenticate User: {0}", username);
             }
 
             try {
                 Session = OnAuthenticate(defaultSchema, username, password);
                 if (Session == null)
                     return false;
 
                 Session.Connection.AutoCommit = autoCommit;
                 Session.Connection.IsInCaseInsensitiveMode = ignoreIdentifiersCase;
                 Session.Connection.ParameterStyle = parameterStyle;
 
                 ChangeState(ConnectorState.Authenticated);
 
                 return true;
             } catch (Exception e) {
                 // TODO: throw server error
                 throw;
             }
         }

int Deveel.Data.Protocol.ServerConnector.BeginTransaction ( )

inlineprotected

Definition at line 189 of file ServerConnector.old.cs.

                                          {
             AssertNotDisposed();
 
             // TODO: In a future version, we will provide multiple transactions.
             //       for the moment we only set the current connection not to auto-commit
             //       that will require an explicit commit.
             Session.Connection.AutoCommit = false;
             return -1;
         }

int Deveel.Data.Protocol.ServerConnector.BeginTransaction ( )

inlineprotected

Definition at line 380 of file ServerConnector.cs.

                                          {
             AssertAuthenticated();
 
             var transaction = Database.CreateTransaction(IsolationLevel.Serializable);
             if (transaction == null)
                 throw new InvalidOperationException();
 
             return transaction.CommitId;
         }

void Deveel.Data.Protocol.ServerConnector.ChangeState ( ConnectorState newState )

inlineprotected

Definition at line 82 of file ServerConnector.old.cs.

                                                             {
             AssertNotDisposed();
             CurrentState = newState;
         }

void Deveel.Data.Protocol.ServerConnector.ChangeState ( ConnectorState newState )

inlineprotected

Definition at line 116 of file ServerConnector.cs.

                                                             {
             AssertNotDisposed();
             CurrentState = newState;
         }

void Deveel.Data.Protocol.ServerConnector.ClearResults ( )

inlineprivate

Definition at line 105 of file ServerConnector.cs.

                                     {
             lock (resultMap) {
                 foreach (var result in resultMap.Values) {
                     if (result != null)
                         result.Dispose();
                 }
 
                 resultMap.Clear();
             }
         }

void Deveel.Data.Protocol.ServerConnector.ClearResults ( )

inlineprivate

Definition at line 493 of file ServerConnector.old.cs.

                                     {
             List<int> keys;
             lock (resultMap) {
                 keys = new List<int>(resultMap.Keys);
             }
 
             foreach (int resultId in keys) {
                 DisposeResult(resultId);
             }
         }

void Deveel.Data.Protocol.ServerConnector.CloseConnector ( )

inlineprotected

Definition at line 121 of file ServerConnector.old.cs.

                                         {
             try {
                 OnCloseConnector();
             } catch (Exception ex) {
                 Logger.Error(this, "Error when closing the connector.");
                 Logger.Error(this, ex);
             } finally {
                 ChangeState(ConnectorState.Closed);
             }
         }

void Deveel.Data.Protocol.ServerConnector.CloseConnector ( )

inlineprotected

Definition at line 141 of file ServerConnector.cs.

                                         {
             try {
                 OnCloseConnector();
             } catch (Exception) {
                 // TODO: log the exception
             } finally {
                 ChangeState(ConnectorState.Closed);
             }
         }

void Deveel.Data.Protocol.ServerConnector.CommitTransaction ( int commitId )

inlineprotected

Definition at line 418 of file ServerConnector.cs.

                                                        {
             AssertNotDisposed();
 
             var transaction = Database.TransactionFactory.OpenTransactions.FindById(commitId);
             if (transaction == null)
                 throw new InvalidOperationException();
 
             using (var session = new Session(transaction, User)) {
                 session.Commit();
             }
         }

void Deveel.Data.Protocol.ServerConnector.CommitTransaction ( int transactionId )

inlineprotected

Definition at line 504 of file ServerConnector.old.cs.

                                                             {
             AssertNotDisposed();
 
             try {
                 Session.Connection.Commit();
             } finally {
                 Session.Connection.AutoCommit = autoCommit;
             }
         }

IRef Deveel.Data.Protocol.ServerConnector.CompleteStream ( long objId )

inlineprivate

Definition at line 563 of file ServerConnector.old.cs.

                                                 {
             lock (blobIdMap) {
                 var objRef = GetObjectRef(objId);
                 if (objRef == null)
                     throw new InvalidOperationException();
 
                 blobIdMap.Remove(objId);
                 objRef.Complete();
                 return objRef;
             }
         }

IQueryResponse [] Deveel.Data.Protocol.ServerConnector.CoreExecuteQuery	(	string	text,
		IEnumerable< SqlQueryParameter >	parameters
	)

inlineprotected

Definition at line 257 of file ServerConnector.old.cs.

                                                                                                             {
             // Record the Query start time
             DateTime startTime = DateTime.Now;
 
             // Where Query result eventually resides.
             int resultId = -1;
 
             // For each StreamableObject in the query object, translate it to a
             // IRef object that presumably has been pre-pushed onto the server from
             // the client.
 
             // Evaluate the sql Query.
             var query = new SqlQuery(text);
             if (parameters != null) {
                 foreach (var parameter in parameters) {
                     var preparedParam = parameter.Value;
                     if (preparedParam is StreamableObject) {
                         var obj = (StreamableObject) preparedParam;
                         IRef objRef = CompleteStream(obj.Identifier);
                         preparedParam = objRef;
                     }
                     query.Parameters.Add(new SqlQueryParameter(parameter.Name, preparedParam));
                 }
             }
 
             Table[] results = SqlQueryExecutor.Execute(Session.Connection, query);
             var responses = new IQueryResponse[results.Length];
             int j = 0;
 
             foreach (Table result in results) {
                 QueryResult queryResult;
                 try {
                     // Put the result in the result cache...  This will Lock this object
                     // until it is removed from the result set cache.  Returns an id that
                     // uniquely identifies this result set in future communication.
                     // NOTE: This locks the roots of the table so that its contents
                     //   may not be altered.
                     queryResult = new QueryResult(query, result);
                     resultId = AddResult(queryResult);
                 } catch (Exception e) {
                     // If resultId set, then dispose the result set.
                     if (resultId != -1)
                         DisposeResult(resultId);
 
                     throw;
                 }
 
                 // The time it took the Query to execute.
                 TimeSpan taken = DateTime.Now - startTime;
 
                 // Return the Query response
                 responses[j]  = new QueryResponse(resultId, queryResult, (int) taken.TotalMilliseconds, "");
                 j++;
             }
 
             return responses;           
         }

IQueryResponse [] Deveel.Data.Protocol.ServerConnector.CoreExecuteQuery	(	IQuery	context,
		string	text,
		IEnumerable< QueryParameter >	parameters
	)

inlineprotected

Definition at line 307 of file ServerConnector.cs.

                                                                                                                          {
             // Where Query result eventually resides.
             int resultId = -1;
 
             // For each StreamableObject in the query object, translate it to a
             // IRef object that presumably has been pre-pushed onto the server from
             // the client.
 
             // Evaluate the sql Query.
             var query = new SqlQuery(text);
             if (parameters != null) {
                 // TODO: Download the Large-Objects and replace with a reference
             }
 
             var stopwatch = new Stopwatch();
             stopwatch.Start();
 
             var results = context.ExecuteQuery(query);
             var responses = new IQueryResponse[results.Length];
             int j = 0;
 
             foreach (var result in results) {
                 QueryResult queryResult;
                 try {
                     queryResult = new QueryResult(query, result);
                     resultId = AddResult(queryResult);
                 } catch (Exception) {
                     if (resultId != -1)
                         DisposeResult(resultId);
 
                     throw;
                 }
 
                 var taken = stopwatch.ElapsedMilliseconds;
 
                 // Return the Query response
                 responses[j] = new QueryResponse(resultId, queryResult, (int)taken, "");
 
                 j++;
             }
 
             stopwatch.Stop();
             return responses;
         }

abstract IServerMessageEnvelope Deveel.Data.Protocol.ServerConnector.CreateEnvelope	(	IDictionary< string, object >	metadata,
		IMessage	message
	)

protectedpure virtual

Implements Deveel.Data.Protocol.IConnector.

Implemented in Deveel.Data.Protocol.EmbeddedServerConnector.

IMessageEnvelope IConnector. Deveel.Data.Protocol.ServerConnector.CreateEnvelope	(	IDictionary< string, object >	metadata,
		IMessage	message
	)

inlineprivate

Implements Deveel.Data.Protocol.IConnector.

Definition at line 396 of file ServerConnector.cs.

                                                                                                            {
             return CreateEnvelope(metadata, message);
         }

abstract IServerMessageEnvelope Deveel.Data.Protocol.ServerConnector.CreateEnvelope	(	IDictionary< string, object >	metadata,
		IMessage	message
	)

protectedpure virtual

Implements Deveel.Data.Protocol.IConnector.

Implemented in Deveel.Data.Protocol.EmbeddedServerConnector.

IMessageEnvelope IConnector. Deveel.Data.Protocol.ServerConnector.CreateEnvelope	(	IDictionary< string, object >	metadata,
		IMessage	message
	)

inlineprivate

Implements Deveel.Data.Protocol.IConnector.

Definition at line 532 of file ServerConnector.old.cs.

                                                                                                            {
             return CreateEnvelope(metadata, message);
         }

ObjectId Deveel.Data.Protocol.ServerConnector.CreateLargeObject ( long objectLength )

inlineprivate

Definition at line 496 of file ServerConnector.cs.

                                                               {
             throw new NotImplementedException();
         }

ILargeObjectChannel Deveel.Data.Protocol.ServerConnector.CreateObjectChannel ( long objectId )

inline

Implements Deveel.Data.Protocol.IConnector.

Definition at line 401 of file ServerConnector.cs.

                                                                       {
             throw new NotImplementedException();
         }

IStreamableObjectChannel IConnector. Deveel.Data.Protocol.ServerConnector.CreateObjectChannel ( long objectId )

inlineprivate

Implements Deveel.Data.Protocol.IConnector.

Definition at line 545 of file ServerConnector.old.cs.

                                                                                {
             return CreateObjectChannel(objectId);
         }

virtual IStreamableObjectChannel Deveel.Data.Protocol.ServerConnector.CreateObjectChannel ( long objectId )

inlineprotectedvirtual

Implements Deveel.Data.Protocol.IConnector.

Definition at line 549 of file ServerConnector.old.cs.

                                                                                       {
             var obj = GetObjectRef(objectId);
             if (obj == null)
                 throw new InvalidOperationException("The object was not created or was not found.");
 
             return new DirectStreamableObjectChannel(this, obj);
         }

IMessageProcessor IConnector. Deveel.Data.Protocol.ServerConnector.CreateProcessor ( )

inlineprivate

Implements Deveel.Data.Protocol.IConnector.

Definition at line 390 of file ServerConnector.cs.

                                                        {
             return new ServerMessageProcessor(this);
         }

IMessageProcessor IConnector. Deveel.Data.Protocol.ServerConnector.CreateProcessor ( )

inlineprivate

Implements Deveel.Data.Protocol.IConnector.

Definition at line 526 of file ServerConnector.old.cs.

                                                        {
             return new ServerMessageProcessor(this);
         }

IQuery Deveel.Data.Protocol.ServerConnector.CreateQueryContext ( )

inlineprivate

Definition at line 246 of file ServerConnector.cs.

                                             {
             // TODO: make the isolation level configurable...
             var transaction = Database.CreateTransaction(IsolationLevel.Serializable);
             var session = new Session(transaction, User);
             session.AutoCommit(true);
             return session.CreateQuery();
         }

long Deveel.Data.Protocol.ServerConnector.CreateStreamableObject	(	ReferenceType	referenceType,
		long	length
	)

inlineprotected

Definition at line 231 of file ServerConnector.old.cs.

                                                                                         {
             lock (blobIdMap) {
                 try {
                     var obj = Session.Connection.CreateLargeObject(referenceType, length);
                     blobIdMap[obj.Id] = obj;
                     return obj.Id;
                 } catch (Exception ex) {
                     Logger.ErrorFormat(this, "A request to create an object of type {0} with length {1} caused and error.", referenceType, length);
                     Logger.Error(this, ex);
                     throw;
                 }
             }
         }

ITriggerChannel Deveel.Data.Protocol.ServerConnector.CreateTriggerChannel	(	string	triggerName,
		string	objectName,
		TriggerEventType	eventType
	)

inline

Implements Deveel.Data.Protocol.IConnector.

Definition at line 405 of file ServerConnector.cs.

                                                                                                                        {
             throw new NotImplementedException();
         }

ITriggerChannel IConnector. Deveel.Data.Protocol.ServerConnector.CreateTriggerChannel	(	string	triggerName,
		string	objectName,
		TriggerEventType	eventType
	)

inlineprivate

Definition at line 575 of file ServerConnector.old.cs.

                                                                                                                            {
             return CreateTriggerChannel(triggerName, objectName, eventType);
         }

virtual ITriggerChannel Deveel.Data.Protocol.ServerConnector.CreateTriggerChannel	(	string	triggerName,
		string	objectName,
		TriggerEventType	eventType
	)

inlineprotectedvirtual

Definition at line 579 of file ServerConnector.old.cs.

                                                                                                                                   {
             AssertAuthenticated();
 
             lock (triggerLock) {
                 if (triggerChannels == null)
                     triggerChannels = new Dictionary<int, TriggerChannel>();
 
                 foreach (TriggerChannel channel in triggerChannels.Values) {
                     // If there's an open channel for the trigger return it
                     if (channel.ShouldNotify(triggerName, objectName, eventType))
                         return channel;
                 }
 
                 int id = ++triggerId;
                 var newChannel = new TriggerChannel(this, id, triggerName, objectName, eventType);
                 triggerChannels[id] = newChannel;
                 return newChannel;
             }
         }

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

inline

Definition at line 54 of file ServerConnector.cs.

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

virtual void Deveel.Data.Protocol.ServerConnector.Dispose ( bool disposing )

inlineprotectedvirtual

Reimplemented in Deveel.Data.Protocol.LocalDatabaseClient.ServerConnector.

Definition at line 59 of file ServerConnector.cs.

                                                        {
             if (disposing) {
                 ClearResults();
             }
 
             Database = null;
             DatabaseHandler = null;
 
             ChangeState(ConnectorState.Disposed);
         }

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

inline

Definition at line 599 of file ServerConnector.old.cs.

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

virtual void Deveel.Data.Protocol.ServerConnector.Dispose ( bool disposing )

inlineprotectedvirtual

Reimplemented in Deveel.Data.Protocol.LocalDatabaseClient.ServerConnector.

Definition at line 604 of file ServerConnector.old.cs.

                                                        {
             if (disposing) {
                 // Clear the result set mapping
                 ClearResults();
 
                 if (Session != null)
                     Session.Dispose();
             }
 
             ChangeState(ConnectorState.Disposed);
         }

void Deveel.Data.Protocol.ServerConnector.DisposeChannel ( long objId )

inlineprivate

Definition at line 557 of file ServerConnector.old.cs.

                                                 {
             lock (blobIdMap) {
                 blobIdMap.Remove(objId);
             }
         }

void Deveel.Data.Protocol.ServerConnector.DisposeResult ( int resultId )

inlineprivate

Definition at line 352 of file ServerConnector.cs.

                                                  {
             // Remove this entry.
             QueryResult result;
             lock (resultMap) {
                 if (resultMap.TryGetValue(resultId, out result))
                     resultMap.Remove(resultId);
             }
 
             if (result != null) {
                 result.Dispose();
             } else {
                 // TODO: Log an error ...
             }
         }

void Deveel.Data.Protocol.ServerConnector.DisposeResult ( int resultId )

inlineprotected

Definition at line 479 of file ServerConnector.old.cs.

                                                    {
             // Remove this entry.
             QueryResult result;
             lock (resultMap) {
                 if (resultMap.TryGetValue(resultId, out result))
                     resultMap.Remove(resultId);
             }
             if (result != null) {
                 result.Dispose();
             } else {
                 Logger.Error(this, "Attempt to dispose invalid 'resultId'.");
             }
         }

void Deveel.Data.Protocol.ServerConnector.DisposeTriggerChannel ( long id )

inlineprivate

Definition at line 966 of file ServerConnector.old.cs.

                                                     {
             throw new NotImplementedException();
         }

IQueryResponse [] Deveel.Data.Protocol.ServerConnector.ExecuteQuery	(	long	commitId,
		string	text,
		IEnumerable< QueryParameter >	parameters
	)

inlineprotected

Definition at line 254 of file ServerConnector.cs.

                                                                                                                     {
             AssertAuthenticated();
 
             IQuery queryContext;
             if (commitId > 0) {
                 queryContext = OpenQueryContext(commitId);
             } else {
                 queryContext = CreateQueryContext();
             }
 
             return ExecuteQuery(queryContext, text, parameters);
         }

virtual IQueryResponse [] Deveel.Data.Protocol.ServerConnector.ExecuteQuery	(	IQuery	context,
		string	text,
		IEnumerable< QueryParameter >	parameters
	)

inlineprotectedvirtual

Definition at line 267 of file ServerConnector.cs.

                                                                                                                              {
             // TODO: Log a debug message..
 
             IQueryResponse[] response = null;
 
             try {
                 // Execute the Query (behaviour for this comes from super).
                 response = CoreExecuteQuery(context, text, parameters);
 
                 // Return the result.
                 return response;
             } finally {
                 // This always happens after tables are unlocked.
                 // Also guarenteed to happen even if something fails.
 
                 // If we are in auto-commit mode then commit the Query here.
                 // Do we auto-commit?
                 if (context.AutoCommit()) {
                     // If an error occured then roll-back
                     if (response == null) {
                         // Rollback.
                         context.Rollback();
                     } else {
                         try {
                             // Otherwise commit.
                             context.Commit();
                         } catch (Exception) {
                             foreach (IQueryResponse queryResponse in response) {
                                 // Dispose this response if the commit failed.
                                 DisposeResult(queryResponse.ResultId);
                             }
 
                             // And throw the SQL Exception
                             throw;
                         }
                     }
                 }
             }
         }

virtual IQueryResponse [] Deveel.Data.Protocol.ServerConnector.ExecuteQuery	(	string	text,
		IEnumerable< SqlQueryParameter >	parameters
	)

inlineprotectedvirtual

Definition at line 315 of file ServerConnector.old.cs.

                                                                                                                 {
             // Log this Query if Query logging is enabled
             if (Logger.IsInterestedIn(LogLevel.Debug)) {
                 // Output the instruction to the _queries log.
                 Logger.DebugFormat(this, "[CLIENT] [{0}] - Query: {1}", Session.User.UserName, text);
             }
 
             // Write debug message (Info level)
             if (Logger.IsInterestedIn(LogLevel.Debug)) {
                 Logger.DebugFormat(this, "Query From User: {0}", Session.User.UserName);
                 Logger.DebugFormat(this, "Query: {0}", text.Trim());
             }
 
             // Get the locking mechanism.
             LockingMechanism locker = Session.Connection.LockingMechanism;
             LockingMode lockMode = LockingMode.None;
             IQueryResponse[] response = null;
 
             try {
                 try {
                     // For simplicity - all database locking is now exclusive inside
                     // a transaction.  This means it is not possible to execute
                     // queries concurrently inside a transaction.  However, we are
                     // still able to execute queries concurrently from different
                     // connections.
                     //
                     // It's debatable whether we even need to perform this Lock anymore
                     // because we could change the contract of this method so that
                     // it is not thread safe.  This would require that the callee ensures
                     // more than one thread can not execute queries on the connection.
                     lockMode = LockingMode.Exclusive;
                     locker.SetMode(lockMode);
 
                     // Execute the Query (behaviour for this comes from super).
                     response = CoreExecuteQuery(text, parameters);
 
                     // Return the result.
                     return response;
 
                 } finally {
                     try {
                         // This is executed no matter what happens.  Very important we
                         // unlock the tables.
                         if (lockMode != LockingMode.None) {
                             locker.FinishMode(lockMode);
                         }
                     } catch (Exception e) {
                         // If this throws an exception, we should output it to the debug
                         // log and screen.
                         Logger.Error(this, "Exception finishing locks");
                         Logger.Error(this, e);
                         // Note, we can't throw an error here because we may already be in
                         // an exception that happened in the above 'try' block.
                     }
                 }
             } finally {
                 // This always happens after tables are unlocked.
                 // Also guarenteed to happen even if something fails.
 
                 // If we are in auto-commit mode then commit the Query here.
                 // Do we auto-commit?
                 if (Session.Connection.AutoCommit) {
                     // Yes, so grab an exclusive Lock and auto-commit.
                     try {
                         // Lock into exclusive mode.
                         locker.SetMode(LockingMode.Exclusive);
                         // If an error occured then roll-back
                         if (response == null) {
                             // Rollback.
                             Session.Connection.Rollback();
                         } else {
                             try {
                                 // Otherwise commit.
                                 Session.Connection.Commit();
                             } catch (Exception e) {
                                 foreach (IQueryResponse queryResponse in response) {
                                     // Dispose this response if the commit failed.
                                     DisposeResult(queryResponse.ResultId);
                                 }
 
                                 // And throw the SQL Exception
                                 throw;
                             }
                         }
                     } finally {
                         locker.FinishMode(LockingMode.Exclusive);
                     }
                 }
             }
         }

virtual EncryptionData Deveel.Data.Protocol.ServerConnector.GetEncryptionData ( )

inlineprotectedvirtual

Definition at line 136 of file ServerConnector.old.cs.

                                                              {
             return null;
         }

virtual EncryptionData Deveel.Data.Protocol.ServerConnector.GetEncryptionData ( )

inlineprotectedvirtual

Definition at line 154 of file ServerConnector.cs.

                                                              {
             return null;
         }

virtual IMessage Deveel.Data.Protocol.ServerConnector.GetMessage ( IMessageEnvelope envelope )

inlineprotectedvirtual

Definition at line 409 of file ServerConnector.cs.

                                                                          {
             if (envelope == null)
                 return null;
 
             // TODO: handle errors? it's not supposed the client to send errors to the server ...
 
             return envelope.Message;
         }

virtual IMessage Deveel.Data.Protocol.ServerConnector.GetMessage ( IMessageEnvelope envelope )

inlineprotectedvirtual

Definition at line 536 of file ServerConnector.old.cs.

                                                                          {
             if (envelope == null)
                 return null;
 
             // TODO: handle errors? it's not supposed the client to send errors to the server ...
 
             return envelope.Message;
         }

IRef Deveel.Data.Protocol.ServerConnector.GetObjectRef ( long objectId )

inlineprivate

Definition at line 245 of file ServerConnector.old.cs.

                                                  {
             lock (blobIdMap) {
                 IRef obj;
                 if (!blobIdMap.TryGetValue(objectId, out obj)) {
                     obj = Session.Connection.GetLargeObject(objectId);
                     blobIdMap[objectId] = obj;
                 }
 
                 return obj;
             }
         }

QueryResult Deveel.Data.Protocol.ServerConnector.GetResult ( int resultId )

inlineprivate

Definition at line 426 of file ServerConnector.old.cs.

                                                     {
             lock (resultMap) {
                 QueryResult result;
                 return resultMap.TryGetValue(resultId, out result) ? result : null;
             }
         }

QueryResult Deveel.Data.Protocol.ServerConnector.GetResult ( int resultId )

inlineprotected

Definition at line 486 of file ServerConnector.cs.

                                                       {
             lock (resultMap) {
                 QueryResult result;
                 if (!resultMap.TryGetValue(resultId, out result))
                     return null;
 
                 return result;
             }
         }

QueryResultPart Deveel.Data.Protocol.ServerConnector.GetResultPart	(	int	resultId,
		int	startRow,
		int	countRows
	)

inlineprotected

Definition at line 433 of file ServerConnector.old.cs.

                                                                                            {
             AssertNotDisposed();
 
             QueryResult table = GetResult(resultId);
             if (table == null)
                 throw new DatabaseException("'resultId' invalid.");
 
             int rowEnd = startRow + countRows;
 
             if (startRow < 0 || startRow >= table.RowCount ||
                 rowEnd > table.RowCount) {
                 throw new DatabaseException("Result part out of range.");
             }
 
             try {
                 int colCount = table.ColumnCount;
                 var block = new QueryResultPart(colCount);
                 for (int r = startRow; r < rowEnd; ++r) {
                     var row = new object[colCount];
                     for (int c = 0; c < colCount; ++c) {
                         TObject value = table.GetCellContents(c, r);
 
                         // If this is a IRef, we must assign it a streamable object
                         // id that the client can use to access the large object.
                         object clientOb;
                         if (value.Object is IRef) {
                             var reference = (IRef) value.Object;
                             clientOb = new StreamableObject(reference.Type, reference.RawSize, reference.Id);
                         } else {
                             clientOb = value.Object;
                         }
 
                         row[c] = clientOb;
                     }
 
                     block.AddRow(row);
                 }
                 return block;
             } catch (Exception e) {
                 Logger.Warning(this, e);
                 // If an exception was generated while getting the cell contents, then
                 // throw an DataException.
                 throw new DatabaseException("Exception while reading results: " + e.Message, e);
             }
         }

QueryResultPart Deveel.Data.Protocol.ServerConnector.GetResultPart	(	int	resultId,
		int	startRow,
		int	countRows
	)

inlineprotected

Definition at line 442 of file ServerConnector.cs.

                                                                                            {
             AssertNotDisposed();
 
             var table = GetResult(resultId);
             if (table == null)
                 throw new InvalidOperationException();
 
             int rowEnd = startRow + countRows;
 
             if (startRow < 0 || startRow >= table.RowCount || rowEnd > table.RowCount) {
                 throw new InvalidOperationException("Result part out of range.");
             }
 
             try {
                 int colCount = table.ColumnCount;
                 var block = new QueryResultPart(colCount);
                 for (int r = startRow; r < rowEnd; ++r) {
                     var row = new ISqlObject[colCount];
                     var sizes = new int[colCount];
 
                     for (int c = 0; c < colCount; ++c) {
                         var value = table.GetValue(r, c);
 
                         ISqlObject clientOb = null;
                         if (value.Value is IObjectRef) {
                             var reference = (IObjectRef)value.Value;
                             // TODO: Make a protocol placeholder for the large object ref
                         } else {
                             clientOb = value.Value;
                         }
 
                         row[c] = clientOb;
                         sizes[c] = value.Size;
                     }
 
                     block.AddRow(new QueryResultRow(row, sizes));
                 }
                 return block;
             } catch (Exception) {
                 // TODO: Log a warning ...
                 throw;
             }
         }

abstract ConnectionEndPoint Deveel.Data.Protocol.ServerConnector.MakeEndPoint ( IDictionary< string, object > properties )

pure virtual

Implemented in Deveel.Data.Protocol.EmbeddedServerConnector.

abstract ConnectionEndPoint Deveel.Data.Protocol.ServerConnector.MakeEndPoint ( IDictionary< string, object > properties )

pure virtual

Implemented in Deveel.Data.Protocol.EmbeddedServerConnector.

virtual AuthenticatedSession Deveel.Data.Protocol.ServerConnector.OnAuthenticate	(	string	defaultSchema,
		string	username,
		string	password
	)

inlineprotectedvirtual

Definition at line 140 of file ServerConnector.old.cs.

                                                                                                                       {
             var user = Database.AuthenticateUser(username, password, RemoteEndPoint);
 
             if (user == null) 
                 return null;
 
             IDatabaseConnection connection = Database.CreateNewConnection(user, OnTriggerFired);
 
             // Put the connection in exclusive mode
             LockingMechanism locker = connection.LockingMechanism;
             locker.SetMode(LockingMode.Exclusive);
 
             try {
                 // By default, connections are auto-commit
                 connection.AutoCommit = true;
 
                 // Set the default schema for this connection if it exists
                 if (connection.SchemaExists(defaultSchema)) {
                     connection.SetDefaultSchema(defaultSchema);
                 } else {
                     Logger.WarningFormat(this, "Couldn't change to '{0}' schema.", defaultSchema);
 
                     // If we can't change to the schema then change to the APP schema
                     connection.SetDefaultSchema(ConfigDefaultValues.DefaultSchema);
                 }
             } finally {
                 try {
                     connection.Commit();
                 } catch (TransactionException e) {
                     // Just issue a warning...
                     Logger.Warning(this, e);
                 } finally {
                     // Guarentee that we unluck from EXCLUSIVE
                     locker.FinishMode(LockingMode.Exclusive);
                 }
             }
 
             return new AuthenticatedSession(user, connection);
         }

virtual bool Deveel.Data.Protocol.ServerConnector.OnAuthenticated ( User user )

inlineprotectedvirtual

Definition at line 196 of file ServerConnector.cs.

                                                           {
             return true;
         }

virtual void Deveel.Data.Protocol.ServerConnector.OnCloseConnector ( )

inlineprotectedvirtual

Definition at line 132 of file ServerConnector.old.cs.

                                                   {
             
         }

virtual void Deveel.Data.Protocol.ServerConnector.OnCloseConnector ( )

inlineprotectedvirtual

Definition at line 151 of file ServerConnector.cs.

151 {

152 }

virtual void Deveel.Data.Protocol.ServerConnector.OnConnectorOpen ( )

inlineprotectedvirtual

Definition at line 103 of file ServerConnector.old.cs.

103 {

104 }

virtual void Deveel.Data.Protocol.ServerConnector.OnConnectorOpen ( )

inlineprotectedvirtual

Definition at line 136 of file ServerConnector.cs.

136 {

137 }

virtual void Deveel.Data.Protocol.ServerConnector.OnTriggerFired	(	string	triggerName,
		string	triggerSource,
		TriggerEventType	eventType,
		int	count
	)

inlineprotectedvirtual

Definition at line 180 of file ServerConnector.old.cs.

                                                                                                                                {
             lock (triggerChannels) {
                 foreach (var channel in triggerChannels.Values) {
                     if (channel.ShouldNotify(triggerName, triggerSource, eventType))
                         channel.Notify(triggerName, triggerSource, eventType, count);
                 }
             }
         }

void Deveel.Data.Protocol.ServerConnector.OpenConnector	(	ConnectionEndPoint	remoteEndPoint,
		string	databaseName
	)

inlineprotected

Definition at line 87 of file ServerConnector.old.cs.

                                                                                              {
             try {
                 RemoteEndPoint = remoteEndPoint;
                 Database = DatabaseHandler.GetDatabase(databaseName);
                 if (Database == null)
                     throw new DatabaseException();
 
                 OnConnectorOpen();
                 ChangeState(ConnectorState.Open);
             } catch (Exception ex) {
                 Logger.Error(this, "Error when opening the connector.");
                 Logger.Error(this, ex);
                 throw;
             }
         }

void Deveel.Data.Protocol.ServerConnector.OpenConnector	(	ConnectionEndPoint	remoteEndPoint,
		string	databaseName
	)

inlineprotected

Definition at line 121 of file ServerConnector.cs.

                                                                                              {
             try {
                 RemoteEndPoint = remoteEndPoint;
                 Database = DatabaseHandler.GetDatabase(databaseName);
                 if (Database == null)
                     throw new InvalidOperationException();
 
                 OnConnectorOpen();
                 ChangeState(ConnectorState.Open);
             } catch (Exception) {
                 // TODO: Log the error...
                 throw;
             }
         }

IQuery Deveel.Data.Protocol.ServerConnector.OpenQueryContext ( long commitId )

inlineprivate

Definition at line 237 of file ServerConnector.cs.

                                                        {
             var transaction = Database.TransactionFactory.OpenTransactions.FindById((int)commitId);
             if (transaction == null)
                 throw new InvalidOperationException();
 
             var session = new Session(transaction, User);
             return session.CreateQuery();
         }

void Deveel.Data.Protocol.ServerConnector.RollbackTransaction ( int commitId )

inlineprotected

Definition at line 430 of file ServerConnector.cs.

                                                          {
             AssertNotDisposed();
 
             var transaction = Database.TransactionFactory.OpenTransactions.FindById(commitId);
             if (transaction == null)
                 throw new InvalidOperationException();
 
             using (var session = new Session(transaction, User)) {
                 session.Rollback();
             }
         }

void Deveel.Data.Protocol.ServerConnector.RollbackTransaction ( int transactionId )

inlineprotected

Definition at line 514 of file ServerConnector.old.cs.

                                                               {
             AssertNotDisposed();
 
             try {
                 Session.Connection.Rollback();
             } finally {
                 Session.Connection.AutoCommit = autoCommit;
             }
         }

void Deveel.Data.Protocol.ServerConnector.SetAutoCommit ( bool value )

inlineprotected

Definition at line 93 of file ServerConnector.cs.

                                                  {
             autoCommit = value;
         }

void Deveel.Data.Protocol.ServerConnector.SetAutoCommit ( bool state )

inlineprotected

Definition at line 106 of file ServerConnector.old.cs.

                                                  {
             AssertNotDisposed();
             autoCommit = state;
         }

void Deveel.Data.Protocol.ServerConnector.SetIgnoreIdentifiersCase ( bool value )

inlineprotected

Definition at line 101 of file ServerConnector.cs.

                                                             {
             ignoreIdentifiersCase = value;
         }

void Deveel.Data.Protocol.ServerConnector.SetIgnoreIdentifiersCase ( bool state )

inlineprotected

Definition at line 111 of file ServerConnector.old.cs.

                                                             {
             AssertNotDisposed();
             ignoreIdentifiersCase = state;
         }

void Deveel.Data.Protocol.ServerConnector.SetParameterStyle ( QueryParameterStyle parameterStyle )

inlineprotected

Definition at line 97 of file ServerConnector.cs.

                                                                              {
             this.parameterStyle = parameterStyle;
         }

void Deveel.Data.Protocol.ServerConnector.SetParameterStyle ( ParameterStyle style )

inlineprotected

Definition at line 116 of file ServerConnector.old.cs.

                                                                {
             AssertNotDisposed();
             parameterStyle = style;
         }

Member Data Documentation

bool Deveel.Data.Protocol.ServerConnector.autoCommit

private

Definition at line 32 of file ServerConnector.cs.

readonly Dictionary<long, IRef> Deveel.Data.Protocol.ServerConnector.blobIdMap

private

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

bool Deveel.Data.Protocol.ServerConnector.ignoreIdentifiersCase

private

Definition at line 34 of file ServerConnector.cs.

QueryParameterStyle Deveel.Data.Protocol.ServerConnector.parameterStyle

private

Definition at line 33 of file ServerConnector.cs.

ParameterStyle Deveel.Data.Protocol.ServerConnector.parameterStyle

private

Definition at line 35 of file ServerConnector.old.cs.

Dictionary<int, QueryResult> Deveel.Data.Protocol.ServerConnector.resultMap

private

Definition at line 36 of file ServerConnector.cs.

readonly Dictionary<int, QueryResult> Deveel.Data.Protocol.ServerConnector.resultMap

private

Definition at line 406 of file ServerConnector.old.cs.

Dictionary<int, TriggerChannel> Deveel.Data.Protocol.ServerConnector.triggerChannels

private

Definition at line 38 of file ServerConnector.old.cs.

int Deveel.Data.Protocol.ServerConnector.triggerId

private

Definition at line 37 of file ServerConnector.old.cs.

readonly object Deveel.Data.Protocol.ServerConnector.triggerLock = new object()

private

Definition at line 39 of file ServerConnector.old.cs.

int Deveel.Data.Protocol.ServerConnector.uniqueResultId

private

Definition at line 37 of file ServerConnector.cs.

Property Documentation

ConnectorState Deveel.Data.Protocol.ServerConnector.CurrentState

getprivate set

Definition at line 78 of file ServerConnector.cs.

IDatabase Deveel.Data.Protocol.ServerConnector.Database

getprivate setprotected

Definition at line 52 of file ServerConnector.cs.

IDatabaseHandler Deveel.Data.Protocol.ServerConnector.DatabaseHandler

getprivate setprotected

Definition at line 50 of file ServerConnector.cs.

abstract ConnectionEndPoint Deveel.Data.Protocol.ServerConnector.LocalEndPoint

get

Definition at line 70 of file ServerConnector.cs.

ILogger Deveel.Data.Protocol.ServerConnector.Logger

getprotected

Definition at line 61 of file ServerConnector.old.cs.

IDictionary<string, object> Deveel.Data.Protocol.ServerConnector.Metadata

getprivate setprotected

Definition at line 76 of file ServerConnector.cs.

ConnectionEndPoint Deveel.Data.Protocol.ServerConnector.RemoteEndPoint

getprivate set

Definition at line 72 of file ServerConnector.cs.

AuthenticatedSession Deveel.Data.Protocol.ServerConnector.Session

getprotected set

Definition at line 51 of file ServerConnector.old.cs.

User Deveel.Data.Protocol.ServerConnector.User

getprivate setprotected

Definition at line 74 of file ServerConnector.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/ServerConnector.cs
/var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Protocol/ServerConnector.old.cs

Classes

Public Member Functions

Protected Member Functions

Properties

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

Property Documentation