Ntp.Analyzer.Data.Sql.HostIoReadingDatabaseMapper Class Reference

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

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

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

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

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

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

Package Functions
	HostIoReadingDatabaseMapper (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< HostIoReading >
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 hostIoReading.

Definition at line 35 of file HostIoReadingDatabaseMapper.cs.

Constructor & Destructor Documentation

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

inlinepackage

Definition at line 37 of file HostIoReadingDatabaseMapper.cs.

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

Member Function Documentation

override IEnumerator<HostIoReading> Ntp.Analyzer.Data.Sql.HostIoReadingDatabaseMapper.GetEnumerator ( )

inline

Read all data from table in a sequential manner.

Returns

The enumerator.

Definition at line 94 of file HostIoReadingDatabaseMapper.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 timeSinceReset = Convert.ToInt32(Reader["timeSinceReset"]);
                    int receiveBuffers = Convert.ToInt32(Reader["receiveBuffers"]);
                    int freeReceiveBuffers = Convert.ToInt32(Reader["freeReceiveBuffers"]);
                    int usedReceiveBuffers = Convert.ToInt32(Reader["usedReceiveBuffers"]);
                    int lowWaterRefills = Convert.ToInt32(Reader["lowWaterRefills"]);
                    long droppedPackets = Convert.ToInt64(Reader["droppedPackets"]);
                    long ignoredPackets = Convert.ToInt64(Reader["ignoredPackets"]);
                    long receivedPackets = Convert.ToInt64(Reader["receivedPackets"]);
                    long packetsSent = Convert.ToInt64(Reader["packetsSent"]);
                    long packetsNotSent = Convert.ToInt64(Reader["packetsNotSent"]);
                    int interruptsHandled = Convert.ToInt32(Reader["interruptsHandled"]);
                    int receivedByInt = Convert.ToInt32(Reader["receivedByInt"]);

                    var reading = new HostIoReading(
                        id, time, zone, host, timeSinceReset,
                        receiveBuffers, freeReceiveBuffers, usedReceiveBuffers, lowWaterRefills,
                        droppedPackets, ignoredPackets, receivedPackets,
                        packetsSent, packetsNotSent,
                        interruptsHandled, receivedByInt);

                    yield return reading;
                }

                Close();
            }
        }

override void Ntp.Analyzer.Data.Sql.HostIoReadingDatabaseMapper.Insert ( HostIoReading  item )

inlineprotected

Definition at line 151 of file HostIoReadingDatabaseMapper.cs.

References Ntp.Analyzer.Objects.HostIoReading.DroppedPackets, e, Ntp.Analyzer.Objects.HostIoReading.FreeReceiveBuffers, Ntp.Analyzer.Objects.Reading.Host, Ntp.Analyzer.Objects.PersistentObject.Id, Ntp.Analyzer.Objects.HostIoReading.IgnoredPackets, Ntp.Analyzer.Objects.HostIoReading.InterruptsHandled, Ntp.Analyzer.Objects.HostIoReading.LowWaterRefills, Ntp.Analyzer.Objects.HostIoReading.PacketsNotSent, Ntp.Analyzer.Objects.HostIoReading.PacketsSent, Ntp.Analyzer.Objects.HostIoReading.ReceiveBuffers, Ntp.Analyzer.Objects.HostIoReading.ReceivedByInt, Ntp.Analyzer.Objects.HostIoReading.ReceivedPackets, Ntp.Analyzer.Objects.PersistentObject.SetId(), Ntp.Analyzer.Objects.Reading.Time, Ntp.Analyzer.Objects.HostIoReading.TimeSinceReset, Ntp.Analyzer.Objects.HostIoReading.UsedReceiveBuffers, 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("@timeSinceReset", item.TimeSinceReset));
                    Command.Parameters.Add(CreateParameter("@receiveBuffers", item.ReceiveBuffers));
                    Command.Parameters.Add(CreateParameter("@freeReceiveBuffers", item.FreeReceiveBuffers));
                    Command.Parameters.Add(CreateParameter("@usedReceiveBuffers", item.UsedReceiveBuffers));
                    Command.Parameters.Add(CreateParameter("@lowWaterRefills", item.LowWaterRefills));
                    Command.Parameters.Add(CreateParameter("@droppedPackets", item.DroppedPackets));
                    Command.Parameters.Add(CreateParameter("@ignoredPackets", item.IgnoredPackets));
                    Command.Parameters.Add(CreateParameter("@receivedPackets", item.ReceivedPackets));
                    Command.Parameters.Add(CreateParameter("@packetsSent", item.PacketsSent));
                    Command.Parameters.Add(CreateParameter("@packetsNotSent", item.PacketsNotSent));
                    Command.Parameters.Add(CreateParameter("@interruptsHandled", item.InterruptsHandled));
                    Command.Parameters.Add(CreateParameter("@receivedByInt", item.ReceivedByInt));
                    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.HostIoReadingDatabaseMapper.ReadContent ( )

inlineprotected

Definition at line 190 of file HostIoReadingDatabaseMapper.cs.

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

        {
            throw new NotSupportedException(LogMessages.DatabaseCacheError);
        }

override void Ntp.Analyzer.Data.Sql.HostIoReadingDatabaseMapper.Update ( HostIoReading  item )

inlineprotected

Definition at line 195 of file HostIoReadingDatabaseMapper.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.HostIoReadingDatabaseMapper.CreateSql

protected

Initial value:

=> "CREATE TABLE hostIoReading ( " +
                                               "    id {0} PRIMARY KEY, " +
                                               "    time TIMESTAMP NOT NULL, " +
                                               "    zone INT NOT NULL, " +
                                               "    hostId INT NOT NULL, " +
                                               "    timeSinceReset INT NOT NULL, " +
                                               "    receiveBuffers INT NOT NULL, " +
                                               "    freeReceiveBuffers INT NOT NULL, " +
                                               "    usedReceiveBuffers INT NOT NULL, " +
                                               "    lowWaterRefills INT NOT NULL, " +
                                               "    droppedPackets BIGINT NOT NULL, " +
                                               "    ignoredPackets BIGINT NOT NULL, " +
                                               "    receivedPackets BIGINT NOT NULL, " +
                                               "    packetsSent BIGINT NOT NULL, " +
                                               "    packetsNotSent BIGINT NOT NULL, " +
                                               "    interruptsHandled INT NOT NULL, " +
                                               "    receivedByInt INT NOT NULL, " +
                                               "    FOREIGN KEY (hostId) REFERENCES host(id) " +
                                               "){1};"

Definition at line 69 of file HostIoReadingDatabaseMapper.cs.

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

private

Definition at line 63 of file HostIoReadingDatabaseMapper.cs.

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

private

Initial value:

=
            "INSERT INTO hostIoReading ( " +
            "time, zone, hostId, timeSinceReset, " +
            "receiveBuffers, freeReceiveBuffers, usedReceiveBuffers, lowWaterRefills, " +
            "droppedPackets, ignoredPackets, receivedPackets, " +
            "packetsSent, packetsNotSent, interruptsHandled, receivedByInt ) " +
            "VALUES ( " +
            "@time, @zone, @hostId, @timeSinceReset, " +
            "@receiveBuffers, @freeReceiveBuffers, @usedReceiveBuffers, @lowWaterRefills, " +
            "@droppedPackets, @ignoredPackets, @receivedPackets, " +
            "@packetsSent, @packetsNotSent, @interruptsHandled, @receivedByInt );{0};"

Definition at line 51 of file HostIoReadingDatabaseMapper.cs.

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

private

Initial value:

=
            "SELECT " +
            "id, time, zone, hostId, timeSinceReset, " +
            "receiveBuffers, freeReceiveBuffers, usedReceiveBuffers, lowWaterRefills, " +
            "droppedPackets, ignoredPackets, receivedPackets, " +
            "packetsSent, packetsNotSent, interruptsHandled, receivedByInt " +
            "FROM hostIoReading"

Definition at line 43 of file HostIoReadingDatabaseMapper.cs.

override string Ntp.Analyzer.Data.Sql.HostIoReadingDatabaseMapper.TableName => "hostIoReading"

protected

Definition at line 67 of file HostIoReadingDatabaseMapper.cs.

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

protected

Definition at line 65 of file HostIoReadingDatabaseMapper.cs.

---

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

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