public sealed class NpgsqlConnectionStringBuilder : DbConnectionStringBuilder

{

private delegate string ValueNativeToString(object value);

private class ValueDescription

{

internal readonly IComparable ImplicitDefault;

internal readonly IComparable ExplicitDefault;

internal readonly bool DefaultsDiffer;

internal readonly bool StoreInBase;

private readonly ValueNativeToString NativeToString;

/// <summary>

/// Set both ImplicitDefault and ExplicitDefault to the <paramref name="t"/>'s default value.

/// </summary>

/// <param name="t"></param>

/// <param name="storeInBase"></param>

/// <param name="nativeToString"></param>

internal ValueDescription(Type t, bool storeInBase = true, ValueNativeToString nativeToString = null)

{

ImplicitDefault = GetImplicitDefault(t);

ExplicitDefault = ImplicitDefault;

DefaultsDiffer = false;

StoreInBase = storeInBase;

NativeToString = nativeToString;

}

/// <summary>

/// Set ImplicitDefault to the default value of <paramref name="explicitDefault"/>'s type,

/// and ExplicitDefault to <paramref name="explicitDefault"/>.

/// </summary>

/// <param name="explicitDefault"></param>

/// <param name="storeInBase"></param>

/// <param name="nativeToString"></param>

internal ValueDescription(IComparable explicitDefault, bool storeInBase = true, ValueNativeToString nativeToString = null)

{

ImplicitDefault = GetImplicitDefault(explicitDefault.GetType());

ExplicitDefault = explicitDefault;

DefaultsDiffer = (ImplicitDefault.CompareTo(ExplicitDefault) != 0);

StoreInBase = storeInBase;

NativeToString = nativeToString;

}

private static IComparable GetImplicitDefault(Type t)

{

if (t == typeof(string))

{

return string.Empty;

}

else

{

return (IComparable)Activator.CreateInstance(t);

}

}

internal string ConvertNativeToString(object value)

{

string asString = value as string;

if (asString != null)

{

return asString.Trim();

}

else if (NativeToString != null)

{

return NativeToString(value);

}

else

{

return value.ToString();

}

}

}

private static readonly ResourceManager resman = new ResourceManager(MethodBase.GetCurrentMethod().DeclaringType);

private static readonly Dictionary<Keywords, ValueDescription> valueDescriptions = new Dictionary<Keywords, ValueDescription>();

private string originalConnectionString;

private const int POOL_SIZE_LIMIT = 1024;

private const int TIMEOUT_LIMIT = 1024;

static NpgsqlConnectionStringBuilder()

{

// Set up value descriptions.

// All connection string values have an implicit default (its type's default value),

// and an explicit default which can be different from its

// implicit default.

valueDescriptions.Add(Keywords.Host, new ValueDescription(typeof(string)));

valueDescriptions.Add(Keywords.Port, new ValueDescription((Int32)5432));

valueDescriptions.Add(Keywords.Protocol, new ValueDescription(typeof(ProtocolVersion), true, ProtocolVersionToString));

valueDescriptions.Add(Keywords.Database, new ValueDescription(typeof(string)));

valueDescriptions.Add(Keywords.UserName, new ValueDescription(typeof(string)));

valueDescriptions.Add(Keywords.Password, new ValueDescription(typeof(string)));

valueDescriptions.Add(Keywords.SSL, new ValueDescription(typeof(bool)));

valueDescriptions.Add(Keywords.SslMode, new ValueDescription(typeof(SslMode)));

#pragma warning disable 618

valueDescriptions.Add(Keywords.Encoding, new ValueDescription("UTF8", false));

#pragma warning restore 618

valueDescriptions.Add(Keywords.Timeout, new ValueDescription((Int32)15));

valueDescriptions.Add(Keywords.SearchPath, new ValueDescription(typeof(string)));

valueDescriptions.Add(Keywords.Pooling, new ValueDescription(true));

valueDescriptions.Add(Keywords.ConnectionLifeTime, new ValueDescription(typeof(Int32)));

valueDescriptions.Add(Keywords.MinPoolSize, new ValueDescription((Int32)1));

valueDescriptions.Add(Keywords.MaxPoolSize, new ValueDescription((Int32)20));

valueDescriptions.Add(Keywords.SyncNotification, new ValueDescription(typeof(bool)));

valueDescriptions.Add(Keywords.CommandTimeout, new ValueDescription((Int32)20));

valueDescriptions.Add(Keywords.Enlist, new ValueDescription(typeof(bool)));

valueDescriptions.Add(Keywords.PreloadReader, new ValueDescription(typeof(bool)));

valueDescriptions.Add(Keywords.UseExtendedTypes, new ValueDescription(typeof(bool)));

valueDescriptions.Add(Keywords.IntegratedSecurity, new ValueDescription(typeof(bool)));

valueDescriptions.Add(Keywords.Compatible, new ValueDescription(THIS_VERSION));

valueDescriptions.Add(Keywords.AlwaysPrepare, new ValueDescription(typeof(bool)));

}

public NpgsqlConnectionStringBuilder()

{

_password = new PasswordBytes();

this.Clear();

}

public NpgsqlConnectionStringBuilder(string connectionString)

{

_password = new PasswordBytes();

this.originalConnectionString = connectionString;

base.ConnectionString = connectionString;

CheckValues();

}

/// <summary>

/// Return an exact copy of this NpgsqlConnectionString.

/// </summary>

public NpgsqlConnectionStringBuilder Clone()

{

NpgsqlConnectionStringBuilder builder = new NpgsqlConnectionStringBuilder();

foreach (string key in this.Keys)

{

builder[key] = this[key];

}

return builder;

}

private void CheckValues()

{

if ((MaxPoolSize > 0) && (MinPoolSize > MaxPoolSize))

{

string key = GetKeyName(Keywords.MinPoolSize);

throw new ArgumentOutOfRangeException(

key, String.Format(resman.GetString("Exception_IntegerKeyValMax"), key, MaxPoolSize));

}

}

#region Parsing Functions

private static SslMode ToSslMode(object value)

{

if (value is SslMode)

{

return (SslMode) value;

}

else

{

return (SslMode) Enum.Parse(typeof (SslMode), value.ToString(), true);

}

}

private static ProtocolVersion ToProtocolVersion(object value)

{

if (value is ProtocolVersion)

{

return (ProtocolVersion) value;

}

else

{

int ver = Convert.ToInt32(value);

switch (ver)

{

case 2:

return ProtocolVersion.Version2;

case 3:

return ProtocolVersion.Version3;

default:

throw new InvalidCastException(value.ToString());

}

}

}

private static string ProtocolVersionToString(object protocolVersion)

{

switch ((ProtocolVersion)protocolVersion)

{

case ProtocolVersion.Version2:

return "2";

case ProtocolVersion.Version3:

return "3";

default:

return string.Empty;

}

}

private static int ToInt32(object value, int min, int max, Keywords keyword)

{

int v = Convert.ToInt32(value);

if (v < min)

{

string key = GetKeyName(keyword);

throw new ArgumentOutOfRangeException(

key, String.Format(resman.GetString("Exception_IntegerKeyValMin"), key, min));

}

else if (v > max)

{

string key = GetKeyName(keyword);

throw new ArgumentOutOfRangeException(

key, String.Format(resman.GetString("Exception_IntegerKeyValMax"), key, max));

}

return v;

}

private static Boolean ToBoolean(object value)

{

string text = value as string;

if (text != null)

{

switch (text.ToLowerInvariant())

{

case "t":

case "true":

case "y":

case "yes":

return true;

case "f":

case "false":

case "n":

case "no":

return false;

default:

throw new InvalidCastException(value.ToString());

}

}

else

{

return Convert.ToBoolean(value);

}

}

private Boolean ToIntegratedSecurity(object value)

{

string text = value as string;

if (text != null)

{

switch (text.ToLowerInvariant())

{

case "t":

case "true":

case "y":

case "yes":

case "sspi":

return true;

case "f":

case "false":

case "n":

case "no":

return false;

default:

throw new InvalidCastException(value.ToString());

}

}

else

{

return Convert.ToBoolean(value);

}

}

#endregion

#region Properties

private string _host;

/// <summary>

/// Gets or sets the backend server host name.

/// </summary>

public string Host

{

get { return _host; }

set { SetValue(GetKeyName(Keywords.Host), Keywords.Host, value); }

}

private int _port;

/// <summary>

/// Gets or sets the backend server port.

/// </summary>

public int Port

{

get { return _port; }

set { SetValue(GetKeyName(Keywords.Port), Keywords.Port, value); }

}

private ProtocolVersion _protocol;

/// <summary>

/// Gets or sets the specified backend communication protocol version.

/// </summary>

public ProtocolVersion Protocol

{

get { return _protocol; }

set { SetValue(GetKeyName(Keywords.Protocol), Keywords.Protocol, value); }

}

private string _database;

///<summary>

/// Gets or sets the name of the database to be used after a connection is opened.

/// </summary>

/// <value>The name of the database to be

/// used after a connection is opened.</value>

public string Database

{

get { return _database; }

set { SetValue(GetKeyName(Keywords.Database), Keywords.Database, value); }

}

private string _username;

/// <summary>

/// Gets or sets the login user name.

/// </summary>

public string UserName

{

get

{

if ((_integrated_security) && (String.IsNullOrEmpty(_username)))

_username = WindowsIdentityUserName;

return _username;

}

set { SetValue(GetKeyName(Keywords.UserName), Keywords.UserName, value); }

}

/// <summary>

/// This is a pretty horrible hack to fix https://github.com/npgsql/Npgsql/issues/133

/// In a nutshell, starting with .NET 4.5 WindowsIdentity inherits from ClaimsIdentity

/// which doesn't exist in mono, and calling UserName getter above bombs.

/// The workaround is that the function that actually deals with WindowsIdentity never

/// gets called on mono, so never gets JITted and the problem goes away.

/// </summary>

private string WindowsIdentityUserName

{

get

{

var identity = System.Security.Principal.WindowsIdentity.GetCurrent();

return identity.Name.Split('\\')[1];

}

}

private PasswordBytes _password;

/// <summary>

/// Gets or sets the login password as a UTF8 encoded byte array.

/// </summary>

public byte[] PasswordAsByteArray

{

get { return _password.PasswordAsByteArray; }

set

{

if (value == null)

{

throw new ArgumentNullException("PasswordAsByteArray");

}

_password.PasswordAsByteArray = value;

}

}

/// <summary>

/// Sets the login password as a string.

/// </summary>

public string Password

{

set { SetValue(GetKeyName(Keywords.Password), Keywords.Password, value); }

}

private bool _ssl;

/// <summary>

/// Gets or sets a value indicating whether to attempt to use SSL.

/// </summary>

public bool SSL

{

get { return _ssl; }

set { SetValue(GetKeyName(Keywords.SSL), Keywords.SSL, value); }

}

private SslMode _sslmode;

/// <summary>

/// Gets or sets a value indicating whether to attempt to use SSL.

/// </summary>

public SslMode SslMode

{

get { return _sslmode; }

set { SetValue(GetKeyName(Keywords.SslMode), Keywords.SslMode, value); }

}

/// <summary>

/// Gets the backend encoding. Always returns "UTF8".

/// </summary>

[Obsolete("UTF8 is always used regardless of this setting.")]

public string Encoding

{

#pragma warning disable 618

get { return (string)valueDescriptions[Keywords.Encoding].ExplicitDefault; }

#pragma warning restore 618

}

private int _timeout;

/// <summary>

/// Gets or sets the time to wait while trying to establish a connection

/// before terminating the attempt and generating an error.

/// </summary>

/// <value>The time (in seconds) to wait for a connection to open. The default value is 15 seconds.</value>

public int Timeout

{

get { return _timeout; }

set { SetValue(GetKeyName(Keywords.Timeout), Keywords.Timeout, value); }

}

private string _searchpath;

/// <summary>

/// Gets or sets the schema search path.

/// </summary>

public string SearchPath

{

get { return _searchpath; }

set { SetValue(GetKeyName(Keywords.SearchPath), Keywords.SearchPath, value); }

}

private bool _pooling;

/// <summary>

/// Gets or sets a value indicating whether connection pooling should be used.

/// </summary>

public bool Pooling

{

get { return _pooling; }

set { SetValue(GetKeyName(Keywords.Pooling), Keywords.Pooling, value); }

}

private int _connection_life_time;

/// <summary>

/// Gets or sets the time to wait before closing unused connections in the pool if the count

/// of all connections exeeds MinPoolSize.

/// </summary>

/// <remarks>

/// If connection pool contains unused connections for ConnectionLifeTime seconds,

/// the half of them will be closed. If there will be unused connections in a second

/// later then again the half of them will be closed and so on.

/// This strategy provide smooth change of connection count in the pool.

/// </remarks>

/// <value>The time (in seconds) to wait. The default value is 15 seconds.</value>

public int ConnectionLifeTime

{

get { return _connection_life_time; }

set { SetValue(GetKeyName(Keywords.ConnectionLifeTime), Keywords.ConnectionLifeTime, value); }

}

private int _min_pool_size;

/// <summary>

/// Gets or sets the minimum connection pool size.

/// </summary>

public int MinPoolSize

{

get { return _min_pool_size; }

set { SetValue(GetKeyName(Keywords.MinPoolSize), Keywords.MinPoolSize, value); }

}

private int _max_pool_size;

/// <summary>

/// Gets or sets the maximum connection pool size.

/// </summary>

public int MaxPoolSize

{

get { return _max_pool_size; }

set { SetValue(GetKeyName(Keywords.MaxPoolSize), Keywords.MaxPoolSize, value); }

}

private bool _sync_notification;

/// <summary>

/// Gets or sets a value indicating whether to listen for notifications and report them between command activity.

/// </summary>

public bool SyncNotification

{

get { return _sync_notification; }

set { SetValue(GetKeyName(Keywords.SyncNotification), Keywords.SyncNotification, value); }

}

private int _command_timeout;

/// <summary>

/// Gets the time to wait while trying to execute a command

/// before terminating the attempt and generating an error.

/// </summary>

/// <value>The time (in seconds) to wait for a command to complete. The default value is 20 seconds.</value>

public int CommandTimeout

{

get { return _command_timeout; }

set { SetValue(GetKeyName(Keywords.CommandTimeout), Keywords.CommandTimeout, value); }

}

private bool _enlist;

public bool Enlist

{

get { return _enlist; }

set { SetValue(GetKeyName(Keywords.Enlist), Keywords.Enlist, value); }

}

private bool _preloadReader;

/// <summary>

/// Gets or sets a value indicating whether datareaders are loaded in their entirety (for compatibility with earlier code).

/// </summary>

public bool PreloadReader

{

get { return _preloadReader; }

set { SetValue(GetKeyName(Keywords.PreloadReader), Keywords.PreloadReader, value); }

}

private bool _useExtendedTypes;

public bool UseExtendedTypes

{

get { return _useExtendedTypes; }

set { SetValue(GetKeyName(Keywords.UseExtendedTypes), Keywords.UseExtendedTypes, value); }

}

private bool _integrated_security;

public bool IntegratedSecurity

{

get { return _integrated_security; }

set

{

if (value == true)

CheckIntegratedSecuritySupport();

SetValue(GetKeyName(Keywords.IntegratedSecurity), Keywords.IntegratedSecurity, value);

}

}

/// <summary>

/// No integrated security if we're on mono and .NET 4.5 because of ClaimsIdentity,

/// see https://github.com/npgsql/Npgsql/issues/133

/// </summary>

[Conditional("NET45")]

private static void CheckIntegratedSecuritySupport()

{

if (Type.GetType("Mono.Runtime") != null)

throw new NotSupportedException("IntegratedSecurity is currently unsupported on mono and .NET 4.5 (see https://github.com/npgsql/Npgsql/issues/133)");

}

private Version _compatible;

private static readonly Version THIS_VERSION =

MethodBase.GetCurrentMethod().DeclaringType.Assembly.GetName().Version;

/// <summary>

/// Compatibilty version. When possible, behaviour caused by breaking changes will be preserved

/// if this version is less than that where the breaking change was introduced.

/// </summary>

public Version Compatible

{

get { return _compatible; }

set { SetValue(GetKeyName(Keywords.Compatible), Keywords.Compatible, value); }

}

private string _application_name;

/// <summary>

/// Gets or sets the ootional application name parameter to be sent to the backend during connection initiation.

/// </summary>

public string ApplicationName

{

get { return _application_name; }

set { SetValue(GetKeyName(Keywords.ApplicationName), Keywords.ApplicationName, value); }

}

private bool _always_prepare;

/// <summary>

/// Gets or sets a value indicating whether to silently Prepare() all commands before execution.

/// </summary>

public bool AlwaysPrepare

{

get { return _always_prepare; }

set { SetValue(GetKeyName(Keywords.AlwaysPrepare), Keywords.AlwaysPrepare, value); }

}

#endregion

private static Keywords GetKey(string key)

{

switch (key.ToUpperInvariant())

{

case "HOST":

case "SERVER":

return Keywords.Host;

case "PORT":

return Keywords.Port;

case "PROTOCOL":

return Keywords.Protocol;

case "DATABASE":

case "DB":

return Keywords.Database;

case "USERNAME":

case "USER NAME":

case "USER":

case "USERID":

case "USER ID":

case "UID":

return Keywords.UserName;

case "PASSWORD":

case "PSW":

case "PWD":

return Keywords.Password;

case "SSL":

return Keywords.SSL;

case "SSLMODE":

return Keywords.SslMode;

case "ENCODING":

#pragma warning disable 618

return Keywords.Encoding;

#pragma warning restore 618

case "TIMEOUT":

return Keywords.Timeout;

case "SEARCHPATH":

return Keywords.SearchPath;

case "POOLING":

return Keywords.Pooling;

case "CONNECTIONLIFETIME":

return Keywords.ConnectionLifeTime;

case "MINPOOLSIZE":

return Keywords.MinPoolSize;

case "MAXPOOLSIZE":

return Keywords.MaxPoolSize;

case "SYNCNOTIFICATION":

return Keywords.SyncNotification;

case "COMMANDTIMEOUT":

return Keywords.CommandTimeout;

case "ENLIST":

return Keywords.Enlist;

case "PRELOADREADER":

case "PRELOAD READER":

return Keywords.PreloadReader;

case "USEEXTENDEDTYPES":

case "USE EXTENDED TYPES":

return Keywords.UseExtendedTypes;

case "INTEGRATED SECURITY":

return Keywords.IntegratedSecurity;

case "COMPATIBLE":

return Keywords.Compatible;

case "APPLICATIONNAME":

return Keywords.ApplicationName;

case "ALWAYSPREPARE":

return Keywords.AlwaysPrepare;

default:

throw new ArgumentException(resman.GetString("Exception_WrongKeyVal"), key);

}

}

internal static string GetKeyName(Keywords keyword)

{

switch (keyword)

{

case Keywords.Host:

return "HOST";

case Keywords.Port:

return "PORT";

case Keywords.Protocol:

return "PROTOCOL";

case Keywords.Database:

return "DATABASE";

case Keywords.UserName:

return "USER ID";

case Keywords.Password:

return "PASSWORD";

case Keywords.SSL:

return "SSL";

case Keywords.SslMode:

return "SSLMODE";

#pragma warning disable 618

case Keywords.Encoding:

#pragma warning restore 618

return "ENCODING";

case Keywords.Timeout:

return "TIMEOUT";

case Keywords.SearchPath:

return "SEARCHPATH";

case Keywords.Pooling:

return "POOLING";

case Keywords.ConnectionLifeTime:

return "CONNECTIONLIFETIME";

case Keywords.MinPoolSize:

return "MINPOOLSIZE";

case Keywords.MaxPoolSize:

return "MAXPOOLSIZE";

case Keywords.SyncNotification:

return "SYNCNOTIFICATION";

case Keywords.CommandTimeout:

return "COMMANDTIMEOUT";

case Keywords.Enlist:

return "ENLIST";

case Keywords.PreloadReader:

return "PRELOADREADER";

case Keywords.UseExtendedTypes:

return "USEEXTENDEDTYPES";

case Keywords.IntegratedSecurity:

return "INTEGRATED SECURITY";

case Keywords.Compatible:

return "COMPATIBLE";

case Keywords.ApplicationName:

return "APPLICATIONNAME";

case Keywords.AlwaysPrepare:

return "ALWAYSPREPARE";

default:

return keyword.ToString().ToUpperInvariant();

}

}

internal static object GetDefaultValue(Keywords keyword)

{

return valueDescriptions[keyword].ExplicitDefault;

}

/// <summary>

/// Case insensative accessor for indivual connection string values.

/// </summary>

public override object this[string keyword]

{

get { return GetValue(GetKey(keyword)); }

set { this[GetKey(keyword)] = value; }

}

public object this[Keywords keyword]

{

get { return GetValue(keyword); }

set { SetValue(GetKeyName(keyword), keyword, value); }

}

public override bool Remove(string keyword)

{

Keywords key = GetKey(keyword);

SetValue(key, GetDefaultValue(key));

return base.Remove(keyword);

}

public bool ContainsKey(Keywords keyword)

{

return base.ContainsKey(GetKeyName(keyword));

}

/// <summary>

/// This function will set value for known key, both private member and base[key].

/// </summary>

/// <param name="keyword"></param>

/// <param name="key"></param>

/// <param name="value"></param>

/// <returns>value, coerced as needed to the stored type.</returns>

private object SetValue(string keyword, Keywords key, object value)

{

ValueDescription description;

description = valueDescriptions[key];

if (! description.StoreInBase)

{

return value;

}

if (value == null)

{

Remove(keyword);

return value;

}

value = SetValue(key, value);

// If the value matches both the parameter's default and the type's default, remove it from base,

// otherwise convert to string and set the base value.

if (

description.DefaultsDiffer ||

(description.ExplicitDefault.CompareTo((IComparable)value) != 0)

)

{

base[keyword] = description.ConvertNativeToString(value);

}

else

{

base.Remove(keyword);

}

return value;

}

/// <summary>

/// The function will modify private member only, not base[key].

/// </summary>

/// <param name="keyword"></param>

/// <param name="value"></param>

/// <returns>value, coerced as needed to the stored type.</returns>

private object SetValue(Keywords keyword, object value)

{

try

{

switch (keyword)

{

case Keywords.Host:

return this._host = Convert.ToString(value);

case Keywords.Port:

return this._port = Convert.ToInt32(value);

case Keywords.Protocol:

return this._protocol = ToProtocolVersion(value);

case Keywords.Database:

return this._database = Convert.ToString(value);

case Keywords.UserName:

return this._username = Convert.ToString(value);

case Keywords.Password:

this._password.Password = value as string;

return value as string;

case Keywords.SSL:

return this._ssl = ToBoolean(value);

case Keywords.SslMode:

return this._sslmode = ToSslMode(value);

#pragma warning disable 618

case Keywords.Encoding:

return Encoding;

#pragma warning restore 618

case Keywords.Timeout:

return this._timeout = ToInt32(value, 0, TIMEOUT_LIMIT, keyword);

case Keywords.SearchPath:

return this._searchpath = Convert.ToString(value);

case Keywords.Pooling:

return this._pooling = ToBoolean(value);

case Keywords.ConnectionLifeTime:

return this._connection_life_time = Convert.ToInt32(value);

case Keywords.MinPoolSize:

return this._min_pool_size = ToInt32(value, 0, POOL_SIZE_LIMIT, keyword);

case Keywords.MaxPoolSize:

return this._max_pool_size = ToInt32(value, 0, POOL_SIZE_LIMIT, keyword);

case Keywords.SyncNotification:

return this._sync_notification = ToBoolean(value);

case Keywords.CommandTimeout:

return this._command_timeout = Convert.ToInt32(value);

case Keywords.Enlist:

return this._enlist = ToBoolean(value);

case Keywords.PreloadReader:

return this._preloadReader = ToBoolean(value);

case Keywords.UseExtendedTypes:

return this._useExtendedTypes = ToBoolean(value);

case Keywords.IntegratedSecurity:

var v2 = ToIntegratedSecurity(value);

if (v2 == true)

CheckIntegratedSecuritySupport();

return this._integrated_security = ToIntegratedSecurity(v2);

case Keywords.Compatible:

Version ver = new Version(value.ToString());

if (ver > THIS_VERSION)

throw new ArgumentException("Attempt to set compatibility with version " + value +

" when using version " + THIS_VERSION);

return _compatible = ver;

case Keywords.ApplicationName:

return this._application_name = Convert.ToString(value);

case Keywords.AlwaysPrepare:

return this._always_prepare = Convert.ToBoolean(value);

}

}

catch (InvalidCastException exception)

{

string exception_template = string.Empty;

switch (keyword)

{

case Keywords.Port:

case Keywords.Timeout:

case Keywords.ConnectionLifeTime:

case Keywords.MinPoolSize:

case Keywords.MaxPoolSize:

case Keywords.CommandTimeout:

exception_template = resman.GetString("Exception_InvalidIntegerKeyVal");