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

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

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

[legend]

Public Member Functions
override IEnumerator< PeerReading >	GetEnumerator ()
	Read all data from table in a sequential manner. More...

Protected Member Functions
override void	Insert (PeerReading item)

override void	ReadContent ()

override void	Update (PeerReading item)

Protected Member Functions inherited from Ntp.Analyzer.Data.Sql.FilteredSqlDatabaseMapper< PeerReading >
	FilteredSqlDatabaseMapper (LogBase log)

override string	PrepareSql (string sql)

Protected Attributes
override string	CreateSql

override string	TableName => "peerReading"

override bool	UseCache => false

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

Private Attributes
readonly HostDatabaseMapper	hostMapper

const string	InsertSql

readonly PeerDatabaseMapper	peerMapper

const string	SelectSql

Additional Inherited Members
Properties inherited from Ntp.Analyzer.Data.Sql.FilteredSqlDatabaseMapper< PeerReading >
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...

Detailed Description

OR/M mapper for table peerReading.

Definition at line 35 of file PeerReadingDatabaseMapper.cs.

Constructor & Destructor Documentation

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

inlinepackage

Definition at line 37 of file PeerReadingDatabaseMapper.cs.

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

Member Function Documentation

override IEnumerator<PeerReading> Ntp.Analyzer.Data.Sql.PeerReadingDatabaseMapper.GetEnumerator ( )

inline

Read all data from table in a sequential manner.

Returns: The enumerator.

Definition at line 83 of file PeerReadingDatabaseMapper.cs.

References e.

         {
             lock (MapperLocker)
             {
                 bool error = false;
 
                 try
                 {
                     Open();
                     Command.CommandText = PrepareSql(SelectSql);
                     Log.SqlExecute(Command.CommandText);
                     Reader = Command.ExecuteReader();
                 }
                 catch (Exception e)
                 {
                     Log.ReadError(TableName, e);
                     error = true;
                 }
 
                 if (error)
                     yield break;
 
                 while (Reader.Read())
                 {
                     int id = Convert.ToInt32(Reader["id"]);
                     var time = Convert.ToDateTime(Reader["time"]);
                     int zone = Convert.ToInt32(Reader["zone"]);
                     int hostId = Convert.ToInt32(Reader["hostId"]);
                     var host = hostMapper[hostId];
                     int peerId = Convert.ToInt32(Reader["peerId"]);
                     var peer = peerMapper[peerId];
                     int last = Convert.ToInt32(Reader["last"]);
                     int reach = Convert.ToInt32(Reader["reach"]);
                     double delay = Convert.ToDouble(Reader["delay"]);
                     double offset = Convert.ToDouble(Reader["offset"]);
                     double jitter = Convert.ToDouble(Reader["jitter"]);
 
                     var reading = new PeerReading(
                         id, time, zone, host, peer,
                         last, reach, delay, offset, jitter);
 
                     yield return reading;
                 }
 
                 Close();
             }
         }

override void Ntp.Analyzer.Data.Sql.PeerReadingDatabaseMapper.Insert ( PeerReading item )

inlineprotected

Definition at line 132 of file PeerReadingDatabaseMapper.cs.

References Ntp.Analyzer.Objects.PeerReading.Delay, e, Ntp.Analyzer.Objects.Reading.Host, Ntp.Analyzer.Objects.PersistentObject.Id, Ntp.Analyzer.Objects.DispersionReading.Jitter, Ntp.Analyzer.Objects.PeerReading.LastPoll, Ntp.Analyzer.Objects.DispersionReading.Offset, Ntp.Analyzer.Objects.DispersionReading.Peer, Ntp.Analyzer.Objects.PeerReading.Reach, Ntp.Analyzer.Objects.PersistentObject.SetId(), Ntp.Analyzer.Objects.Reading.Time, and Ntp.Analyzer.Objects.Reading.UtcOffset.

         {
             lock (MapperLocker)
             {
                 try
                 {
                     Open();
                     Command.CommandText = PrepareInsertSql(InsertSql);
                     Command.Parameters.Add(CreateParameter("@time", item.Time));
                     Command.Parameters.Add(CreateParameter("@zone", item.UtcOffset));
                     Command.Parameters.Add(CreateParameter("@hostId", item.Host.Id));
                     Command.Parameters.Add(CreateParameter("@peerId", item.Peer.Id));
                     Command.Parameters.Add(CreateParameter("@last", item.LastPoll));
                     Command.Parameters.Add(CreateParameter("@reach", item.Reach));
                     Command.Parameters.Add(CreateParameter("@delay", item.Delay));
                     Command.Parameters.Add(CreateParameter("@offset", item.Offset));
                     Command.Parameters.Add(CreateParameter("@jitter", item.Jitter));
                     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.PeerReadingDatabaseMapper.ReadContent ( )

inlineprotected

Definition at line 165 of file PeerReadingDatabaseMapper.cs.

References Ntp.Analyzer.Data.Log.LogMessages.DatabaseCacheError.

         {
             throw new NotSupportedException(LogMessages.DatabaseCacheError);
         }

override void Ntp.Analyzer.Data.Sql.PeerReadingDatabaseMapper.Update ( PeerReading item )

inlineprotected

Definition at line 170 of file PeerReadingDatabaseMapper.cs.

References Ntp.Analyzer.Data.Log.LogMessages.DatabaseNoUpdate.

         {
             throw new NotSupportedException(string.Format(LogMessages.DatabaseNoUpdate, TableName));
         }

Member Data Documentation

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

protected

Initial value:

=> "CREATE TABLE peerReading ( " +
                                               "    id {0} PRIMARY KEY, " +
                                               "    time  TIMESTAMP NOT NULL, " +
                                               "    zone INT NOT NULL, " +
                                               "    hostId INT NOT NULL, " +
                                               "    peerId INT NOT NULL, " +
                                               "    last INT NOT NULL, " +
                                               "    reach INT NOT NULL, " +
                                               "    delay DOUBLE PRECISION NOT NULL, " +
                                               "    [offset] DOUBLE PRECISION NOT NULL, " +
                                               "    jitter DOUBLE PRECISION NOT NULL, " +
                                               "    FOREIGN KEY (hostId) REFERENCES host(id), " +
                                               "    FOREIGN KEY (peerId) REFERENCES peer(id) " +
                                               "){1};"

Definition at line 63 of file PeerReadingDatabaseMapper.cs.

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

private

Definition at line 56 of file PeerReadingDatabaseMapper.cs.

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

private

Initial value:

=
            "INSERT INTO peerReading ( time, zone, hostId, peerId, last, reach, delay, [offset], jitter ) " +
            "VALUES ( @time, @zone, @hostId, @peerId, @last, @reach, @delay, @offset, @jitter );{0};"

Definition at line 52 of file PeerReadingDatabaseMapper.cs.

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

private

Definition at line 57 of file PeerReadingDatabaseMapper.cs.

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

private

Initial value:

=
            "SELECT " +
            "id, time, zone, hostId, peerId, last, reach, delay, [offset], jitter " +
            "FROM peerReading"

Definition at line 47 of file PeerReadingDatabaseMapper.cs.

override string Ntp.Analyzer.Data.Sql.PeerReadingDatabaseMapper.TableName => "peerReading"

protected

Definition at line 61 of file PeerReadingDatabaseMapper.cs.

override bool Ntp.Analyzer.Data.Sql.PeerReadingDatabaseMapper.UseCache => false

protected

Definition at line 59 of file PeerReadingDatabaseMapper.cs.

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

Ntp.Analyzer.Data/Sql/PeerReadingDatabaseMapper.cs

Public Member Functions

Protected Member Functions

Protected Attributes

Package Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation