Ntp.Data.Schema.VersionController Class Reference

Collaboration diagram for Ntp.Data.Schema.VersionController:

Public Member Functions
	VersionController (ISqlFactory factory, LogBase log)
int	FindCurrentVersion ()
void	SetCurrentVersion (IVersionChanges version)

Private Member Functions
bool	CheckTable ()
void	CreateTable ()
void	InsertTable ()
int	SelectVersion ()

Private Attributes
const string	CreateSql = "CREATE TABLE version (number INT NOT NULL PRIMARY KEY);"
readonly ISqlFactory	factory
const string	InsertSql = "INSERT INTO version (number) VALUES (0);"
readonly LogBase	log
const string	SelectSql = "SELECT number FROM version;"
const string	UpdateSql = "UPDATE version SET number=@number;"

Detailed Description

Definition at line 30 of file VersionController.cs.

Constructor & Destructor Documentation

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

inline

Definition at line 32 of file VersionController.cs.

References factory.

        {
            this.factory = factory;
            this.log = log;
        }

Member Function Documentation

bool Ntp.Data.Schema.VersionController.CheckTable ( )

inlineprivate

Definition at line 91 of file VersionController.cs.

References e.

        {
            IDbConnection connection = null;

            try
            {
                connection = factory.CreateConnection();
                connection.Open();
                var command = factory.CreateCommand();
                command.Connection = connection;
                command.CommandText = factory.PrepareCheckTableSql("version");
                command.Prepare();
                log.SqlExecute(command.CommandText);
                var reader = command.ExecuteReader();
                return reader.Read();
            }
            catch (Exception e)
            {
                log.VersionTableCreateError(e);
                return false;
            }
            finally
            {
                if (connection != null && connection.State == ConnectionState.Open)
                    connection.Close();
            }
        }

void Ntp.Data.Schema.VersionController.CreateTable ( )

inlineprivate

Definition at line 119 of file VersionController.cs.

References e.

        {
            IDbConnection connection = null;

            try
            {
                connection = factory.CreateConnection();
                connection.Open();
                var command = factory.CreateCommand();
                command.Connection = connection;
                command.CommandText = CreateSql;
                command.Prepare();
                log.SqlExecute(command.CommandText);
                command.ExecuteNonQuery();
            }
            catch (Exception e)
            {
                log.VersionTableCreateError(e);
            }
            finally
            {
                if (connection != null && connection.State == ConnectionState.Open)
                    connection.Close();
            }

            log.VersionTableCreated();
        }

int Ntp.Data.Schema.VersionController.FindCurrentVersion ( )

inline

Definition at line 45 of file VersionController.cs.

        {
            if (CheckTable())
                return SelectVersion();

            CreateTable();
            InsertTable();
            return -1;
        }

void Ntp.Data.Schema.VersionController.InsertTable ( )

inlineprivate

Definition at line 147 of file VersionController.cs.

References e.

        {
            IDbConnection connection = null;

            try
            {
                connection = factory.CreateConnection();
                connection.Open();
                var command = factory.CreateCommand();
                command.Connection = connection;
                command.CommandText = InsertSql;
                command.Prepare();
                log.SqlExecute(command.CommandText);
                command.ExecuteNonQuery();
            }
            catch (Exception e)
            {
                log.VersionTableInsertError(e);
            }
            finally
            {
                if (connection != null && connection.State == ConnectionState.Open)
                    connection.Close();
            }
        }

int Ntp.Data.Schema.VersionController.SelectVersion ( )

inlineprivate

Definition at line 173 of file VersionController.cs.

References e.

        {
            IDbConnection connection = null;

            try
            {
                connection = factory.CreateConnection();
                connection.Open();
                var command = factory.CreateCommand();
                command.Connection = connection;
                command.CommandText = SelectSql;
                command.Prepare();
                log.SqlExecute(command.CommandText);
                var result = command.ExecuteScalar();
                return Convert.ToInt32(result);
            }
            catch (Exception e)
            {
                log.VersionTableFetchError(e);
                return -1;
            }
            finally
            {
                if (connection != null && connection.State == ConnectionState.Open)
                    connection.Close();
            }
        }

void Ntp.Data.Schema.VersionController.SetCurrentVersion ( IVersionChanges  version )

inline

Definition at line 55 of file VersionController.cs.

References e, Ntp.Data.Schema.IVersionChanges.VersionNumber, and Ntp.Data.Schema.IVersionChanges.VersionText.

        {
            if (version == null)
            {
                log.VersionTableParamError();
                return;
            }

            IDbConnection connection = null;

            try
            {
                connection = factory.CreateConnection();
                connection.Open();
                var command = factory.CreateCommand();
                command.Connection = connection;
                command.CommandText = UpdateSql;
                command.Parameters.Add(factory.CreateParameter("@number", version.VersionNumber));
                command.Prepare();
                log.SqlExecute(command.CommandText, command.Parameters);
                command.ExecuteNonQuery();
            }
            catch (Exception e)
            {
                log.VersionTableUpdateError(e);
            }
            finally
            {
                if (connection != null && connection.State == ConnectionState.Open)
                    connection.Close();
            }

            log.SchemaUpdated(version.VersionText);
        }

Member Data Documentation

const string Ntp.Data.Schema.VersionController.CreateSql = "CREATE TABLE version (number INT NOT NULL PRIMARY KEY);"

private

Definition at line 38 of file VersionController.cs.

readonly ISqlFactory Ntp.Data.Schema.VersionController.factory

private

Definition at line 42 of file VersionController.cs.

const string Ntp.Data.Schema.VersionController.InsertSql = "INSERT INTO version (number) VALUES (0);"

private

Definition at line 41 of file VersionController.cs.

readonly LogBase Ntp.Data.Schema.VersionController.log

private

Definition at line 43 of file VersionController.cs.

const string Ntp.Data.Schema.VersionController.SelectSql = "SELECT number FROM version;"

private

Definition at line 39 of file VersionController.cs.

const string Ntp.Data.Schema.VersionController.UpdateSql = "UPDATE version SET number=@number;"

private

Definition at line 40 of file VersionController.cs.

---

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

• Ntp.Data/Schema/VersionController.cs