OR/M mapper for tables with a large amount of rows. More...

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

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

Protected Member Functions
	FilteredSqlDatabaseMapper (LogBase log)

override string	PrepareSql (string sql)

Protected Member Functions inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >
	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)

abstract void	ReadContent ()

void	RemoveItem (T item)

abstract void	Update (T item)

Protected Member Functions inherited from Ntp.Data.DataMapper< T >
	DataMapper (LogBase log)

Properties
Host	FilterHost `[get, set]`
	Gets or sets the host More...

Peer	FilterPeer `[get, set]`
	Gets or sets the peer to use when extracting data. More...

DateTime	FilterTime `[get, set]`
	Gets or sets the time to use when extracting data. Only readings with a timestamp later than FilterTime gets extracted. More...

Properties inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >
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]`

Additional Inherited Members
Public Member Functions inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >
void	CheckTable ()

override IEnumerator< T >	GetEnumerator ()
	Read all data from table in a sequential manner. More...

void	Save (T item)

Protected Attributes inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >
IEnumerable< T >	Content => items.Values

readonly object	MapperLocker = new object()

IDataReader	Reader

Detailed Description

OR/M mapper for tables with a large amount of rows.

Type Constraints

T

:

PersistentObject

Definition at line 32 of file FilteredSqlDatabaseMapper.cs.

Constructor & Destructor Documentation

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

inlineprotected

Definition at line 35 of file FilteredSqlDatabaseMapper.cs.

             : base(log)
         {
         }

Member Function Documentation

override string Ntp.Analyzer.Data.Sql.FilteredSqlDatabaseMapper< T >.PrepareSql ( string sql )

inlineprotectedvirtual

Reimplemented from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< T >.

Definition at line 59 of file FilteredSqlDatabaseMapper.cs.

         {
             string preparedSql = base.PrepareSql(sql).Trim();
 
             if (FilterTime == null && FilterHost == null && FilterPeer == null)
                 return preparedSql;
 
             bool filterAdded = false;
 
             preparedSql += " WHERE ";
 
             if (FilterTime != null)
             {
                 var time = FilterTime.Value.ToUniversalTime();
                 var datePart = SqlDatabaseFactory.Instance.DateAddMinutes("time", "zone");
                 preparedSql += $"{datePart} > \'{time.ToString("yyyy-MM-dd HH:mm:ss")}\'";
                 filterAdded = true;
             }
 
             if (FilterHost != null)
             {
                 if (filterAdded)
                 {
                     preparedSql += " AND ";
                 }
 
                 preparedSql += $"hostId = {FilterHost.Id}";
                 filterAdded = true;
             }
 
             if (FilterPeer == null)
                 return preparedSql;
 
             if (filterAdded)
             {
                 preparedSql += " AND ";
             }
 
             preparedSql += $"peerId = {FilterPeer.Id}";
 
             return preparedSql;
         }