Deveel.Data.Sql.Views.ViewManager Class Reference

Inheritance diagram for Deveel.Data.Sql.Views.ViewManager:

Classes
class	ViewTableContainer

Public Member Functions
	ViewManager (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	DefineView (ViewInfo viewInfo)
View	GetView (ObjectName viewName)
bool	ViewExists (ObjectName viewName)
bool	DropView (ObjectName viewName)
ITableContainer	CreateInternalTableInfo ()

Properties
ITransaction	Transaction [get, private set]
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
void	OnCommit (TableCommitInfo obj)
void	InvalidateViewCache ()
void	Dispose (bool disposing)
ITable	FindViewEntry (ObjectName viewName)
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...
View	GetViewAt (int offset)

Private Attributes
Dictionary< long, ViewInfo >	viewCache
bool	viewTableChanged

Detailed Description

Definition at line 28 of file ViewManager.cs.

Constructor & Destructor Documentation

Deveel.Data.Sql.Views.ViewManager.ViewManager ( ITransaction  transaction )

inline

Definition at line 32 of file ViewManager.cs.

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

            Transaction = transaction;
            viewCache = new Dictionary<long, ViewInfo>();

            transaction.RegisterOnCommit(OnCommit);
        }

Member Function Documentation

bool IObjectManager. Deveel.Data.Sql.Views.ViewManager.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 132 of file ViewManager.cs.

                                                             {
            throw new NotSupportedException();
        }

void Deveel.Data.Sql.Views.ViewManager.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 100 of file ViewManager.cs.

                             {
            var tableInfo = new TableInfo(SystemSchema.ViewTableName);
            tableInfo.AddColumn("schema", PrimitiveTypes.String());
            tableInfo.AddColumn("name", PrimitiveTypes.String());
            tableInfo.AddColumn("query", PrimitiveTypes.String());
            tableInfo.AddColumn("plan", PrimitiveTypes.Binary());

            // TODO: Columns...

            Transaction.CreateTable(tableInfo);
        }

ITableContainer Deveel.Data.Sql.Views.ViewManager.CreateInternalTableInfo ( )

inline

Definition at line 236 of file ViewManager.cs.

                                                         {
            return new ViewTableContainer(this);
        }

void IObjectManager. Deveel.Data.Sql.Views.ViewManager.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 112 of file ViewManager.cs.

                                                              {
            var viewInfo = objInfo as ViewInfo;
            if (viewInfo == null)
                throw new ArgumentException();

            DefineView(viewInfo);
        }

void Deveel.Data.Sql.Views.ViewManager.DefineView ( ViewInfo  viewInfo )

inline

Definition at line 144 of file ViewManager.cs.

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

            var dataTableInfo = viewInfo.TableInfo;
            var viewTable = Transaction.GetMutableTable(SystemSchema.ViewTableName);

            var viewName = dataTableInfo.TableName;
            var query = viewInfo.QueryExpression;
            var viewInfoData = viewInfo.AsBinary();

            // Create the view record
            var rdat = viewTable.NewRow();
            rdat.SetValue(0, dataTableInfo.SchemaName.Name);
            rdat.SetValue(1, dataTableInfo.Name);
            rdat.SetValue(2, query.ToString());
            rdat.SetValue(3, DataObject.Binary(viewInfoData));

            // Find the entry from the view that equals this name
            var t = FindViewEntry(viewName);

            // Delete the entry if it already exists.
            if (t.RowCount == 1) {
                viewTable.Delete(t);
            }

            // Insert the new view entry in the system view table
            viewTable.AddRow(rdat);

            // Notify that this database object has been successfully created.
            Transaction.Registry.RegisterEvent(new ObjectCreatedEvent(viewName, DbObjectType.View));

            // Change to the view table
            viewTableChanged = true;
        }

void Deveel.Data.Sql.Views.ViewManager.Dispose ( )

inline

Definition at line 64 of file ViewManager.cs.

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

void Deveel.Data.Sql.Views.ViewManager.Dispose ( bool  disposing )

inlineprivate

Definition at line 69 of file ViewManager.cs.

                                             {
            Transaction = null;
        }

bool IObjectManager. Deveel.Data.Sql.Views.ViewManager.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 136 of file ViewManager.cs.

                                                           {
            return DropView(objName);
        }

bool Deveel.Data.Sql.Views.ViewManager.DropView ( ObjectName  viewName )

inline

Definition at line 218 of file ViewManager.cs.

                                                  {
            var table = Transaction.GetMutableTable(SystemSchema.ViewTableName);

            var t = FindViewEntry(viewName);

            if (t.RowCount == 0)
                return false;

            table.Delete(t);

            // Notify that this database object has been successfully dropped.
            Transaction.Registry.RegisterEvent(new ObjectDroppedEvent(DbObjectType.View, viewName));

            viewTableChanged = true;

            return true;
        }

ITable Deveel.Data.Sql.Views.ViewManager.FindViewEntry ( ObjectName  viewName )

inlineprivate

Definition at line 77 of file ViewManager.cs.

                                                          {
            var table = Transaction.GetTable(SystemSchema.ViewTableName);

            var schemav = table.GetResolvedColumnName(0);
            var namev = table.GetResolvedColumnName(1);

            using (var session = new SystemSession(Transaction, SystemSchema.Name)) {
                using (var query =session.CreateQuery()) {
                    var t = table.SimpleSelect(query, namev, SqlExpressionType.Equal,
                        SqlExpression.Constant(DataObject.String(viewName.Name)));
                    t = t.ExhaustiveSelect(query,
                        SqlExpression.Equal(SqlExpression.Reference(schemav), SqlExpression.Constant(viewName.ParentName)));

                    // This should be at most 1 row in size
                    if (t.RowCount > 1)
                        throw new ArgumentException(String.Format("Multiple view entries for name '{0}' in the system.", viewName));

                    // Return the entries found.
                    return t;
                }
            }
        }

IDbObject IObjectManager. Deveel.Data.Sql.Views.ViewManager.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 128 of file ViewManager.cs.

                                                               {
            return GetView(objName);
        }

View Deveel.Data.Sql.Views.ViewManager.GetView ( ObjectName  viewName )

inline

Definition at line 180 of file ViewManager.cs.

                                                 {
            var viewTable = Transaction.GetTable(SystemSchema.ViewTableName);
            var e = viewTable.GetEnumerator();
            while (e.MoveNext()) {
                int row = e.Current.RowId.RowNumber;

                var cSchema = viewTable.GetValue(row, 0).Value.ToString();
                var cName = viewTable.GetValue(row, 1).Value.ToString();

                if (viewName.ParentName.Equals(cSchema) &&
                    viewName.Name.Equals(cName)) {

                    ViewInfo viewInfo;
                    if (!viewCache.TryGetValue(row, out viewInfo)) { 
                        var blob = (SqlBinary)viewTable.GetValue(row, 3).Value;
                        using (var session = new SystemSession(Transaction, SystemSchema.Name)) {
                            using (var context = session.CreateQuery()) {

                                viewInfo = ViewInfo.Deserialize(blob.GetInput());
                            }
                        }

                        viewCache[row] = viewInfo;

                    }

                    return new View(viewInfo);
                }

            }

            return null;
        }

View Deveel.Data.Sql.Views.ViewManager.GetViewAt ( int  offset )

inlineprivate

Definition at line 240 of file ViewManager.cs.

                                           {
            var table = Transaction.GetTable(SystemSchema.ViewTableName);
            if (table == null)
                throw new DatabaseSystemException(String.Format("System table '{0}' was not defined.", SystemSchema.ViewTableName));

            var e = table.GetEnumerator();
            int i = 0;
            while (e.MoveNext()) {
                var row = e.Current.RowId.RowNumber;

                if (i == offset) {
                    ViewInfo viewInfo;
                    if (!viewCache.TryGetValue(row, out viewInfo)) {
                        var binary = (ISqlBinary)table.GetValue(row, 3).Value;

                        using (var session = new SystemSession(Transaction, SystemSchema.Name)) {
                            using (var context = session.CreateQuery()) {
                                viewInfo = ViewInfo.Deserialize(binary.GetInput());
                            }
                        }

                        viewCache[row] = viewInfo;
                    }

                    return new View(viewInfo);
                }

                ++i;
            }

            throw new ArgumentOutOfRangeException("offset");
        }

void Deveel.Data.Sql.Views.ViewManager.InvalidateViewCache ( )

inlineprivate

Definition at line 58 of file ViewManager.cs.

                                           {
            viewCache.Clear();
        }

bool IObjectManager. Deveel.Data.Sql.Views.ViewManager.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 124 of file ViewManager.cs.

                                                             {
            return ViewExists(objName);
        }

void Deveel.Data.Sql.Views.ViewManager.OnCommit ( TableCommitInfo  obj )

inlineprivate

Definition at line 42 of file ViewManager.cs.

                                                   {
            if (!obj.TableName.Equals(SystemSchema.ViewTableName))
                return;

            // If there were changed then invalidate the cache
            if (viewTableChanged) {
                InvalidateViewCache();
                viewTableChanged = false;
            } else if ((obj.AddedRows != null && obj.AddedRows.Any()) ||
                     (obj.RemovedRows != null && obj.RemovedRows.Any())) {
                // Otherwise, if there were committed added or removed changes also
                // invalidate the cache,
                InvalidateViewCache();
            }
        }

bool IObjectManager. Deveel.Data.Sql.Views.ViewManager.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 120 of file ViewManager.cs.

                                                                 {
            return ViewExists(objName);
        }

ObjectName Deveel.Data.Sql.Views.ViewManager.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 140 of file ViewManager.cs.

                                                                           {
            throw new NotImplementedException();
        }

bool Deveel.Data.Sql.Views.ViewManager.ViewExists ( ObjectName  viewName )

inline

Definition at line 214 of file ViewManager.cs.

                                                    {
            return FindViewEntry(viewName).RowCount > 0;
        }

Member Data Documentation

Dictionary<long, ViewInfo> Deveel.Data.Sql.Views.ViewManager.viewCache

private

Definition at line 29 of file ViewManager.cs.

bool Deveel.Data.Sql.Views.ViewManager.viewTableChanged

private

Definition at line 30 of file ViewManager.cs.

Property Documentation

DbObjectType IObjectManager. Deveel.Data.Sql.Views.ViewManager.ObjectType

getprivate

Definition at line 73 of file ViewManager.cs.

ITransaction Deveel.Data.Sql.Views.ViewManager.Transaction

getprivate set

Definition at line 62 of file ViewManager.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.Views/ViewManager.cs