Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T > Class Template Reference

Base class for OR/M mappers. Can be used for mapping objects stored in SQL databases. More...

Inheritance diagram for Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >:

Collaboration diagram for Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >:

Public Member Functions
void	CheckTable ()
override IEnumerator< T >	GetEnumerator ()
	Read all data from table in a sequential manner. More...
void	Save (T item)

Protected Member Functions
	SqlDatabaseMapper (LogBase log)
void	AddItem (T item)
void	Close ()
IDbDataParameter	CreateParameter (string name, object value)
virtual T	FetchExternal (int id)
abstract void	Insert (T item)
void	Open ()
string	PrepareInsertSql (string sql)
virtual string	PrepareSql (string sql)
abstract void	ReadContent ()
void	RemoveItem (T item)
abstract void	Update (T item)
Protected Member Functions inherited from Ntp.Data.DataMapper< T >
	DataMapper (LogBase log)

Protected Attributes
IEnumerable< T >	Content => items.Values
readonly object	MapperLocker = new object()
IDataReader	Reader

Properties
IDbCommand	Command [get, private set]
abstract string	CreateSql [get]
abstract string	TableName [get]
T	this[int id] [get]
abstract bool	UseCache [get]
Properties inherited from Ntp.Data.DataMapper< T >
LogBase	Log [get]

Private Member Functions
void	FetchTable ()

Private Attributes
IDbConnection	connection
readonly Dictionary< int, T >	items = new Dictionary<int, T>()
bool	tableFetched

Static Private Attributes
static readonly AutoResetEvent	InsertEvent = new AutoResetEvent(true)

Detailed Description

Base class for OR/M mappers. Can be used for mapping objects stored in SQL databases.

Type Constraints

T

:

PersistentObject

Definition at line 40 of file SqlDatabaseMapper.cs.

Constructor & Destructor Documentation

Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.SqlDatabaseMapper ( LogBase  log )

inlineprotected

Definition at line 43 of file SqlDatabaseMapper.cs.

            : base(log)
        {
        }

Member Function Documentation

void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.AddItem ( T  item )

inlineprotected

Definition at line 150 of file SqlDatabaseMapper.cs.

        {
            lock (items)
            {
                items.Add(item.Id, item);
            }
        }

void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.CheckTable ( )

inline

Implements Ntp.Data.ITableInitializer.

Definition at line 87 of file SqlDatabaseMapper.cs.

Referenced by Ntp.Analyzer.Data.DatabaseInitializer.CreateTables().

        {
            string sql = SqlDatabaseFactory.Instance.PrepareCheckTableSql(TableName);
            bool exists;

            try
            {
                Open();
                Command.CommandText = sql;
                Log.SqlExecute(Command.CommandText);
                Reader = Command.ExecuteReader();
                exists = Reader.Read();
            }
            finally
            {
                Close();
            }

            if (exists)
            {
                Log.TableExists(TableName);
                return;
            }

            Log.CreateTable(TableName);

            try
            {
                Open();
                Command.CommandText = SqlDatabaseFactory.Instance.PrepareCreateTableSql(CreateSql);
                Log.SqlExecute(Command.CommandText);
                Command.Prepare();
                Command.ExecuteNonQuery();
            }
            finally
            {
                Close();
            }
        }

Here is the caller graph for this function:

void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.Close ( )

inlineprotected

Definition at line 158 of file SqlDatabaseMapper.cs.

        {
            connection?.Close();
            connection = null;
            InsertEvent.Set();
        }

IDbDataParameter Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.CreateParameter ( string  name, object  value  )

inlineprotected

Definition at line 165 of file SqlDatabaseMapper.cs.

        {
            return SqlDatabaseFactory.Instance.CreateParameter(name, value ?? DBNull.Value);
        }

virtual T Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.FetchExternal ( int  id )

inlineprotectedvirtual

Reimplemented in Ntp.Analyzer.Data.Sql.TimeServerDatabaseMapper.

Definition at line 170 of file SqlDatabaseMapper.cs.

        {
            return null;
        }

void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.FetchTable ( )

inlineprivate

Definition at line 224 of file SqlDatabaseMapper.cs.

        {
            lock (MapperLocker)
            {
                if (tableFetched)
                    return;

                ReadContent();
                tableFetched = true;
            }
        }

override IEnumerator<T> Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.GetEnumerator ( )

inlinevirtual

Read all data from table in a sequential manner.

Returns

The enumerator.

Implements Ntp.Data.DataMapper< T >.

Definition at line 127 of file SqlDatabaseMapper.cs.

        {
            FetchTable();
            return Content.ToList().GetEnumerator();
        }

abstract void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.Insert ( T  item )

protectedpure virtual

void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.Open ( )

inlineprotected

Definition at line 177 of file SqlDatabaseMapper.cs.

        {
            InsertEvent.WaitOne();

            if (Reader != null && !Reader.IsClosed)
            {
                Reader.Close();
                Reader = null;
            }

            // TODO: Implement monitoring of database link
            if (connection == null)
            {
                connection = SqlDatabaseFactory.Instance.CreateConnection();
            }

            if (connection.State == ConnectionState.Closed)
            {
                connection.Open();
            }

            Command = SqlDatabaseFactory.Instance.CreateCommand();
            Command.Connection = connection;
        }

string Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.PrepareInsertSql ( string  sql )

inlineprotected

Definition at line 202 of file SqlDatabaseMapper.cs.

        {
            return SqlDatabaseFactory.Instance.PrepareInsertSql(sql);
        }

virtual string Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.PrepareSql ( string  sql )

inlineprotectedvirtual

Reimplemented in Ntp.Analyzer.Data.Sql.FilteredSqlDatabaseMapper< T >.

Definition at line 207 of file SqlDatabaseMapper.cs.

        {
            return SqlDatabaseFactory.Instance.PrepareSql(sql);
        }

abstract void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.ReadContent ( )

protectedpure virtual

Implemented in Ntp.Analyzer.Data.Sql.AssociationEntryMapper, Ntp.Analyzer.Data.Sql.TimeServerDatabaseMapper, Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper, Ntp.Analyzer.Data.Sql.PeerDatabaseMapper, Ntp.Analyzer.Data.Sql.HostDatabaseMapper, and Ntp.Analyzer.Data.Sql.ReadingBulkMapper.

void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.RemoveItem ( T  item )

inlineprotected

Definition at line 214 of file SqlDatabaseMapper.cs.

        {
            lock (items)
            {
                items.Remove(item.Id);
            }
        }

void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.Save ( T  item )

inline

Definition at line 133 of file SqlDatabaseMapper.cs.

        {
            if (item.NewObject)
            {
                Insert(item);

                if (UseCache)
                {
                    AddItem(item);
                }
            }
            else
            {
                Update(item);
            }
        }

abstract void Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.Update ( T  item )

protectedpure virtual

Member Data Documentation

IDbConnection Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.connection

private

Definition at line 52 of file SqlDatabaseMapper.cs.

IEnumerable<T> Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.Content => items.Values

protected

Definition at line 56 of file SqlDatabaseMapper.cs.

readonly AutoResetEvent Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.InsertEvent = new AutoResetEvent(true)

staticprivate

Definition at line 49 of file SqlDatabaseMapper.cs.

readonly Dictionary<int, T> Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.items = new Dictionary<int, T>()

private

Definition at line 50 of file SqlDatabaseMapper.cs.

readonly object Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.MapperLocker = new object()

protected

Definition at line 51 of file SqlDatabaseMapper.cs.

IDataReader Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.Reader

protected

Definition at line 53 of file SqlDatabaseMapper.cs.

bool Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.tableFetched

private

Definition at line 54 of file SqlDatabaseMapper.cs.

Property Documentation

IDbCommand Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.Command

getprivate setprotected

Definition at line 58 of file SqlDatabaseMapper.cs.

abstract string Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.CreateSql

getprotected

Definition at line 62 of file SqlDatabaseMapper.cs.

abstract string Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.TableName

getprotected

Definition at line 60 of file SqlDatabaseMapper.cs.

T Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.this[int id]

get

Definition at line 67 of file SqlDatabaseMapper.cs.

abstract bool Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.UseCache

getprotected

Definition at line 64 of file SqlDatabaseMapper.cs.

---

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

• Ntp.Analyzer.Data/Sql/SqlDatabaseMapper.cs