Ntp.Analyzer.Data.Sql.DriftReadingDatabaseMapper Class Reference

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

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

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

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

Protected Member Functions
override void	Insert (DriftReading item)
override void	ReadContent ()
override void	Update (DriftReading item)
Protected Member Functions inherited from Ntp.Analyzer.Data.Sql.FilteredSqlDatabaseMapper< DriftReading >
	FilteredSqlDatabaseMapper (LogBase log)
override string	PrepareSql (string sql)

Protected Attributes
override string	CreateSql
override string	TableName => "driftReading"
override bool	UseCache => false

Package Functions
	DriftReadingDatabaseMapper (HostDatabaseMapper hostMapper, LogBase log)

Private Attributes
readonly HostDatabaseMapper	hostMapper
const string	InsertSql
const string	SelectSql

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

Definition at line 35 of file DriftReadingDatabaseMapper.cs.

Constructor & Destructor Documentation

Ntp.Analyzer.Data.Sql.DriftReadingDatabaseMapper.DriftReadingDatabaseMapper ( HostDatabaseMapper  hostMapper, LogBase  log  )

inlinepackage

Definition at line 37 of file DriftReadingDatabaseMapper.cs.

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

Member Function Documentation

override IEnumerator<DriftReading> Ntp.Analyzer.Data.Sql.DriftReadingDatabaseMapper.GetEnumerator ( )

inline

Read all data from table in a sequential manner.

Returns

The enumerator.

Definition at line 72 of file DriftReadingDatabaseMapper.cs.

References e.

        {
            lock (MapperLocker)
            {
                bool error = false;
                string sql = PrepareSql(SelectSql);

                try
                {
                    Open();
                    Command.CommandText = sql;
                    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];
                    double drift = Convert.ToDouble(Reader["drift"]);
                    yield return new DriftReading(id, time, zone, host, drift);
                }

                Close();
            }
        }

override void Ntp.Analyzer.Data.Sql.DriftReadingDatabaseMapper.Insert ( DriftReading  item )

inlineprotected

Definition at line 111 of file DriftReadingDatabaseMapper.cs.

References e, Ntp.Analyzer.Objects.Reading.Host, Ntp.Analyzer.Objects.PersistentObject.Id, Ntp.Analyzer.Objects.PersistentObject.SetId(), Ntp.Analyzer.Objects.Reading.Time, Ntp.Analyzer.Objects.Reading.UtcOffset, and Ntp.Analyzer.Objects.DriftReading.Value.

        {
            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("@drift", item.Value));
                    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.DriftReadingDatabaseMapper.ReadContent ( )

inlineprotected

Definition at line 139 of file DriftReadingDatabaseMapper.cs.

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

        {
            throw new NotSupportedException(LogMessages.DatabaseCacheError);
        }

override void Ntp.Analyzer.Data.Sql.DriftReadingDatabaseMapper.Update ( DriftReading  item )

inlineprotected

Definition at line 144 of file DriftReadingDatabaseMapper.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.DriftReadingDatabaseMapper.CreateSql

protected

Initial value:

=> "CREATE TABLE driftReading ( " +
                                               "    id {0} PRIMARY KEY, " +
                                               "    time  TIMESTAMP NOT NULL, " +
                                               "    zone INT NOT NULL, " +
                                               "    hostId INT NOT NULL, " +
                                               "    drift DOUBLE PRECISION NOT NULL, " +
                                               "    FOREIGN KEY (hostId) REFERENCES host(id) " +
                                               "){1};"

Definition at line 58 of file DriftReadingDatabaseMapper.cs.

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

private

Definition at line 52 of file DriftReadingDatabaseMapper.cs.

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

private

Initial value:

=
            "INSERT INTO driftReading ( time, zone, hostId, drift ) " +
            "VALUES ( @time, @zone, @hostId, @drift );{0};"

Definition at line 48 of file DriftReadingDatabaseMapper.cs.

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

private

Initial value:

=
            "SELECT " +
            "id, time, zone, hostId, drift " +
            "FROM driftReading"

Definition at line 43 of file DriftReadingDatabaseMapper.cs.

override string Ntp.Analyzer.Data.Sql.DriftReadingDatabaseMapper.TableName => "driftReading"

protected

Definition at line 56 of file DriftReadingDatabaseMapper.cs.

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

protected

Definition at line 54 of file DriftReadingDatabaseMapper.cs.

---

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

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