Ntp.Analyzer.Data.Sql.TimeServerDatabaseMapper Class Reference

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

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

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

Protected Member Functions
override TimeServer	FetchExternal (int id)
	Fetch time server from external source. More...
override void	Insert (TimeServer item)
override void	ReadContent ()
override void	Update (TimeServer item)
Protected Member Functions inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< TimeServer >
	SqlDatabaseMapper (LogBase log)
void	AddItem (T item)
void	Close ()
IDbDataParameter	CreateParameter (string name, object value)
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 => "timeServer"
override bool	UseCache => true
Protected Attributes inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< TimeServer >
IEnumerable< T >	Content
readonly object	MapperLocker
IDataReader	Reader

Package Functions
	TimeServerDatabaseMapper (LogBase log)

Private Attributes
const string	InsertSql
const string	SelectSql

Additional Inherited Members
Public Member Functions inherited from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< TimeServer >
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< TimeServer >
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 timeServer.

Definition at line 36 of file TimeServerDatabaseMapper.cs.

Constructor & Destructor Documentation

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

inlinepackage

Definition at line 38 of file TimeServerDatabaseMapper.cs.

            : base(log)
        {
        }

Member Function Documentation

override TimeServer Ntp.Analyzer.Data.Sql.TimeServerDatabaseMapper.FetchExternal ( int  id )

inlineprotectedvirtual

Fetch time server from external source.

Returns

The external.

Parameters

id	The time server identifier used on support.ntp.org.

Reimplemented from Ntp.Analyzer.Data.Sql.SqlDatabaseMapper< TimeServer >.

Definition at line 102 of file TimeServerDatabaseMapper.cs.

References Ntp.Analyzer.Data.Import.TimeServerWebAdapter.Create(), and e.

        {
            var adapter = TimeServerWebAdapter.Create(Log);

            if (adapter == null)
                return null;

            TimeServer server;

            try
            {
                server = adapter.Import(id);
                Insert(server);
                AddItem(server);
            }
            catch (Exception e)
            {
                Log.TimeServerFetchError(e);
                return null;
            }

            return server;
        }

Here is the call graph for this function:

override void Ntp.Analyzer.Data.Sql.TimeServerDatabaseMapper.Insert ( TimeServer  item )

inlineprotected

Definition at line 127 of file TimeServerDatabaseMapper.cs.

References Ntp.Analyzer.Objects.TimeServer.AccessDetails, Ntp.Analyzer.Objects.TimeServer.AccessPolicy, Ntp.Analyzer.Objects.TimeServer.Address, Ntp.Analyzer.Objects.TimeServer.AutoKey, Ntp.Analyzer.Objects.TimeServer.Contact, Ntp.Analyzer.Objects.TimeServer.Country, Ntp.Analyzer.Objects.TimeServer.DisplayLocation, e, Ntp.Analyzer.Objects.TimeServer.Geo, Ntp.Analyzer.Objects.PersistentObject.Id, Ntp.Analyzer.Objects.TimeServer.IsPoolMember, Ntp.Analyzer.Objects.TimeServer.Location, Ntp.Analyzer.Objects.TimeServer.Name, Ntp.Analyzer.Objects.TimeServer.Organization, Ntp.Analyzer.Objects.TimeServer.ProviderPage, Ntp.Analyzer.Objects.TimeServer.ProviderUrl, Ntp.Analyzer.Objects.TimeServer.Server, Ntp.Analyzer.Objects.TimeServer.ServiceArea, Ntp.Analyzer.Objects.PersistentObject.SetId(), Ntp.Analyzer.Objects.TimeServer.ShouldNotify, Ntp.Analyzer.Objects.TimeServer.ShouldUseDns, Ntp.Analyzer.Objects.TimeServer.Stratum, Ntp.Analyzer.Objects.TimeServer.SymKey, Ntp.Analyzer.Objects.TimeServer.SymUrl, Ntp.Analyzer.Objects.TimeServer.Updated, and Ntp.Analyzer.Objects.TimeServer.V6Address.

        {
            string countryCode = item.Country?.PadRight(7).Substring(0, 7).TrimEnd();
            string hostName = item.Name?.PadRight(50).Substring(0, 50).TrimEnd();
            string ip = item.Address?.ToString().PadRight(15).Substring(0, 15).TrimEnd();
            string ip6 = item.V6Address?.PadRight(30).Substring(0, 30).TrimEnd();
            string location = item.Location?.PadRight(100).Substring(0, 100).TrimEnd();
            string displayLocation = item.DisplayLocation?.PadRight(60).Substring(0, 60).TrimEnd();
            string organization = item.Organization?.PadRight(50).Substring(0, 50).TrimEnd();
            string coordinates = item.Geo?.PadRight(50).Substring(0, 50).TrimEnd();
            string synchronization = item.Server?.PadRight(255).Substring(0, 255).TrimEnd();
            string serviceArea = item.ServiceArea?.PadRight(100).Substring(0, 100).TrimEnd();
            string accessPolicy = item.AccessPolicy?.PadRight(255).Substring(0, 255).TrimEnd();
            string accessDetails = item.AccessDetails?.PadRight(512).Substring(0, 512).TrimEnd();
            string autoKeyUrl = item.AutoKey?.PadRight(255).Substring(0, 255).TrimEnd();
            string symmetricKeyType = item.SymKey?.PadRight(100).Substring(0, 100).TrimEnd();
            string symmetricKeyUrl = item.SymUrl?.PadRight(100).Substring(0, 100).TrimEnd();
            string serverContact = item.Contact?.PadRight(255).Substring(0, 255).TrimEnd();
            string providerPage = item.ProviderPage?.PadRight(100).Substring(0, 100).TrimEnd();
            string providerUrl = item.ProviderUrl?.PadRight(255).Substring(0, 255).TrimEnd();

            lock (MapperLocker)
            {
                try
                {
                    Open();
                    Command.CommandText = PrepareInsertSql(InsertSql);
                    Command.Parameters.Add(CreateParameter("@id", item.Id));
                    Command.Parameters.Add(CreateParameter("@stratum", item.Stratum));
                    Command.Parameters.Add(CreateParameter("@countryCode", countryCode));
                    Command.Parameters.Add(CreateParameter("@hostName", hostName));
                    Command.Parameters.Add(CreateParameter("@ip", ip));
                    Command.Parameters.Add(CreateParameter("@ip6", ip6));
                    Command.Parameters.Add(CreateParameter("@useDns", item.ShouldUseDns));
                    Command.Parameters.Add(CreateParameter("@poolMember", item.IsPoolMember));
                    Command.Parameters.Add(CreateParameter("@location", location));
                    Command.Parameters.Add(CreateParameter("@displayLocation", displayLocation));
                    Command.Parameters.Add(CreateParameter("@organization", organization));
                    Command.Parameters.Add(CreateParameter("@coordinates", coordinates));
                    Command.Parameters.Add(CreateParameter("@synchronization", synchronization));
                    Command.Parameters.Add(CreateParameter("@serviceArea", serviceArea));
                    Command.Parameters.Add(CreateParameter("@accessPolicy", accessPolicy));
                    Command.Parameters.Add(CreateParameter("@accessDetails", accessDetails));
                    Command.Parameters.Add(CreateParameter("@notification", item.ShouldNotify));
                    Command.Parameters.Add(CreateParameter("@autoKeyUrl", autoKeyUrl));
                    Command.Parameters.Add(CreateParameter("@symmetricKeyType", symmetricKeyType));
                    Command.Parameters.Add(CreateParameter("@symmetricKeyURL", symmetricKeyUrl));
                    Command.Parameters.Add(CreateParameter("@serverContact", serverContact));
                    Command.Parameters.Add(CreateParameter("@providerPage", providerPage));
                    Command.Parameters.Add(CreateParameter("@providerUrl", providerUrl));
                    Command.Parameters.Add(CreateParameter("@updated", item.Updated));
                    Command.Prepare();
                    Log.SqlExecute(Command.CommandText, Command.Parameters);
                    Command.ExecuteNonQuery();
                    item.SetId(item.Id);
                }
                catch (Exception e)
                {
                    Log.InsertError(TableName, e);
                }
                finally
                {
                    Close();
                }
            }
        }

Here is the call graph for this function:

override void Ntp.Analyzer.Data.Sql.TimeServerDatabaseMapper.ReadContent ( )

inlineprotectedvirtual

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

Definition at line 195 of file TimeServerDatabaseMapper.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"]);
                    int stratum = Convert.ToInt32(Reader["stratum"]);
                    string countryCode = Reader["countryCode"].ToString();
                    string hostName = Reader["hostName"].ToString();
                    string ip4 = Reader["ip"] != DBNull.Value ? Reader["ip"].ToString() : null;
                    string ip6 = Reader["ip6"] != DBNull.Value ? Reader["ip6"].ToString() : null;
                    bool? useDns = Reader["dns"] != DBNull.Value ? Convert.ToBoolean(Reader["dns"]) : (bool?) null;
                    bool? poolMember = Reader["pool"] != DBNull.Value ? Convert.ToBoolean(Reader["pool"]) : (bool?) null;
                    string location = Reader["location"].ToString();
                    string displayLocation = Reader["displayLocation"].ToString();
                    string organization = Reader["organization"] != DBNull.Value
                        ? Reader["organization"].ToString()
                        : null;
                    string coordinates = Reader["coordinates"] != DBNull.Value
                        ? Reader["organization"].ToString()
                        : null;
                    string synchronization = Reader["synchronization"].ToString();
                    string serviceArea = Reader["serviceArea"].ToString();
                    string accessPolicy = Reader["accessPolicy"].ToString();
                    string accessDetails = Reader["accessDetails"] != DBNull.Value
                        ? Reader["accessDetails"].ToString()
                        : null;
                    bool? notification = Reader["noti"] != DBNull.Value
                        ? Convert.ToBoolean(Reader["noti"])
                        : (bool?) null;
                    string autoKeyUrl = Reader["autoKeyUrl"] != DBNull.Value ? Reader["autoKeyUrl"].ToString() : null;
                    string symmetricKeyType = Reader["symmetricKeyType"] != DBNull.Value
                        ? Reader["symmetricKeyType"].ToString()
                        : null;
                    string symmetricKeyUrl = Reader["symmetricKeyURL"] != DBNull.Value
                        ? Reader["symmetricKeyURL"].ToString()
                        : null;
                    string serverContact = Reader["serverContact"] != DBNull.Value
                        ? Reader["serverContact"].ToString()
                        : null;
                    string providerPage = Reader["providerPage"] != DBNull.Value
                        ? Reader["providerPage"].ToString()
                        : null;
                    string providerUrl = Reader["providerUrl"] != DBNull.Value
                        ? Reader["providerUrl"].ToString()
                        : null;
                    DateTime updated = Convert.ToDateTime(Reader["updated"]);

                    IPAddress address = null;
                    if (ip4 != null)
                        IPAddress.TryParse(ip4, out address);

                    var server = new CalgaryTimeServer(
                        id, stratum, countryCode, hostName, address, ip6, useDns, poolMember, location,
                        displayLocation, organization, coordinates, synchronization, serviceArea, accessDetails,
                        accessPolicy, notification, autoKeyUrl, symmetricKeyType, symmetricKeyUrl, serverContact,
                        providerPage, providerUrl, updated);

                    AddItem(server);
                }
            }
            catch (Exception e)
            {
                Log.ReadError(TableName, e);
            }
            finally
            {
                Close();
            }
        }

override void Ntp.Analyzer.Data.Sql.TimeServerDatabaseMapper.Update ( TimeServer  item )

inlineprotected

Definition at line 272 of file TimeServerDatabaseMapper.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.TimeServerDatabaseMapper.CreateSql

protected

Initial value:

=> "CREATE TABLE timeServer ( " +
                                               "    id INT NOT NULL PRIMARY KEY, " +
                                               "    stratum INT NOT NULL, " +
                                               "    countryCode CHAR(7) NOT NULL, " +
                                               "    hostName VARCHAR(50) NOT NULL, " +
                                               "    ip VARCHAR(15) NULL, " +
                                               "    ip6 VARCHAR(30) NULL, " +
                                               "    useDns BIT(1) NULL, " +
                                               "    poolMember BIT(1) NULL, " +
                                               "    location VARCHAR(100) NULL, " +
                                               "    displayLocation VARCHAR(60) NOT NULL, " +
                                               "    organization VARCHAR(50) NULL, " +
                                               "    coordinates VARCHAR(50) NULL, " +
                                               "    synchronization VARCHAR(255) NULL, " +
                                               "    serviceArea VARCHAR(100) NULL, " +
                                               "    accessPolicy VARCHAR(255) NULL, " +
                                               "    accessDetails VARCHAR(512) NULL, " +
                                               "    notification BIT(1) NULL, " +
                                               "    autoKeyUrl VARCHAR(255) NULL, " +
                                               "    symmetricKeyType VARCHAR(100) NULL, " +
                                               "    symmetricKeyURL VARCHAR(100) NULL, " +
                                               "    serverContact VARCHAR(255) NULL, " +
                                               "    updated TIMESTAMP NOT NULL, " +
                                               "    providerPage VARCHAR(100) NULL, " +
                                               "    providerUrl VARCHAR(255) NULL " +
                                               "){1};"

Definition at line 70 of file TimeServerDatabaseMapper.cs.

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

private

Initial value:

=
            "INSERT INTO timeServer( id, stratum, countryCode, hostName, ip, ip6, " +
            "useDns, poolMember, location, displayLocation, organization, " +
            "coordinates, synchronization, serviceArea, accessPolicy, " +
            "accessDetails, notification, autoKeyUrl, symmetricKeyType, " +
            "symmetricKeyURL, serverContact, providerPage, providerUrl, " +
            "updated ) " +
            "VALUES ( @id, @stratum, @countryCode, @hostName, @ip, @ip6, " +
            "@useDns, @poolMember, @location, @displayLocation, @organization, " +
            "@coordinates, @synchronization, @serviceArea, @accessPolicy, " +
            "@accessDetails, @notification, @autoKeyUrl, @symmetricKeyType, " +
            "@symmetricKeyURL, @serverContact, @providerPage, @providerUrl, " +
            "@updated );"

Definition at line 52 of file TimeServerDatabaseMapper.cs.

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

private

Initial value:

=
            "SELECT id, stratum, countryCode, hostName, ip, ip6, " +
            "useDns+0 as dns, poolMember+0 as pool, location, displayLocation, organization, " +
            "coordinates, synchronization, serviceArea, accessPolicy, " +
            "accessDetails, notification+0 as noti, autoKeyUrl, symmetricKeyType, " +
            "symmetricKeyURL, serverContact, providerPage, providerUrl, " +
            "updated " +
            "FROM timeServer;"

Definition at line 43 of file TimeServerDatabaseMapper.cs.

override string Ntp.Analyzer.Data.Sql.TimeServerDatabaseMapper.TableName => "timeServer"

protected

Definition at line 68 of file TimeServerDatabaseMapper.cs.

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

protected

Definition at line 66 of file TimeServerDatabaseMapper.cs.

---

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

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