Deveel.Data.Sql.Triggers.TriggerManager Class Reference

Inheritance diagram for Deveel.Data.Sql.Triggers.TriggerManager:

Classes
class	TriggerArgument
class	TriggersTableContainer

Public Member Functions
	TriggerManager (ITransaction transaction)
void	Dispose ()
void	Create ()
	Initializes the manager into the underlying system. More...
ObjectName	ResolveName (ObjectName objName, bool ignoreCase)
	Normalizes the input object name using the case sensitivity specified. More...
void	CreateTrigger (TriggerInfo triggerInfo)
bool	DropTrigger (ObjectName triggerName)
bool	TriggerExists (ObjectName triggerName)
Trigger	GetTrigger (ObjectName triggerName)
bool	AlterTrigger (TriggerInfo triggerInfo)
IEnumerable< Trigger >	FindTriggers (TriggerEventInfo eventInfo)
void	FireTriggers (IQuery context, TableEvent tableEvent)
ITableContainer	CreateTriggersTableContainer ()

Properties
DbObjectType IObjectManager.	ObjectType [get]
Properties inherited from Deveel.Data.Sql.IObjectManager
DbObjectType	ObjectType [get]
	Gets the type of objects managed by this instance. More...

Private Member Functions
	~TriggerManager ()
void	Dispose (bool disposing)
void	OnTableCommit (TableCommitEvent commitEvent)
void	OnCommit (TableCommitInfo commitInfo)
void	BuildTriggerCache ()
void	InvalidateTriggerCache ()
ITable	FindTrigger (ITable table, string schema, string name)
IEnumerable< TriggerInfo >	FindTriggers (ObjectName tableName, TriggerEventType eventType)
void IObjectManager.	CreateObject (IObjectInfo objInfo)
	Create a new object of the ObjectType given the specifications given. More...
bool IObjectManager.	RealObjectExists (ObjectName objName)
	Checks if an object really exists in the system. More...
bool IObjectManager.	ObjectExists (ObjectName objName)
	Checks if an object identified by the given name is managed by this instance. More...
IDbObject IObjectManager.	GetObject (ObjectName objName)
	Gets a database object managed by this manager. More...
bool IObjectManager.	AlterObject (IObjectInfo objInfo)
	Modifies an existing object managed, identified by IObjectInfo.FullName component of the given specification, with the format given. More...
bool IObjectManager.	DropObject (ObjectName objName)
	Deletes a database object handled by this manager from the system. More...
void ITriggerManager.	RegisterTrigger (TriggerInfo triggerInfo)
TriggerInfo	FormTrigger (Row row)

Static Private Member Functions
static byte[]	SerializeArguments (TriggerArgument args)

Private Attributes
ITransaction	transaction
bool	tableModified
bool	cacheValid
List< Trigger >	triggerCache

Detailed Description

Definition at line 30 of file TriggerManager.cs.

Constructor & Destructor Documentation

Deveel.Data.Sql.Triggers.TriggerManager.TriggerManager ( ITransaction  transaction )

inline

Definition at line 36 of file TriggerManager.cs.

                                                        {
            this.transaction = transaction;
            triggerCache = new List<Trigger>(24);
            this.transaction.RegisterOnCommit(OnCommit);
        }

Deveel.Data.Sql.Triggers.TriggerManager.~TriggerManager ( )

inlineprivate

Definition at line 42 of file TriggerManager.cs.

                          {
            Dispose(false);
        }

Member Function Documentation

bool IObjectManager. Deveel.Data.Sql.Triggers.TriggerManager.AlterObject ( IObjectInfo  objInfo )

inlineprivate

Modifies an existing object managed, identified by IObjectInfo.FullName component of the given specification, with the format given.

Parameters

objInfo

The object specification used to alter an existing object.

Returns

Returns true an object was identified and successfully altered, or false if none database object was found for the unique name given.

Exceptions

ArgumentNullException	If the given objInfo object is null.
ArgumentException	If the type of the object specified (IObjectInfo.ObjectType) is different than the type of objects handled by this manager.

Implements Deveel.Data.Sql.IObjectManager.

Definition at line 195 of file TriggerManager.cs.

                                                             {
            var triggerInfo = objInfo as TriggerInfo;
            if (triggerInfo == null)
                throw new ArgumentException();

            return AlterTrigger(triggerInfo);
        }

bool Deveel.Data.Sql.Triggers.TriggerManager.AlterTrigger ( TriggerInfo  triggerInfo )

inline

Definition at line 331 of file TriggerManager.cs.

                                                          {
            throw new NotImplementedException();
        }

void Deveel.Data.Sql.Triggers.TriggerManager.BuildTriggerCache ( )

inlineprivate

Definition at line 90 of file TriggerManager.cs.

                                         {
            if (!cacheValid) {
                var table = transaction.GetTable(SystemSchema.TriggerTableName);

                var list =  new List<Trigger>();
                foreach (var row in table) {
                    var triggerInfo = FormTrigger(row);
                    list.Add(new Trigger(triggerInfo));
                }

                triggerCache = new List<Trigger>(list);
                cacheValid = true;
            }
        }

void Deveel.Data.Sql.Triggers.TriggerManager.Create ( )

inline

Initializes the manager into the underlying system.

Typically this method generates the tables required to manage the features relative to the objects.

Implements Deveel.Data.Sql.IObjectManager.

Definition at line 109 of file TriggerManager.cs.

                             {
            var tableInfo = new TableInfo(SystemSchema.TriggerTableName);
            tableInfo.AddColumn("schema", PrimitiveTypes.String());
            tableInfo.AddColumn("name", PrimitiveTypes.String());
            tableInfo.AddColumn("type", PrimitiveTypes.Integer());
            tableInfo.AddColumn("on_object", PrimitiveTypes.String());
            tableInfo.AddColumn("action", PrimitiveTypes.Integer());
            tableInfo.AddColumn("procedure_name", PrimitiveTypes.String());
            tableInfo.AddColumn("args", PrimitiveTypes.Binary());
            transaction.CreateTable(tableInfo);
        }

void IObjectManager. Deveel.Data.Sql.Triggers.TriggerManager.CreateObject ( IObjectInfo  objInfo )

inlineprivate

Create a new object of the ObjectType given the specifications given.

Parameters

objInfo

The object specifications used to create a new object.

Exceptions

ArgumentNullException	If the given objInfo is null.
ArgumentException	If the object type of the specification (IObjectInfo.ObjectType) is different than the ObjectType of this manager.

Implements Deveel.Data.Sql.IObjectManager.

Definition at line 175 of file TriggerManager.cs.

                                                              {
            var triggerInfo = objInfo as TriggerInfo;
            if (triggerInfo == null)
                throw new ArgumentException();

            CreateTrigger(triggerInfo);
        }

void Deveel.Data.Sql.Triggers.TriggerManager.CreateTrigger ( TriggerInfo  triggerInfo )

inline

Definition at line 245 of file TriggerManager.cs.

                                                           {
            if (!transaction.TableExists(SystemSchema.TriggerTableName))
                return;

            try {
                var args = new TriggerArgument(triggerInfo.Arguments.ToArray());
                var binArgs = SerializeArguments(args);

                var schema = triggerInfo.TriggerName.ParentName;
                var name = triggerInfo.TriggerName.Name;
                var type = (int) triggerInfo.TriggerType;
                var onTable = triggerInfo.TableName == null ? null : triggerInfo.TableName.FullName;
                var procedureName = triggerInfo.ProcedureName != null ? triggerInfo.ProcedureName.FullName : null;

                var action = (int) triggerInfo.EventType;
                
                // TODO: if the trigger has a body, create a special procedure and set the name

                // Insert the entry into the trigger table,
                var table = transaction.GetMutableTable(SystemSchema.TriggerTableName);
                var row = table.NewRow();
                row.SetValue(0, DataObject.String(schema));
                row.SetValue(1, DataObject.String(name));
                row.SetValue(2, DataObject.Integer(type));
                row.SetValue(3, DataObject.String(onTable));
                row.SetValue(4, DataObject.Integer(action));
                row.SetValue(5, DataObject.String(procedureName));
                row.SetValue(6, DataObject.Binary(binArgs));
                table.AddRow(row);

                InvalidateTriggerCache();

                transaction.Registry.RegisterEvent(new ObjectCreatedEvent(triggerInfo.TriggerName, DbObjectType.Trigger));

                tableModified = true;
            } catch (Exception) {
                // TODO: use a specialized exception
                throw;
            }
        }

ITableContainer Deveel.Data.Sql.Triggers.TriggerManager.CreateTriggersTableContainer ( )

inline

Definition at line 352 of file TriggerManager.cs.

                                                              {
            return new TriggersTableContainer(transaction);
        }

void Deveel.Data.Sql.Triggers.TriggerManager.Dispose ( )

inline

Definition at line 46 of file TriggerManager.cs.

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

void Deveel.Data.Sql.Triggers.TriggerManager.Dispose ( bool  disposing )

inlineprivate

Definition at line 51 of file TriggerManager.cs.

                                             {
            if (disposing) {
                if (triggerCache != null)
                    triggerCache.Clear();
            }

            triggerCache = null;
            transaction = null;
            cacheValid = false;
        }

bool IObjectManager. Deveel.Data.Sql.Triggers.TriggerManager.DropObject ( ObjectName  objName )

inlineprivate

Deletes a database object handled by this manager from the system.

Parameters

objName

The unique name of the object to be deleted.

Returns

Returns true if a database object was found with the given unique name and successfully deleted from the system, or false if none object was found.

Implements Deveel.Data.Sql.IObjectManager.

Definition at line 203 of file TriggerManager.cs.

                                                           {
            return DropTrigger(objName);
        }

bool Deveel.Data.Sql.Triggers.TriggerManager.DropTrigger ( ObjectName  triggerName )

inline

Definition at line 286 of file TriggerManager.cs.

                                                        {
            throw new NotImplementedException();
        }

ITable Deveel.Data.Sql.Triggers.TriggerManager.FindTrigger ( ITable  table, string  schema, string  name  )

inlineprivate

Definition at line 121 of file TriggerManager.cs.

                                                                             {
            // Find all the trigger entries with this name
            var schemaColumn = table.GetResolvedColumnName(0);
            var nameColumn = table.GetResolvedColumnName(1);

            using (var session = new SystemSession(transaction, SystemSchema.Name)) {
                using (var context = session.CreateQuery()) {
                    var t = table.SimpleSelect(context, nameColumn, SqlExpressionType.Equal,
                        SqlExpression.Constant(DataObject.String(name)));
                    return t.ExhaustiveSelect(context,
                        SqlExpression.Equal(SqlExpression.Reference(schemaColumn), SqlExpression.Constant(DataObject.String(schema))));
                }
            }
        }

IEnumerable<TriggerInfo> Deveel.Data.Sql.Triggers.TriggerManager.FindTriggers ( ObjectName  tableName, TriggerEventType  eventType  )

inlineprivate

Definition at line 136 of file TriggerManager.cs.

                                                                                                        {
            var fullTableName = tableName.FullName;
            var eventTypeCode = (int)eventType;

            var table = transaction.GetTable(SystemSchema.TriggerTableName);
            if (table == null)
                return new TriggerInfo[0];

            var tableColumn = table.GetResolvedColumnName(3);
            var eventTypeColumn = table.GetResolvedColumnName(4);

            ITable result;
            using (var session = new SystemSession(transaction, SystemSchema.Name)) {
                using (var context = session.CreateQuery()) {
                    var t = table.SimpleSelect(context, tableColumn, SqlExpressionType.Equal,
                        SqlExpression.Constant(DataObject.String(fullTableName)));

                    result = t.ExhaustiveSelect(context,
                        SqlExpression.Equal(SqlExpression.Reference(eventTypeColumn), SqlExpression.Constant(eventTypeCode)));
                }
            }

            if (result.RowCount == 0)
                return new TriggerInfo[0];

            var list = new List<TriggerInfo>();

            foreach (var row in result) {
                var triggerInfo = FormTrigger(row);

                //TODO: get the other information such has the body, the external method or the procedure
                //      if this is a non-callback

                list.Add(triggerInfo);
            }

            return list.AsEnumerable();
        }

IEnumerable<Trigger> Deveel.Data.Sql.Triggers.TriggerManager.FindTriggers ( TriggerEventInfo  eventInfo )

inline

Definition at line 335 of file TriggerManager.cs.

                                                                             {
            var triggers = FindTriggers(eventInfo.TableName, eventInfo.EventType);
            return triggers.Select(x => new Trigger(x));
        }

void Deveel.Data.Sql.Triggers.TriggerManager.FireTriggers ( IQuery  context, TableEvent  tableEvent  )

inline

Implements Deveel.Data.Sql.Triggers.ITriggerManager.

Definition at line 340 of file TriggerManager.cs.

                                                                        {
            if (!transaction.TableExists(SystemSchema.TriggerTableName))
                return;

            BuildTriggerCache();

            foreach (var trigger in triggerCache) {
                if (trigger.CanInvoke(tableEvent))
                    trigger.Invoke(context, tableEvent);
            }
        }

TriggerInfo Deveel.Data.Sql.Triggers.TriggerManager.FormTrigger ( Row  row )

inlineprivate

Definition at line 315 of file TriggerManager.cs.

                                                 {
            var schema = row.GetValue(0).Value.ToString();
            var name = row.GetValue(1).Value.ToString();
            var triggerName = new ObjectName(new ObjectName(schema), name);

            var triggerType = (TriggerType)((SqlNumber)row.GetValue(2).Value).ToInt32();

            // TODO: In case it's  a procedural trigger, take the reference to the procedure
            if (triggerType == TriggerType.Procedure)
                throw new NotImplementedException();

            var tableName = ObjectName.Parse(((SqlString) row.GetValue(3).Value).ToString());
            var eventType = (TriggerEventType) ((SqlNumber) row.GetValue(4).Value).ToInt32();
            return  new TriggerInfo(triggerName, triggerType, eventType, tableName);
        }

IDbObject IObjectManager. Deveel.Data.Sql.Triggers.TriggerManager.GetObject ( ObjectName  objName )

inlineprivate

Gets a database object managed by this manager.

Parameters

objName

The name that uniquely identifies the object to get.

Returns

Returns a IDbObject instance that is identified by the given unique name, or null if this manager was not able to map any object to the name specified.

Implements Deveel.Data.Sql.IObjectManager.

Definition at line 191 of file TriggerManager.cs.

                                                               {
            return GetTrigger(objName);
        }

Trigger Deveel.Data.Sql.Triggers.TriggerManager.GetTrigger ( ObjectName  triggerName )

inline

Definition at line 302 of file TriggerManager.cs.

                                                          {
            var table = transaction.GetTable(SystemSchema.TriggerTableName);
            var result = FindTrigger(table, triggerName.ParentName, triggerName.Name);
            if (result.RowCount == 0)
                return null;

            if (result.RowCount > 1)
                throw new InvalidOperationException(String.Format("More than one trigger found with name '{0}'.", triggerName));

            var triggerInfo = FormTrigger(result.First());
            return new Trigger(triggerInfo);
        }

void Deveel.Data.Sql.Triggers.TriggerManager.InvalidateTriggerCache ( )

inlineprivate

Definition at line 105 of file TriggerManager.cs.

                                              {
            cacheValid = false;
        }

bool IObjectManager. Deveel.Data.Sql.Triggers.TriggerManager.ObjectExists ( ObjectName  objName )

inlineprivate

Checks if an object identified by the given name is managed by this instance.

Parameters

objName

The name that uniquely identifies the object.

Returns

Implements Deveel.Data.Sql.IObjectManager.

Definition at line 187 of file TriggerManager.cs.

                                                             {
            return TriggerExists(objName);
        }

void Deveel.Data.Sql.Triggers.TriggerManager.OnCommit ( TableCommitInfo  commitInfo )

inlineprivate

Definition at line 78 of file TriggerManager.cs.

                                                          {
            if (tableModified) {
                InvalidateTriggerCache();
                tableModified = false;
            } else if ((commitInfo.AddedRows != null &&
                 commitInfo.AddedRows.Any()) ||
                (commitInfo.RemovedRows != null &&
                 commitInfo.RemovedRows.Any())) {
                InvalidateTriggerCache();
            }
        }

void Deveel.Data.Sql.Triggers.TriggerManager.OnTableCommit ( TableCommitEvent  commitEvent )

inlineprivate

Definition at line 66 of file TriggerManager.cs.

                                                                 {
            if (tableModified) {
                InvalidateTriggerCache();
                tableModified = false;
            } else if ((commitEvent.AddedRows != null &&
                        commitEvent.AddedRows.Any()) ||
                       (commitEvent.RemovedRows != null &&
                        commitEvent.RemovedRows.Any())) {
                InvalidateTriggerCache();
            }
        }

bool IObjectManager. Deveel.Data.Sql.Triggers.TriggerManager.RealObjectExists ( ObjectName  objName )

inlineprivate

Checks if an object really exists in the system.

Parameters

objName

The unique name of the object to check.

Returns

Returns true if an object with the given name concretely exists in the system, or false otherwise.

Implements Deveel.Data.Sql.IObjectManager.

Definition at line 183 of file TriggerManager.cs.

                                                                 {
            return TriggerExists(objName);
        }

void ITriggerManager. Deveel.Data.Sql.Triggers.TriggerManager.RegisterTrigger ( TriggerInfo  triggerInfo )

inlineprivate

Implements Deveel.Data.Sql.Triggers.ITriggerManager.

Definition at line 241 of file TriggerManager.cs.

                                                                      {
            CreateTrigger(triggerInfo);
        }

ObjectName Deveel.Data.Sql.Triggers.TriggerManager.ResolveName ( ObjectName  objName, bool  ignoreCase  )

inline

Normalizes the input object name using the case sensitivity specified.

Parameters

objName	The input object name, that can be partial or complete, to be normalized to the real name of an object.
ignoreCase	The case sensitivity specification used to compare the input name with the names of the existing objects handled by this manager.

Returns

Returns the fully normalized ObjectName that is the real name of an object matching the input name, or null if the input name was not possible to be resolved.

Implements Deveel.Data.Sql.IObjectManager.

Definition at line 207 of file TriggerManager.cs.

                                                                           {
            throw new NotImplementedException();
        }

static byte [] Deveel.Data.Sql.Triggers.TriggerManager.SerializeArguments ( TriggerArgument  args )

inlinestaticprivate

Definition at line 228 of file TriggerManager.cs.

                                                                       {
            using (var stream = new MemoryStream()) {
                using (var writer = new BinaryWriter(stream)) {
                    var serializer = new BinarySerializer();
                    serializer.Serialize(writer, args);

                    writer.Flush();

                    return stream.ToArray();
                }
            }
        }

bool Deveel.Data.Sql.Triggers.TriggerManager.TriggerExists ( ObjectName  triggerName )

inline

Definition at line 290 of file TriggerManager.cs.

                                                          {
            var table = transaction.GetTable(SystemSchema.TriggerTableName);
            var result = FindTrigger(table, triggerName.ParentName, triggerName.Name);
            if (result.RowCount == 0)
                return false;

            if (result.RowCount > 1)
                throw new InvalidOperationException(String.Format("More than one trigger found with name '{0}'.", triggerName));

            return true;
        }

Member Data Documentation

bool Deveel.Data.Sql.Triggers.TriggerManager.cacheValid

private

Definition at line 33 of file TriggerManager.cs.

bool Deveel.Data.Sql.Triggers.TriggerManager.tableModified

private

Definition at line 32 of file TriggerManager.cs.

ITransaction Deveel.Data.Sql.Triggers.TriggerManager.transaction

private

Definition at line 31 of file TriggerManager.cs.

List<Trigger> Deveel.Data.Sql.Triggers.TriggerManager.triggerCache

private

Definition at line 34 of file TriggerManager.cs.

Property Documentation

DbObjectType IObjectManager. Deveel.Data.Sql.Triggers.TriggerManager.ObjectType

getprivate

Definition at line 62 of file TriggerManager.cs.

---

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

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Sql.Triggers/TriggerManager.cs