Ntp.Analyzer.Data.Sql.AssociationEntryMapper Class Reference

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

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

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

Public Member Functions
void	Delete (string ip, int hostId)
void	Delete (int hostId)
override IEnumerator< AssociationEntry >	GetEnumerator ()
	Read all data from table in a sequential manner. More...
Public Member Functions inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< AssociationEntry >
void	CheckTable ()
override IEnumerator< T >	GetEnumerator ()
	Read all data from table in a sequential manner. More...
void	Save (T item)

Protected Member Functions
override void	Insert (AssociationEntry item)
override void	ReadContent ()
override void	Update (AssociationEntry item)
Protected Member Functions inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< AssociationEntry >
	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 => "associationEntry"
override bool	UseCache => false
Protected Attributes inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< AssociationEntry >
IEnumerable< T >	Content
readonly object	MapperLocker
IDataReader	Reader

Package Functions
	AssociationEntryMapper (LogBase log)

Private Attributes
const string	DeleteHostSql
const string	DeleteUniqueSql
const string	InsertSql
const string	SelectSql

Additional Inherited Members
Properties inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< AssociationEntry >
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 associationEntry.

Definition at line 35 of file AssociationEntryMapper.cs.

Constructor & Destructor Documentation

Ntp.Analyzer.Data.Sql.AssociationEntryMapper.AssociationEntryMapper ( LogBase  log )

inlinepackage

Definition at line 37 of file AssociationEntryMapper.cs.

            : base(log)
        {
        }

Member Function Documentation

void Ntp.Analyzer.Data.Sql.AssociationEntryMapper.Delete ( string  ip, int  hostId  )

inline

Definition at line 80 of file AssociationEntryMapper.cs.

References e.

        {
            lock (MapperLocker)
            {
                try
                {
                    Open();
                    Command.CommandText = PrepareSql(DeleteUniqueSql);
                    Command.Parameters.Add(CreateParameter("@remote", ip));
                    Command.Parameters.Add(CreateParameter("@hostId", hostId));
                    Command.Prepare();
                    Log.SqlExecute(Command.CommandText, Command.Parameters);
                    Command.ExecuteNonQuery();
                }
                catch (Exception e)
                {
                    Log.DeleteError(TableName, e);
                }
                finally
                {
                    Close();
                }
            }
        }

void Ntp.Analyzer.Data.Sql.AssociationEntryMapper.Delete ( int  hostId )

inline

Definition at line 106 of file AssociationEntryMapper.cs.

References e.

        {
            lock (MapperLocker)
            {
                try
                {
                    Open();
                    Command.CommandText = PrepareSql(DeleteHostSql);
                    Command.Parameters.Add(CreateParameter("@hostId", hostId));
                    Command.Prepare();
                    Log.SqlExecute(Command.CommandText, Command.Parameters);
                    Command.ExecuteNonQuery();
                }
                catch (Exception e)
                {
                    Log.DeleteError(TableName, e);
                }
                finally
                {
                    Close();
                }
            }
        }

override IEnumerator<AssociationEntry> Ntp.Analyzer.Data.Sql.AssociationEntryMapper.GetEnumerator ( )

inline

Read all data from table in a sequential manner.

Returns

The enumerator.

Definition at line 135 of file AssociationEntryMapper.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"]);
                    string tallyChar = Convert.ToString(Reader["tallyChar"]);
                    string remote = Convert.ToString(Reader["remote"]);
                    string refid = Convert.ToString(Reader["refid"]);
                    int stratus = Convert.ToInt32(Reader["stratus"]);
                    char type = Convert.ToChar(Reader["type"]);
                    int lastPoll = Convert.ToInt32(Reader["lastPoll"]);
                    int poll = Convert.ToInt32(Reader["poll"]);
                    int reach = Convert.ToInt32(Reader["reach"]);
                    double delay = Convert.ToDouble(Reader["delay"]);
                    double offset = Convert.ToDouble(Reader["offset"]);
                    double jitter = Convert.ToDouble(Reader["jitter"]);
                    int hostId = Convert.ToInt32(Reader["hostId"]);

                    if (tallyChar == string.Empty)
                        tallyChar = " ";

                    var entry = new AssociationEntry(
                        id, hostId, tallyChar[0], remote, refid, stratus, type,
                        lastPoll, poll, reach, delay, offset, jitter);

                    yield return entry;
                }

                Close();
            }
        }

override void Ntp.Analyzer.Data.Sql.AssociationEntryMapper.Insert ( AssociationEntry  item )

inlineprotected

Definition at line 188 of file AssociationEntryMapper.cs.

References Ntp.Analyzer.Objects.AssociationEntry.Delay, e, Ntp.Analyzer.Objects.AssociationEntry.HostId, Ntp.Analyzer.Objects.AssociationEntry.Jitter, Ntp.Analyzer.Objects.AssociationEntry.LastPoll, Ntp.Analyzer.Objects.AssociationEntry.Offset, Ntp.Analyzer.Objects.AssociationEntry.PeerType, Ntp.Analyzer.Objects.AssociationEntry.Poll, Ntp.Analyzer.Objects.AssociationEntry.Reach, Ntp.Analyzer.Objects.AssociationEntry.Refid, Ntp.Analyzer.Objects.AssociationEntry.Remote, Ntp.Analyzer.Objects.PersistentObject.SetId(), Ntp.Analyzer.Objects.AssociationEntry.Stratus, and Ntp.Analyzer.Objects.AssociationEntry.TallyChar.

        {
            lock (MapperLocker)
            {
                try
                {
                    Open();
                    Command.CommandText = PrepareInsertSql(InsertSql);
                    Command.Parameters.Add(CreateParameter("@tallyChar", item.TallyChar));
                    Command.Parameters.Add(CreateParameter("@remote", item.Remote));
                    Command.Parameters.Add(CreateParameter("@refid", item.Refid));
                    Command.Parameters.Add(CreateParameter("@stratus", item.Stratus));
                    Command.Parameters.Add(CreateParameter("@type", item.PeerType));
                    Command.Parameters.Add(CreateParameter("@lastPoll", item.LastPoll));
                    Command.Parameters.Add(CreateParameter("@poll", item.Poll));
                    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.Parameters.Add(CreateParameter("@hostId", item.HostId));
                    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.AssociationEntryMapper.ReadContent ( )

inlineprotectedvirtual

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

Definition at line 224 of file AssociationEntryMapper.cs.

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

        {
            throw new NotSupportedException(LogMessages.DatabaseCacheError);
        }

override void Ntp.Analyzer.Data.Sql.AssociationEntryMapper.Update ( AssociationEntry  item )

inlineprotected

Definition at line 229 of file AssociationEntryMapper.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.AssociationEntryMapper.CreateSql

protected

Initial value:

=> "CREATE TABLE associationEntry ( " +
                                               "    id {0} PRIMARY KEY, " +
                                               "    tallyChar CHAR(1) NOT NULL, " +
                                               "    remote VARCHAR(45) NOT NULL, " +
                                               "    refid VARCHAR(45) NOT NULL, " +
                                               "    stratus INT NOT NULL, " +
                                               "    type CHAR(1) NOT NULL, " +
                                               "    lastPoll INT NOT NULL, " +
                                               "    poll INT NOT NULL, " +
                                               "    reach INT NOT NULL, " +
                                               "    delay DOUBLE PRECISION NOT NULL, " +
                                               "    [offset] DOUBLE PRECISION NOT NULL, " +
                                               "    jitter DOUBLE PRECISION NOT NULL, " +
                                               "    hostId INT NOT NULL, " +
                                               "    UNIQUE KEY (hostId, remote), " +
                                               "    FOREIGN KEY (hostId) REFERENCES host(id) " +
                                               "){1};"

Definition at line 61 of file AssociationEntryMapper.cs.

const string Ntp.Analyzer.Data.Sql.AssociationEntryMapper.DeleteHostSql

private

Initial value:

=
            "DELETE FROM associationEntry WHERE hostId = @hostId"

Definition at line 54 of file AssociationEntryMapper.cs.

const string Ntp.Analyzer.Data.Sql.AssociationEntryMapper.DeleteUniqueSql

private

Initial value:

=
            "DELETE FROM associationEntry WHERE remote = @remote AND hostId = @hostId"

Definition at line 51 of file AssociationEntryMapper.cs.

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

private

Initial value:

=
            "INSERT INTO associationEntry ( tallyChar, hostId, remote, refid, stratus, type, lastPoll, poll, reach, delay, [offset], jitter ) " +
            "VALUES ( @tallyChar, @hostId, @remote, @refid, @stratus, @type, @lastPoll, @poll, @reach, @delay, @offset, @jitter );{0};"

Definition at line 47 of file AssociationEntryMapper.cs.

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

private

Initial value:

=
            "SELECT " +
            "id, tallyChar, remote, refid, stratus, type, lastPoll, poll, reach, delay, [offset], jitter, hostId " +
            "FROM associationEntry"

Definition at line 42 of file AssociationEntryMapper.cs.

override string Ntp.Analyzer.Data.Sql.AssociationEntryMapper.TableName => "associationEntry"

protected

Definition at line 59 of file AssociationEntryMapper.cs.

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

protected

Definition at line 57 of file AssociationEntryMapper.cs.

---

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

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