Ntp.Data.Schema.DatabaseUpdater Class Reference

Inheritance diagram for Ntp.Data.Schema.DatabaseUpdater:

Collaboration diagram for Ntp.Data.Schema.DatabaseUpdater:

Public Member Functions
	DatabaseUpdater (ISqlFactory factory, LogBase log)
void	Add (IVersionChanges item)
void	ApplyChanges ()
bool	CheckLatestVersion ()
IEnumerator< IVersionChanges >	GetEnumerator ()

Private Member Functions
IEnumerator IEnumerable.	GetEnumerator ()

Private Attributes
readonly List< IVersionChanges >	changes
readonly ISqlFactory	factory
readonly LogBase	log

Detailed Description

Definition at line 33 of file DatabaseUpdater.cs.

Constructor & Destructor Documentation

Ntp.Data.Schema.DatabaseUpdater.DatabaseUpdater ( ISqlFactory  factory, LogBase  log  )

inline

Definition at line 35 of file DatabaseUpdater.cs.

References factory.

        {
            this.factory = factory;
            this.log = log;
            changes = new List<IVersionChanges>();
        }

Member Function Documentation

void Ntp.Data.Schema.DatabaseUpdater.Add ( IVersionChanges  item )

inline

Definition at line 56 of file DatabaseUpdater.cs.

        {
            changes.Add(item);
        }

void Ntp.Data.Schema.DatabaseUpdater.ApplyChanges ( )

inline

Definition at line 62 of file DatabaseUpdater.cs.

References c, e, and version.

        {
            var controller = new VersionController(factory, log);
            int databaseVersion = controller.FindCurrentVersion();

            if (databaseVersion <= 0)
            {
                var last = changes.OrderBy(c => c.VersionNumber).LastOrDefault();
                if (last != null)
                    controller.SetCurrentVersion(last);

                return;
            }

            IVersionChanges lastVersion = null;
            var versionChanges = changes.
                OrderBy(c => c.VersionNumber).
                Where(c => c.VersionNumber > databaseVersion);

            var changeList = versionChanges.ToList();
            if (changeList.Count == 0)
            {
                log.SchemaUpToDate();
                return;
            }

            log.ApplySchemaChanges();

            var connection = factory.CreateConnection();
            connection.Open();

            foreach (var version in changeList)
            {
                var transaction = connection.BeginTransaction();
                try
                {
                    foreach (var change in version)
                    {
                        var command = factory.CreateCommand();
                        command.Connection = connection;
                        command.CommandText = change.Sql;
                        command.Transaction = transaction;
                        command.Prepare();
                        log.SqlExecute(command.CommandText);
                        command.ExecuteNonQuery();
                    }
                    transaction.Commit();
                }
                catch (Exception e)
                {
                    log.SchemaUpdateError(e);
                    transaction.Rollback();
                    return;
                }

                lastVersion = version;
                log.SchemaChangesApplied(lastVersion.VersionText);
            }

            if (connection.State == ConnectionState.Open)
                connection.Close();

            controller.SetCurrentVersion(lastVersion);
        }

bool Ntp.Data.Schema.DatabaseUpdater.CheckLatestVersion ( )

inline

Definition at line 127 of file DatabaseUpdater.cs.

References c.

        {
            var controller = new VersionController(factory, log);
            int databaseVersion = controller.FindCurrentVersion();
            var latest = changes.OrderBy(c => c.VersionNumber).Last();

            if (databaseVersion == -1)
            {
                controller.SetCurrentVersion(latest);
                return true;
            }

            if (databaseVersion == latest.VersionNumber)
                return true;

            log.SchemaVersionError(databaseVersion, latest.VersionNumber);
            return false;
        }

IEnumerator IEnumerable. Ntp.Data.Schema.DatabaseUpdater.GetEnumerator ( )

inlineprivate

Definition at line 46 of file DatabaseUpdater.cs.

        {
            return changes.GetEnumerator();
        }

IEnumerator<IVersionChanges> Ntp.Data.Schema.DatabaseUpdater.GetEnumerator ( )

inline

Definition at line 51 of file DatabaseUpdater.cs.

        {
            return changes.GetEnumerator();
        }

Member Data Documentation

readonly List<IVersionChanges> Ntp.Data.Schema.DatabaseUpdater.changes

private

Definition at line 42 of file DatabaseUpdater.cs.

readonly ISqlFactory Ntp.Data.Schema.DatabaseUpdater.factory

private

Definition at line 43 of file DatabaseUpdater.cs.

readonly LogBase Ntp.Data.Schema.DatabaseUpdater.log

private

Definition at line 44 of file DatabaseUpdater.cs.

---

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

• Ntp.Data/Schema/DatabaseUpdater.cs