Ntp.Data.Provider.PostgreSqlFactory Class Reference

Inheritance diagram for Ntp.Data.Provider.PostgreSqlFactory:

Collaboration diagram for Ntp.Data.Provider.PostgreSqlFactory:

Public Member Functions
override IDbCommand	CreateCommand ()
override IDbConnection	CreateConnection ()
override void	CreateDatabase ()
override IDbConnection	CreateGenericConnection ()
override IDbDataParameter	CreateParameter (string name, object value)
override string	DateAddMinutes (string dateColumn, string minuteColumn)
override string	PrepareCheckTableSql (string table)
override string	PrepareCreateTableSql (string sql)
override string	PrepareInsertSql (string sql)
override string	PrepareSql (string sql)

Package Functions
	PostgreSqlFactory ()

Static Private Member Functions
static string	BuildConnectionString (bool includeName=true)

Private Attributes
const string	CheckTableSql
const string	CreateDatabaseSql1
const string	CreateDatabaseSql2

Additional Inherited Members
Static Public Member Functions inherited from Ntp.Data.Provider.SqlDatabaseFactory
static void	Initialize (IDatabaseConfiguration factoryConfiguration)
Static Protected Attributes inherited from Ntp.Data.Provider.SqlDatabaseFactory
static IDatabaseConfiguration	Config
Properties inherited from Ntp.Data.Provider.SqlDatabaseFactory
static SqlDatabaseFactory	Instance [get]

Detailed Description

Definition at line 50 of file PostgreSqlFactory.cs.

Constructor & Destructor Documentation

Ntp.Data.Provider.PostgreSqlFactory.PostgreSqlFactory ( )

inlinepackage

Definition at line 52 of file PostgreSqlFactory.cs.

        {
        }

Member Function Documentation

static string Ntp.Data.Provider.PostgreSqlFactory.BuildConnectionString ( bool  includeName = true )

inlinestaticprivate

Definition at line 139 of file PostgreSqlFactory.cs.

References b.

        {
            if (Config.ConnectionString != null)
                return Config.ConnectionString;

            var b = new StringBuilder();
            b.Append($"Server={Config.Host};");

            if (Config.Port != null)
                b.Append($"Port={Config.Port};");

            b.Append(includeName ? $"Database={Config.Name};" : @"Database=postgres;");

            b.Append($"User Id={Config.User};");
            b.Append($"Password={Config.Pass};");

            if (Config.ConnectionTimeout.HasValue)
                b.Append($"Timeout={Config.ConnectionTimeout.Value};");

            b.Append(Config.EnableSsl ? @"SslMode=Require;" : @"SslMode=Disable;");

            if (Config.Protocol.HasValue)
                b.Append($"Protocol={Config.Protocol.Value};");

            return b.ToString();
        }

override IDbCommand Ntp.Data.Provider.PostgreSqlFactory.CreateCommand ( )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 68 of file PostgreSqlFactory.cs.

        {
            return new NpgsqlCommand();
        }

override IDbConnection Ntp.Data.Provider.PostgreSqlFactory.CreateConnection ( )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 73 of file PostgreSqlFactory.cs.

        {
            return new NpgsqlConnection(BuildConnectionString());
        }

override void Ntp.Data.Provider.PostgreSqlFactory.CreateDatabase ( )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 79 of file PostgreSqlFactory.cs.

        {
            var connection = CreateGenericConnection();
            connection.Open();

            var command = Instance.CreateCommand();
            command.Connection = connection;
            command.CommandText = string.Format(CreateDatabaseSql1, Config.Name);
            command.Prepare();
            int count = Convert.ToInt32(command.ExecuteScalar());

            if (count == 0)
            {
                command.CommandText = string.Format(CreateDatabaseSql2, Config.Name);
                command.Prepare();
                command.ExecuteNonQuery();
            }

            connection.Close();
        }

override IDbConnection Ntp.Data.Provider.PostgreSqlFactory.CreateGenericConnection ( )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 100 of file PostgreSqlFactory.cs.

        {
            return new NpgsqlConnection(BuildConnectionString(false));
        }

override IDbDataParameter Ntp.Data.Provider.PostgreSqlFactory.CreateParameter ( string  name, object  value  )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 105 of file PostgreSqlFactory.cs.

        {
            return new NpgsqlParameter(name, value);
        }

override string Ntp.Data.Provider.PostgreSqlFactory.DateAddMinutes ( string  dateColumn, string  minuteColumn  )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 110 of file PostgreSqlFactory.cs.

        {
            return $"{dateColumn} - {minuteColumn} * INTERVAL '1 minute'";
        }

override string Ntp.Data.Provider.PostgreSqlFactory.PrepareCheckTableSql ( string  table )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 115 of file PostgreSqlFactory.cs.

        {
            return PrepareSql(string.Format(CheckTableSql, Config.Name, table));
        }

override string Ntp.Data.Provider.PostgreSqlFactory.PrepareCreateTableSql ( string  sql )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 120 of file PostgreSqlFactory.cs.

        {
            string sql2 = sql.
                Replace("UNIQUE KEY", "UNIQUE").
                Replace("BIT(1)", "BOOL");

            return PrepareSql(string.Format(sql2, "SERIAL", string.Empty));
        }

override string Ntp.Data.Provider.PostgreSqlFactory.PrepareInsertSql ( string  sql )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 129 of file PostgreSqlFactory.cs.

        {
            return PrepareSql(string.Format(sql, "SELECT LASTVAL();"));
        }

override string Ntp.Data.Provider.PostgreSqlFactory.PrepareSql ( string  sql )

inlinevirtual

Implements Ntp.Data.Provider.SqlDatabaseFactory.

Definition at line 134 of file PostgreSqlFactory.cs.

        {
            return sql.Replace('[', '\"').Replace(']', '\"');
        }

Member Data Documentation

const string Ntp.Data.Provider.PostgreSqlFactory.CheckTableSql

private

Initial value:

=
            "SELECT * " +
            "FROM information_schema.tables " +
            "WHERE table_catalog = lower('{0}') " +
            "AND table_name = lower('{1}');"

Definition at line 62 of file PostgreSqlFactory.cs.

const string Ntp.Data.Provider.PostgreSqlFactory.CreateDatabaseSql1

private

Initial value:

=
            "SELECT COUNT(*) FROM pg_database WHERE datname = lower('{0}');"

Definition at line 56 of file PostgreSqlFactory.cs.

const string Ntp.Data.Provider.PostgreSqlFactory.CreateDatabaseSql2

private

Initial value:

=
            "CREATE DATABASE {0};"

Definition at line 59 of file PostgreSqlFactory.cs.

---

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

• Ntp.Data.Provider/PostgreSqlFactory.cs