OR/M mapper for table peerActivity. More...

Inheritance diagram for Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper:

Collaboration diagram for Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper:

[legend]

Protected Member Functions
override void	Insert (PeerActivity item)

override void	ReadContent ()

override void	Update (PeerActivity item)

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

void	RemoveItem (T item)

abstract void	Update (T item)

Protected Attributes
override string	CreateSql

override string	TableName => "peerActivity"

override bool	UseCache => true

Protected Attributes inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< PeerActivity >
IEnumerable< T >	Content

readonly object	MapperLocker

IDataReader	Reader

Package Functions
	PeerActivityDatabaseMapper (HostDatabaseMapper hostMapper, PeerDatabaseMapper peerMapper, LogBase log)

Private Attributes
readonly HostDatabaseMapper	hostMapper

const string	InsertSql

readonly PeerDatabaseMapper	peerMapper

const string	SelectSql

const string	UpdateSql

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

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

void	Save (T item)

Properties inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< PeerActivity >
IDbCommand	Command `[get, private set]`

abstract string	CreateSql `[get]`

abstract string	TableName `[get]`

T	this[int id] `[get]`

abstract bool	UseCache `[get]`

Detailed Description

OR/M mapper for table peerActivity.

Definition at line 34 of file PeerActivityDatabaseMapper.cs.

Constructor & Destructor Documentation

Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.PeerActivityDatabaseMapper	(	HostDatabaseMapper	hostMapper,
		PeerDatabaseMapper	peerMapper,
		LogBase	log
	)

inlinepackage

Definition at line 36 of file PeerActivityDatabaseMapper.cs.

             : base(log)
         {
             this.hostMapper = hostMapper;
             this.peerMapper = peerMapper;
         }

Member Function Documentation

override void Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.Insert ( PeerActivity item )

inlineprotected

Definition at line 76 of file PeerActivityDatabaseMapper.cs.

References e, Ntp.Analyzer.Objects.PeerActivity.Hide, Ntp.Analyzer.Objects.PeerActivity.Host, Ntp.Analyzer.Objects.PersistentObject.Id, Ntp.Analyzer.Objects.PeerActivity.LastActive, Ntp.Analyzer.Objects.PeerActivity.Peer, Ntp.Analyzer.Objects.PersistentObject.SetId(), and Ntp.Analyzer.Objects.PeerActivity.UtcOffset.

         {
             lock (MapperLocker)
             {
                 try
                 {
                     Open();
                     Command.CommandText = PrepareInsertSql(InsertSql);
                     Command.Parameters.Add(CreateParameter("@lastActive", item.LastActive));
                     Command.Parameters.Add(CreateParameter("@zone", item.UtcOffset));
                     Command.Parameters.Add(CreateParameter("@hide", item.Hide));
                     Command.Parameters.Add(CreateParameter("@hostId", item.Host.Id));
                     Command.Parameters.Add(CreateParameter("@peerId", item.Peer.Id));
                     Command.Prepare();
                     Log.SqlExecute(Command.CommandText, Command.Parameters);
                     var idObject = Command.ExecuteScalar();
                     item.SetId(Convert.ToInt32(idObject));
                 }
                 catch (Exception e)
                 {
                     Log.InsertError(TableName, e);
                 }
                 finally
                 {
                     Close();
                 }
             }
         }

Here is the call graph for this function:

override void Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.ReadContent ( )

inlineprotectedvirtual

Implements Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< PeerActivity >.

Definition at line 106 of file PeerActivityDatabaseMapper.cs.

References e.

         {
             try
             {
                 Open();
                 Command.CommandText = PrepareSql(SelectSql);
                 Log.SqlExecute(Command.CommandText);
                 Reader = Command.ExecuteReader();
 
                 while (Reader.Read())
                 {
                     int id = Convert.ToInt32(Reader["id"]);
                     var time = Convert.ToDateTime(Reader["lastActive"]);
                     int zone = Convert.ToInt32(Reader["zone"]);
                     bool hide = Convert.ToBoolean(Reader["hide"]);
                     int hostId = Convert.ToInt32(Reader["hostId"]);
                     var host = hostMapper[hostId];
                     int peerId = Convert.ToInt32(Reader["peerId"]);
                     var peer = peerMapper[peerId];
                     var item = new PeerActivity(id, peer, host, time, zone, hide);
                     AddItem(item);
                 }
             }
             catch (Exception e)
             {
                 Log.UpdateError(TableName, e);
             }
             finally
             {
                 Close();
             }
         }

override void Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.Update ( PeerActivity item )

inlineprotected

Definition at line 140 of file PeerActivityDatabaseMapper.cs.

References e, Ntp.Analyzer.Objects.PersistentObject.Id, Ntp.Analyzer.Objects.PeerActivity.LastActive, and Ntp.Analyzer.Objects.PeerActivity.UtcOffset.

         {
             lock (MapperLocker)
             {
                 try
                 {
                     Open();
                     Command.CommandText = PrepareSql(UpdateSql);
                     Command.Parameters.Add(CreateParameter("@lastActive", item.LastActive));
                     Command.Parameters.Add(CreateParameter("@zone", item.UtcOffset));
                     Command.Parameters.Add(CreateParameter("@id", item.Id));
                     Command.Prepare();
                     Log.SqlExecute(Command.CommandText, Command.Parameters);
                     Command.ExecuteNonQuery();
                 }
                 catch (Exception e)
                 {
                     Log.UpdateError(TableName, e);
                 }
                 finally
                 {
                     Close();
                 }
             }
         }

Member Data Documentation

override string Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.CreateSql

protected

Initial value:

=> "CREATE TABLE peerActivity ( " +
                                               "    id {0} PRIMARY KEY, " +
                                               "    lastActive TIMESTAMP NOT NULL, " +
                                               "    zone INT NOT NULL, " +
                                               "    hide BIT(1) NOT NULL, " +
                                               "    hostId INT NOT NULL, " +
                                               "    peerId INT NOT NULL, " +
                                               "    UNIQUE KEY (hostId, peerId), " +
                                               "    FOREIGN KEY (hostId) REFERENCES host(id), " +
                                               "    FOREIGN KEY (peerId) REFERENCES peer(id) " +
                                               "){1};"

Definition at line 63 of file PeerActivityDatabaseMapper.cs.

readonly HostDatabaseMapper Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.hostMapper

private

Definition at line 56 of file PeerActivityDatabaseMapper.cs.

const string Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.InsertSql

private

Initial value:

=
            "INSERT INTO peerActivity( lastActive, zone, hide, hostId, peerId ) " +
            "VALUES( @lastActive, @zone, @hide, @hostId, @peerId );{0};"

Definition at line 49 of file PeerActivityDatabaseMapper.cs.

readonly PeerDatabaseMapper Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.peerMapper

private

Definition at line 57 of file PeerActivityDatabaseMapper.cs.

const string Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.SelectSql

private

Initial value:

=

"SELECT id, lastActive, zone, hide, hostId, peerId FROM peerActivity"

Definition at line 46 of file PeerActivityDatabaseMapper.cs.

override string Ntp.Analyzer.Data.Sql.PeerActivityDatabaseMapper.TableName => "peerActivity"

protected