Deveel.Data.TableEventRegistry Class Reference

Inheritance diagram for Deveel.Data.TableEventRegistry:

Public Member Functions
IEnumerator< ITableEvent >	GetEnumerator ()
ITableEvent	GetEvent (int index)

Package Functions
	TableEventRegistry (TableSource tableSource)
void	Rollback (int count)
void	Register (ITableEvent tableEvent)
void	TestCommitClash (TableInfo tableInfo, TableEventRegistry journal)

Properties
TableSource	TableSource [get, private set]
int	TableId [get]
long	CommitId [get, set]
IEnumerable< int >	AddedRows [get]
IEnumerable< int >	RemovedRows [get]
int	EventCount [get]

Private Member Functions
IEnumerator IEnumerable.	GetEnumerator ()

Private Attributes
readonly List< ITableEvent >	events

Detailed Description

Definition at line 27 of file TableEventRegistry.cs.

Constructor & Destructor Documentation

Deveel.Data.TableEventRegistry.TableEventRegistry ( TableSource  tableSource )

inlinepackage

Definition at line 30 of file TableEventRegistry.cs.

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

            TableSource = tableSource;
            CommitId = -1;

            events = new List<ITableEvent>();
        }

Member Function Documentation

IEnumerator<ITableEvent> Deveel.Data.TableEventRegistry.GetEnumerator ( )

inline

Definition at line 145 of file TableEventRegistry.cs.

                                                        {
            lock (this) {
                return events.GetEnumerator();
            }
        }

IEnumerator IEnumerable. Deveel.Data.TableEventRegistry.GetEnumerator ( )

inlineprivate

Definition at line 151 of file TableEventRegistry.cs.

                                                {
            return GetEnumerator();
        }

ITableEvent Deveel.Data.TableEventRegistry.GetEvent ( int  index )

inline

Definition at line 155 of file TableEventRegistry.cs.

                                               {
            lock (this) {
                if (index < 0 || index >= events.Count)
                    throw new ArgumentOutOfRangeException("index");

                return events[index];
            }
        }

void Deveel.Data.TableEventRegistry.Register ( ITableEvent  tableEvent )

inlinepackage

Definition at line 120 of file TableEventRegistry.cs.

                                                       {
            lock (this) {
                events.Add(tableEvent);
            }
        }

void Deveel.Data.TableEventRegistry.Rollback ( int  count )

inlinepackage

Definition at line 95 of file TableEventRegistry.cs.

                                          {
            lock (this) {
                if (count > events.Count)
                    throw new Exception("Trying to rollback more events than are in the registry.");

                List<int> toAdd = new List<int>();

                // Find all entries and added new rows to the table
                foreach (var tableEvent in events.OfType<TableRowEvent>()) {
                    if (tableEvent.EventType == TableRowEventType.Add ||
                        tableEvent.EventType == TableRowEventType.UpdateAdd)
                        toAdd.Add(tableEvent.RowNumber);
                }

                events.RemoveRange(0, count);

                // Mark all added entries to deleted.
                for (int i = 0; i < toAdd.Count; ++i) {
                    events.Add(new TableRowEvent(TableId, toAdd[i], TableRowEventType.Add));
                    events.Add(new TableRowEvent(TableId, toAdd[i], TableRowEventType.Remove));
                }

            }
        }

void Deveel.Data.TableEventRegistry.TestCommitClash ( TableInfo  tableInfo, TableEventRegistry  journal  )

inlinepackage

Definition at line 126 of file TableEventRegistry.cs.

                                                                                       {
            lock (this) {
                // Very nasty search here...
                foreach (var rowEvent in events.OfType<TableRowEvent>()) {
                    if (rowEvent.EventType == TableRowEventType.Remove) {
                        var rowNum = rowEvent.RowNumber;
                        foreach (var otherRowEvent in journal.events.OfType<TableRowEvent>()) {
                            if (otherRowEvent.RowNumber == rowNum &&
                                otherRowEvent.EventType == TableRowEventType.Remove) {
                                throw new TransactionException(TransactionErrorCodes.RowRemoveClash,
                                    String.Format("Concurrent Serializable Transaction Conflict(1): " +
                                    "Current row remove clash ( row: {0}, table: {1})", rowNum, tableInfo.TableName));
                            }
                        }
                    }
                }               
            }
        }

Member Data Documentation

readonly List<ITableEvent> Deveel.Data.TableEventRegistry.events

private

Definition at line 28 of file TableEventRegistry.cs.

Property Documentation

IEnumerable<int> Deveel.Data.TableEventRegistry.AddedRows

get

Definition at line 48 of file TableEventRegistry.cs.

long Deveel.Data.TableEventRegistry.CommitId

getset

Definition at line 46 of file TableEventRegistry.cs.

int Deveel.Data.TableEventRegistry.EventCount

get

Definition at line 87 of file TableEventRegistry.cs.

IEnumerable<int> Deveel.Data.TableEventRegistry.RemovedRows

get

Definition at line 71 of file TableEventRegistry.cs.

int Deveel.Data.TableEventRegistry.TableId

get

Definition at line 42 of file TableEventRegistry.cs.

TableSource Deveel.Data.TableEventRegistry.TableSource

getprivate setpackage

Definition at line 40 of file TableEventRegistry.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.Tables/TableEventRegistry.cs