Deveel.Data.Sql.Tables.MutableTableExtensions Class Reference

Static Public Member Functions
static bool	RemoveRow (this IMutableTable table, int rowIndex)
static void	DeleteRows (this IMutableTable table, IEnumerable< int > rows)
static Row	NewRow (this IMutableTable table)
	Creates a new row that is compatible with the table context, ready to be populated and added. More...
static int	Delete (this IMutableTable table, ITable t)
static int	Delete (this IMutableTable table, ITable other, int limit)
static bool	Delete (this IMutableTable table, int columnOffset, DataObject value)
static int	Update (this IMutableTable mutableTable, IQuery context, ITable table, IEnumerable< SqlAssignExpression > assignList, int limit)

Detailed Description

Definition at line 25 of file MutableTableExtensions.cs.

Member Function Documentation

static int Deveel.Data.Sql.Tables.MutableTableExtensions.Delete ( this IMutableTable  table, ITable  t  )

inlinestatic

Definition at line 59 of file MutableTableExtensions.cs.

                                                                     {
            return Delete(table, t, -1);
        }

static int Deveel.Data.Sql.Tables.MutableTableExtensions.Delete ( this IMutableTable  table, ITable  other, int  limit  )

inlinestatic

Definition at line 63 of file MutableTableExtensions.cs.

                                                                                    {
            List<int> rowSet = new List<int>(other.RowCount);
            var e = other.GetEnumerator();
            while (e.MoveNext()) {
                rowSet.Add(e.Current.RowId.RowNumber);
            }

            // HACKY: Find the first column of this table in the search table.  This
            //   will allow us to generate a row set of only the rows in the search
            //   table.
            int firstColumn = other.IndexOfColumn(table.GetResolvedColumnName(0));

            if (firstColumn == -1)
                throw new DatabaseSystemException("Search table does not contain any reference to table being deleted from");

            // Generate a row set that is in this tables domain.
            var rowsToDelete = other.ResolveRows(firstColumn, rowSet, table).ToList();

            // row_set may contain duplicate row indices, therefore we must sort so
            // any duplicates are grouped and therefore easier to find.
            rowSet.Sort();

            // If limit less than zero then limit is whole set.
            if (limit < 0)
                limit = Int32.MaxValue;

            // Remove each row in row set in turn.  Make sure we don't remove the
            // same row index twice.
            int len = System.Math.Min(rowsToDelete.Count, limit);
            int lastRemoved = -1;
            int removeCount = 0;
            for (int i = 0; i < len; ++i) {
                int toRemove = rowsToDelete[i];
                if (toRemove < lastRemoved)
                    throw new DatabaseSystemException("Internal error: row sorting error or row set not in the range > 0");

                if (toRemove != lastRemoved) {
                    table.RemoveRow(toRemove);
                    lastRemoved = toRemove;
                    ++removeCount;
                }
            }

            if (removeCount > 0)
                // Perform a referential integrity check on any changes to the table.
                table.AssertConstraints();

            return removeCount;
        }

static bool Deveel.Data.Sql.Tables.MutableTableExtensions.Delete ( this IMutableTable  table, int  columnOffset, DataObject  value  )

inlinestatic

Definition at line 113 of file MutableTableExtensions.cs.

                                                                                                {
            var list = table.SelectRowsEqual(columnOffset, value).ToArray();
            if (list.Length == 0)
                return false;

            return table.RemoveRow(list[0]);
        }

static void Deveel.Data.Sql.Tables.MutableTableExtensions.DeleteRows ( this IMutableTable  table, IEnumerable< int >  rows  )

inlinestatic

Definition at line 30 of file MutableTableExtensions.cs.

                                                                                       {
            foreach (var row in rows) {
                table.RemoveRow(row);
            }
        }

static Row Deveel.Data.Sql.Tables.MutableTableExtensions.NewRow ( this IMutableTable  table )

inlinestatic

Creates a new row that is compatible with the table context, ready to be populated and added.

When this method is called, a new RowId is generated and persisted: when a subsequent call to this method will be issued, another new row identifier will be generated, even if the row was not persisted into the table.

Returns

Returns an instance of Row that belongs to this table and can be added or updated through IMutableTable.AddRow or IMutableTable.UpdateRow method calls.

Definition at line 55 of file MutableTableExtensions.cs.

                                                           {
            return new Row(table);
        }

static bool Deveel.Data.Sql.Tables.MutableTableExtensions.RemoveRow ( this IMutableTable  table, int  rowIndex  )

inlinestatic

Definition at line 26 of file MutableTableExtensions.cs.

                                                                             {
            return table.RemoveRow(new RowId(table.TableInfo.Id, rowIndex));
        }

static int Deveel.Data.Sql.Tables.MutableTableExtensions.Update ( this IMutableTable  mutableTable, IQuery  context, ITable  table, IEnumerable< SqlAssignExpression >  assignList, int  limit  )

inlinestatic

Definition at line 121 of file MutableTableExtensions.cs.

                                                                    {

            // Get the rows from the input table.
            var rowSet = new List<int>();
            var e = table.GetEnumerator();
            while (e.MoveNext()) {
                rowSet.Add(e.Current.RowId.RowNumber);
            }

            // HACKY: Find the first column of this table in the search table.  This
            //   will allow us to generate a row set of only the rows in the search
            //   table.
            int firstColumn = table.FindColumn(mutableTable.GetResolvedColumnName(0));
            if (firstColumn == -1)
                throw new InvalidOperationException("Search table does not contain any " +
                                            "reference to table being updated from");

            // Convert the row_set to this table's domain.
            rowSet = table.ResolveRows(firstColumn, rowSet, mutableTable).ToList();

            // NOTE: Assume there's no duplicate rows.

            // If limit less than zero then limit is whole set.
            if (limit < 0)
                limit = Int32.MaxValue;

            // Update each row in row set in turn up to the limit.
            int len = System.Math.Min(rowSet.Count, limit);

            int updateCount = 0;
            for (int i = 0; i < len; ++i) {
                int toUpdate = rowSet[i];

                // Make a row object from this row (plus keep the original intact
                // in case we need to roll back to it).
                var row = mutableTable.GetRow(toUpdate);
                row.SetFromTable();

                // Run each assignment on the row.
                foreach (var assignment in assignList) {
                    row.EvaluateAssignment(assignment, context);
                }

                // Update the row
                mutableTable.UpdateRow(row);

                ++updateCount;
            }

            if (updateCount > 0)
                // Perform a referential integrity check on any changes to the table.
                mutableTable.AssertConstraints();

            return updateCount;
        }

---

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

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