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

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

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

[legend]

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

Protected Member Functions
override void	Insert (HostReading item)

override void	ReadContent ()

override void	Update (HostReading item)

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

override string	PrepareSql (string sql)

Protected Attributes
override string	CreateSql

override string	TableName => "hostReading"

override bool	UseCache => false

Package Functions
	HostReadingDatabaseMapper (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< HostReading >
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 hostReading.

Definition at line 35 of file HostReadingDatabaseMapper.cs.

Constructor & Destructor Documentation

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

inlinepackage

Definition at line 37 of file HostReadingDatabaseMapper.cs.

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

Member Function Documentation

override IEnumerator<HostReading> Ntp.Analyzer.Data.Sql.HostReadingDatabaseMapper.GetEnumerator ( )

inline

Read all data from table in a sequential manner.

Returns: The enumerator.

Definition at line 82 of file HostReadingDatabaseMapper.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];
                     double offset = Convert.ToDouble(Reader["offset"]);
                     double jitter = Convert.ToDouble(Reader["jitter"]);
                     double frequency = Convert.ToDouble(Reader["frequency"]);
                     double stability = Convert.ToDouble(Reader["stability"]);
 
                     var reading = new HostReading(
                         id, time, zone, host, peer,
                         offset, jitter, frequency, stability);
 
                     yield return reading;
                 }
 
                 Close();
             }
         }

override void Ntp.Analyzer.Data.Sql.HostReadingDatabaseMapper.Insert ( HostReading item )

inlineprotected

Definition at line 130 of file HostReadingDatabaseMapper.cs.

References e, Ntp.Analyzer.Objects.HostReading.Frequency, Ntp.Analyzer.Objects.Reading.Host, Ntp.Analyzer.Objects.PersistentObject.Id, Ntp.Analyzer.Objects.DispersionReading.Jitter, Ntp.Analyzer.Objects.DispersionReading.Offset, Ntp.Analyzer.Objects.DispersionReading.Peer, Ntp.Analyzer.Objects.PersistentObject.SetId(), Ntp.Analyzer.Objects.HostReading.Stability, 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("@offset", item.Offset));
                     Command.Parameters.Add(CreateParameter("@jitter", item.Jitter));
                     Command.Parameters.Add(CreateParameter("@frequency", item.Frequency));
                     Command.Parameters.Add(CreateParameter("@stability", item.Stability));
                     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.HostReadingDatabaseMapper.ReadContent ( )

inlineprotected

Definition at line 162 of file HostReadingDatabaseMapper.cs.

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

         {
             throw new NotSupportedException(LogMessages.DatabaseCacheError);
         }

override void Ntp.Analyzer.Data.Sql.HostReadingDatabaseMapper.Update ( HostReading item )

inlineprotected

Definition at line 167 of file HostReadingDatabaseMapper.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.HostReadingDatabaseMapper.CreateSql

protected

Initial value:

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

Definition at line 63 of file HostReadingDatabaseMapper.cs.

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

private

Definition at line 56 of file HostReadingDatabaseMapper.cs.

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

private

Initial value:

=
            "INSERT INTO hostReading ( time, zone, hostId, peerId, [offset], jitter, frequency, stability ) " +
            "VALUES ( @time, @zone, @hostId, @peerId, @offset, @jitter, @frequency, @stability );{0};"

Definition at line 52 of file HostReadingDatabaseMapper.cs.

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

private

Definition at line 57 of file HostReadingDatabaseMapper.cs.

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

private

Initial value:

=
            "SELECT " +
            "id, time, zone, hostId, peerId, [offset], jitter, frequency, stability " +
            "FROM hostReading"

Definition at line 47 of file HostReadingDatabaseMapper.cs.

override string Ntp.Analyzer.Data.Sql.HostReadingDatabaseMapper.TableName => "hostReading"

protected

Definition at line 61 of file HostReadingDatabaseMapper.cs.

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

protected

Definition at line 59 of file HostReadingDatabaseMapper.cs.

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

Ntp.Analyzer.Data/Sql/HostReadingDatabaseMapper.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