Ntp.Analyzer.Data.Sql.PeerDatabaseMapper Class Reference

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

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

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

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

Package Functions
	PeerDatabaseMapper (TimeServerDatabaseMapper timeServerMapper, LogBase log)

Private Attributes
const string	InsertSql
const string	SelectSql
readonly TimeServerDatabaseMapper	timeServerMapper
const string	UpdateSql

Additional Inherited Members
Public Member Functions inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< Peer >
void	CheckTable ()
override IEnumerator< T >	GetEnumerator ()
	Read all data from table in a sequential manner. More...
void	Save (T item)
Properties inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< Peer >
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 peer.

Definition at line 34 of file PeerDatabaseMapper.cs.

Constructor & Destructor Documentation

Ntp.Analyzer.Data.Sql.PeerDatabaseMapper.PeerDatabaseMapper ( TimeServerDatabaseMapper  timeServerMapper, LogBase  log  )

inlinepackage

Definition at line 36 of file PeerDatabaseMapper.cs.

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

Member Function Documentation

override void Ntp.Analyzer.Data.Sql.PeerDatabaseMapper.Insert ( Peer  item )

inlineprotected

Definition at line 65 of file PeerDatabaseMapper.cs.

References e, Ntp.Analyzer.Objects.Peer.Ip, Ntp.Analyzer.Objects.NamedObject.Name, Ntp.Analyzer.Objects.Peer.OrgId, and Ntp.Analyzer.Objects.PersistentObject.SetId().

        {
            lock (MapperLocker)
            {
                try
                {
                    Open();
                    Command.CommandText = PrepareInsertSql(InsertSql);
                    Command.Parameters.Add(CreateParameter("@name", item.Name));
                    Command.Parameters.Add(CreateParameter("@ip", item.Ip));
                    Command.Parameters.Add(CreateParameter("@orgId", item.OrgId));
                    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.PeerDatabaseMapper.ReadContent ( )

inlineprotectedvirtual

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

Definition at line 93 of file PeerDatabaseMapper.cs.

References e.

        {
            try
            {
                Open();
                Command.CommandText = PrepareSql(SelectSql);
                Log.SqlExecute(Command.CommandText);
                Reader = Command.ExecuteReader();

                while (Reader.Read())
                {
                    int id = Convert.ToInt32(Reader["id"]);
                    string name = Reader["name"].ToString();
                    string ip = Reader["ip"].ToString();
                    var orgId = Reader["orgId"] != DBNull.Value
                        ? Convert.ToInt32(Reader["orgId"])
                        : (int?) null;

                    var server = orgId.HasValue
                        ? timeServerMapper[orgId.Value]
                        : null;

                    var peer = new Peer(id, name, ip, server);
                    AddItem(peer);
                }
            }
            catch (Exception e)
            {
                Log.ReadError(TableName, e);
            }
            finally
            {
                Close();
            }
        }

override void Ntp.Analyzer.Data.Sql.PeerDatabaseMapper.Update ( Peer  item )

inlineprotected

Definition at line 130 of file PeerDatabaseMapper.cs.

References e, Ntp.Analyzer.Objects.PersistentObject.Id, Ntp.Analyzer.Objects.Peer.Ip, Ntp.Analyzer.Objects.NamedObject.Name, and Ntp.Analyzer.Objects.Peer.OrgId.

        {
            lock (MapperLocker)
            {
                try
                {
                    Open();
                    Command.CommandText = PrepareSql(UpdateSql);
                    Command.Parameters.Add(CreateParameter("@name", item.Name));
                    Command.Parameters.Add(CreateParameter("@ip", item.Ip));
                    Command.Parameters.Add(CreateParameter("@orgId", item.OrgId));
                    Command.Parameters.Add(CreateParameter("@id", item.Id));
                    Command.Prepare();
                    Log.SqlExecute(Command.CommandText, Command.Parameters);
                    Command.ExecuteNonQuery();
                }
                catch (Exception e)
                {
                    Log.UpdateError(TableName, e);
                }
                finally
                {
                    Close();
                }
            }
        }

Member Data Documentation

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

protected

Initial value:

=> "CREATE TABLE peer ( " +
                                               "    id {0} PRIMARY KEY, " +
                                               "    name VARCHAR(255) NOT NULL, " +
                                               "    ip VARCHAR(45) NOT NULL, " +
                                               "    orgId INT " +
                                               "){1};"

Definition at line 57 of file PeerDatabaseMapper.cs.

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

private

Initial value:

=
            "INSERT INTO peer( name, ip, orgId ) VALUES( @name, @ip, @orgId );{0};"

Definition at line 45 of file PeerDatabaseMapper.cs.

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

private

Initial value:

=
            "SELECT id, name, ip, orgId FROM peer;"

Definition at line 42 of file PeerDatabaseMapper.cs.

override string Ntp.Analyzer.Data.Sql.PeerDatabaseMapper.TableName => "peer"

protected

Definition at line 55 of file PeerDatabaseMapper.cs.

readonly TimeServerDatabaseMapper Ntp.Analyzer.Data.Sql.PeerDatabaseMapper.timeServerMapper

private

Definition at line 51 of file PeerDatabaseMapper.cs.

const string Ntp.Analyzer.Data.Sql.PeerDatabaseMapper.UpdateSql

private

Initial value:

=
            "UPDATE peer SET name = @name, ip = @ip, orgId = @orgId WHERE id = @id"

Definition at line 48 of file PeerDatabaseMapper.cs.

override bool Ntp.Analyzer.Data.Sql.PeerDatabaseMapper.UseCache => true

protected

Definition at line 53 of file PeerDatabaseMapper.cs.

---

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

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