using System;

using System.IO;

using System.Collections;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data.Common;

using System.Diagnostics;

using System.Diagnostics.CodeAnalysis;

using System.Linq;

using Npgsql.Internal;

using Npgsql.Netstandard20;

using Npgsql.Properties;

using Npgsql.Replication;

namespace Npgsql;

/// <summary>

/// Provides a simple way to create and manage the contents of connection strings used by

/// the <see cref="NpgsqlConnection"/> class.

/// </summary>

public sealed partial class NpgsqlConnectionStringBuilder : DbConnectionStringBuilder, IDictionary<string, object?>

{

#region Fields

/// <summary>

/// Cached DataSource value to reduce allocations on NpgsqlConnection.DataSource.get

/// </summary>

string? _dataSourceCached;

internal string DataSourceCached

=> _dataSourceCached ??= _host is null

? string.Empty

: IsUnixSocket(_host, _port, out var socketPath, replaceForAbstract: false)

? socketPath

: $"tcp://{_host}:{_port}";

TimeSpan? _hostRecheckSecondsTranslated;

internal TimeSpan HostRecheckSecondsTranslated

=> _hostRecheckSecondsTranslated ??= TimeSpan.FromSeconds(HostRecheckSeconds == 0 ? -1 : HostRecheckSeconds);

#endregion

#region Constructors

/// <summary>

/// Initializes a new instance of the NpgsqlConnectionStringBuilder class.

/// </summary>

public NpgsqlConnectionStringBuilder() => Init();

/// <summary>

/// Initializes a new instance of the NpgsqlConnectionStringBuilder class, optionally using ODBC rules for quoting values.

/// </summary>

/// <param name="useOdbcRules">true to use {} to delimit fields; false to use quotation marks.</param>

public NpgsqlConnectionStringBuilder(bool useOdbcRules) : base(useOdbcRules) => Init();

/// <summary>

/// Initializes a new instance of the NpgsqlConnectionStringBuilder class and sets its <see cref="DbConnectionStringBuilder.ConnectionString"/>.

/// </summary>

public NpgsqlConnectionStringBuilder(string? connectionString)

{

Init();

ConnectionString = connectionString;

}

// Method fake-returns an int only to make sure it's code-generated

private partial int Init();

#endregion

#region Non-static property handling

/// <summary>

/// Gets or sets the value associated with the specified key.

/// </summary>

/// <param name="keyword">The key of the item to get or set.</param>

/// <returns>The value associated with the specified key.</returns>

[AllowNull]

public override object this[string keyword]

{

get

{

if (!TryGetValue(keyword, out var value))

throw new ArgumentException("Keyword not supported: " + keyword, nameof(keyword));

return value;

}

set

{

if (value is null)

{

Remove(keyword);

return;

}

try

{

GeneratedSetter(keyword.ToUpperInvariant(), value);

}

catch (Exception e)

{

throw new ArgumentException("Couldn't set " + keyword, keyword, e);

}

}

}

// Method fake-returns an int only to make sure it's code-generated

private partial int GeneratedSetter(string keyword, object? value);

object? IDictionary<string, object?>.this[string keyword]

{

get => this[keyword];

set => this[keyword] = value!;

}

/// <summary>

/// Adds an item to the <see cref="NpgsqlConnectionStringBuilder"/>.

/// </summary>

/// <param name="item">The key-value pair to be added.</param>

public void Add(KeyValuePair<string, object?> item)

=> this[item.Key] = item.Value!;

void IDictionary<string, object?>.Add(string keyword, object? value)

=> this[keyword] = value;

/// <summary>

/// Removes the entry with the specified key from the DbConnectionStringBuilder instance.

/// </summary>

/// <param name="keyword">The key of the key/value pair to be removed from the connection string in this DbConnectionStringBuilder.</param>

/// <returns><b>true</b> if the key existed within the connection string and was removed; <b>false</b> if the key did not exist.</returns>

public override bool Remove(string keyword)

=> RemoveGenerated(keyword.ToUpperInvariant());

private partial bool RemoveGenerated(string keyword);

/// <summary>

/// Removes the entry from the DbConnectionStringBuilder instance.

/// </summary>

/// <param name="item">The key/value pair to be removed from the connection string in this DbConnectionStringBuilder.</param>

/// <returns><b>true</b> if the key existed within the connection string and was removed; <b>false</b> if the key did not exist.</returns>

public bool Remove(KeyValuePair<string, object?> item)

=> Remove(item.Key);

/// <summary>

/// Clears the contents of the <see cref="NpgsqlConnectionStringBuilder"/> instance.

/// </summary>

public override void Clear()

{

Debug.Assert(Keys != null);

foreach (var k in Keys.ToArray())

Remove(k);

}

/// <summary>

/// Determines whether the <see cref="NpgsqlConnectionStringBuilder"/> contains a specific key.

/// </summary>

/// <param name="keyword">The key to locate in the <see cref="NpgsqlConnectionStringBuilder"/>.</param>

/// <returns><b>true</b> if the <see cref="NpgsqlConnectionStringBuilder"/> contains an entry with the specified key; otherwise <b>false</b>.</returns>

public override bool ContainsKey(string keyword)

=> keyword is null

? throw new ArgumentNullException(nameof(keyword))

: ContainsKeyGenerated(keyword.ToUpperInvariant());

private partial bool ContainsKeyGenerated(string keyword);

/// <summary>

/// Determines whether the <see cref="NpgsqlConnectionStringBuilder"/> contains a specific key-value pair.

/// </summary>

/// <param name="item">The item to locate in the <see cref="NpgsqlConnectionStringBuilder"/>.</param>

/// <returns><b>true</b> if the <see cref="NpgsqlConnectionStringBuilder"/> contains the entry; otherwise <b>false</b>.</returns>

public bool Contains(KeyValuePair<string, object?> item)

=> TryGetValue(item.Key, out var value) &&

((value == null && item.Value == null) || (value != null && value.Equals(item.Value)));

/// <summary>

/// Retrieves a value corresponding to the supplied key from this <see cref="NpgsqlConnectionStringBuilder"/>.

/// </summary>

/// <param name="keyword">The key of the item to retrieve.</param>

/// <param name="value">The value corresponding to the key.</param>

/// <returns><b>true</b> if keyword was found within the connection string, <b>false</b> otherwise.</returns>

public override bool TryGetValue(string keyword, [NotNullWhen(true)] out object? value)

{

if (keyword == null)

throw new ArgumentNullException(nameof(keyword));

return TryGetValueGenerated(keyword.ToUpperInvariant(), out value);

}

private partial bool TryGetValueGenerated(string keyword, [NotNullWhen(true)] out object? value);

void SetValue(string propertyName, object? value)

{

var canonicalKeyword = ToCanonicalKeyword(propertyName.ToUpperInvariant());

if (value == null)

base.Remove(canonicalKeyword);

else

base[canonicalKeyword] = value;

}

private partial string ToCanonicalKeyword(string keyword);

#endregion

#region Properties - Connection

/// <summary>

/// The hostname or IP address of the PostgreSQL server to connect to.

/// </summary>

[Category("Connection")]

[Description("The hostname or IP address of the PostgreSQL server to connect to.")]

[DisplayName("Host")]

[NpgsqlConnectionStringProperty("Server")]

public string? Host

{

get => _host;

set

{

_host = value;

SetValue(nameof(Host), value);

_dataSourceCached = null;

}

}

string? _host;

/// <summary>

/// The TCP/IP port of the PostgreSQL server.

/// </summary>

[Category("Connection")]

[Description("The TCP port of the PostgreSQL server.")]

[DisplayName("Port")]

[NpgsqlConnectionStringProperty]

[DefaultValue(NpgsqlConnection.DefaultPort)]

public int Port

{

get => _port;

set

{

if (value <= 0)

throw new ArgumentOutOfRangeException(nameof(value), value, "Invalid port: " + value);

_port = value;

SetValue(nameof(Port), value);

_dataSourceCached = null;

}

}

int _port;

///<summary>

/// The PostgreSQL database to connect to.

/// </summary>

[Category("Connection")]

[Description("The PostgreSQL database to connect to.")]

[DisplayName("Database")]

[NpgsqlConnectionStringProperty("DB")]

public string? Database

{

get => _database;

set

{

_database = value;

SetValue(nameof(Database), value);

}

}

string? _database;

/// <summary>

/// The username to connect with. Not required if using IntegratedSecurity.

/// </summary>

[Category("Connection")]

[Description("The username to connect with. Not required if using IntegratedSecurity.")]

[DisplayName("Username")]

[NpgsqlConnectionStringProperty("User Name", "UserId", "User Id", "UID")]

public string? Username

{

get => _username;

set

{

_username = value;

SetValue(nameof(Username), value);

}

}

string? _username;

/// <summary>

/// The password to connect with. Not required if using IntegratedSecurity.

/// </summary>

[Category("Connection")]

[Description("The password to connect with. Not required if using IntegratedSecurity.")]

[PasswordPropertyText(true)]

[DisplayName("Password")]

[NpgsqlConnectionStringProperty("PSW", "PWD")]

public string? Password

{

get => _password;

set

{

_password = value;

SetValue(nameof(Password), value);

}

}

string? _password;

/// <summary>

/// Path to a PostgreSQL password file (PGPASSFILE), from which the password would be taken.

/// </summary>

[Category("Connection")]

[Description("Path to a PostgreSQL password file (PGPASSFILE), from which the password would be taken.")]

[DisplayName("Passfile")]

[NpgsqlConnectionStringProperty]

public string? Passfile

{

get => _passfile;

set

{

_passfile = value;

SetValue(nameof(Passfile), value);

}

}

string? _passfile;

/// <summary>

/// The optional application name parameter to be sent to the backend during connection initiation.

/// </summary>

[Category("Connection")]

[Description("The optional application name parameter to be sent to the backend during connection initiation")]

[DisplayName("Application Name")]

[NpgsqlConnectionStringProperty]

public string? ApplicationName

{

get => _applicationName;

set

{

_applicationName = value;

SetValue(nameof(ApplicationName), value);

}

}

string? _applicationName;

/// <summary>

/// Whether to enlist in an ambient TransactionScope.

/// </summary>

[Category("Connection")]

[Description("Whether to enlist in an ambient TransactionScope.")]

[DisplayName("Enlist")]

[DefaultValue(true)]

[NpgsqlConnectionStringProperty]

public bool Enlist

{

get => _enlist;

set

{

_enlist = value;

SetValue(nameof(Enlist), value);

}

}

bool _enlist;

/// <summary>

/// Gets or sets the schema search path.

/// </summary>

[Category("Connection")]

[Description("Gets or sets the schema search path.")]

[DisplayName("Search Path")]

[NpgsqlConnectionStringProperty]

public string? SearchPath

{

get => _searchPath;

set

{

_searchPath = value;

SetValue(nameof(SearchPath), value);

}

}

string? _searchPath;

/// <summary>

/// Gets or sets the client_encoding parameter.

/// </summary>

[Category("Connection")]

[Description("Gets or sets the client_encoding parameter.")]

[DisplayName("Client Encoding")]

[NpgsqlConnectionStringProperty]

public string? ClientEncoding

{

get => _clientEncoding;

set

{

_clientEncoding = value;

SetValue(nameof(ClientEncoding), value);

}

}

string? _clientEncoding;

/// <summary>

/// Gets or sets the .NET encoding that will be used to encode/decode PostgreSQL string data.

/// </summary>

[Category("Connection")]

[Description("Gets or sets the .NET encoding that will be used to encode/decode PostgreSQL string data.")]

[DisplayName("Encoding")]

[DefaultValue("UTF8")]

[NpgsqlConnectionStringProperty]

public string Encoding

{

get => _encoding;

set

{

_encoding = value;

SetValue(nameof(Encoding), value);

}

}

string _encoding = "UTF8";

/// <summary>

/// Gets or sets the PostgreSQL session timezone, in Olson/IANA database format.

/// </summary>

[Category("Connection")]

[Description("Gets or sets the PostgreSQL session timezone, in Olson/IANA database format.")]

[DisplayName("Timezone")]

[NpgsqlConnectionStringProperty]

public string? Timezone

{

get => _timezone;

set

{

_timezone = value;

SetValue(nameof(Timezone), value);

}

}

string? _timezone;

#endregion

#region Properties - Security

/// <summary>

/// Controls whether SSL is required, disabled or preferred, depending on server support.

/// </summary>

[Category("Security")]

[Description("Controls whether SSL is required, disabled or preferred, depending on server support.")]

[DisplayName("SSL Mode")]

[DefaultValue(SslMode.Prefer)]

[NpgsqlConnectionStringProperty]

public SslMode SslMode

{

get => _sslMode;

set

{

_sslMode = value;

SetValue(nameof(SslMode), value);

}

}

SslMode _sslMode;

/// <summary>

/// Whether to trust the server certificate without validating it.

/// </summary>

[Category("Security")]

[Description("Whether to trust the server certificate without validating it.")]

[DisplayName("Trust Server Certificate")]

[NpgsqlConnectionStringProperty]

public bool TrustServerCertificate

{

get => _trustServerCertificate;

set

{

_trustServerCertificate = value;

SetValue(nameof(TrustServerCertificate), value);

}

}

bool _trustServerCertificate;

/// <summary>

/// Location of a client certificate to be sent to the server.

/// </summary>

[Category("Security")]

[Description("Location of a client certificate to be sent to the server.")]

[DisplayName("SSL Certificate")]

[NpgsqlConnectionStringProperty]

public string? SslCertificate

{

get => _sslCertificate;

set

{

_sslCertificate = value;

SetValue(nameof(SslCertificate), value);

}

}

string? _sslCertificate;

/// <summary>

/// Location of a client key for a client certificate to be sent to the server.

/// </summary>

[Category("Security")]

[Description("Location of a client key for a client certificate to be sent to the server.")]

[DisplayName("SSL Key")]

[NpgsqlConnectionStringProperty]

public string? SslKey

{

get => _sslKey;

set

{

_sslKey = value;

SetValue(nameof(SslKey), value);

}

}

string? _sslKey;

/// <summary>

/// Password for a key for a client certificate.

/// </summary>

[Category("Security")]

[Description("Password for a key for a client certificate.")]

[DisplayName("SSL Password")]

[NpgsqlConnectionStringProperty]

public string? SslPassword

{

get => _sslPassword;

set

{

_sslPassword = value;

SetValue(nameof(SslPassword), value);

}

}

string? _sslPassword;

/// <summary>

/// Location of a CA certificate used to validate the server certificate.

/// </summary>

[Category("Security")]

[Description("Location of a CA certificate used to validate the server certificate.")]

[DisplayName("Root Certificate")]

[NpgsqlConnectionStringProperty]

public string? RootCertificate

{

get => _rootCertificate;

set

{

_rootCertificate = value;

SetValue(nameof(RootCertificate), value);

}

}

string? _rootCertificate;

/// <summary>

/// Whether to check the certificate revocation list during authentication.

/// False by default.

/// </summary>

[Category("Security")]

[Description("Whether to check the certificate revocation list during authentication.")]

[DisplayName("Check Certificate Revocation")]

[NpgsqlConnectionStringProperty]

public bool CheckCertificateRevocation

{

get => _checkCertificateRevocation;

set

{

_checkCertificateRevocation = value;

SetValue(nameof(CheckCertificateRevocation), value);

}

}

bool _checkCertificateRevocation;

/// <summary>

/// Whether to use Windows integrated security to log in.

/// </summary>

[Category("Security")]

[Description("Whether to use Windows integrated security to log in.")]

[DisplayName("Integrated Security")]

[NpgsqlConnectionStringProperty]

public bool IntegratedSecurity

{

get => _integratedSecurity;

set

{

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

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

if (value && 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)");

_integratedSecurity = value;

SetValue(nameof(IntegratedSecurity), value);

}

}

bool _integratedSecurity;

/// <summary>

/// The Kerberos service name to be used for authentication.

/// </summary>

[Category("Security")]

[Description("The Kerberos service name to be used for authentication.")]

[DisplayName("Kerberos Service Name")]

[NpgsqlConnectionStringProperty("Krbsrvname")]

[DefaultValue("postgres")]

public string KerberosServiceName

{

get => _kerberosServiceName;

set

{

_kerberosServiceName = value;

SetValue(nameof(KerberosServiceName), value);

}

}

string _kerberosServiceName = "postgres";

/// <summary>

/// The Kerberos realm to be used for authentication.

/// </summary>

[Category("Security")]

[Description("The Kerberos realm to be used for authentication.")]

[DisplayName("Include Realm")]

[NpgsqlConnectionStringProperty]

public bool IncludeRealm

{

get => _includeRealm;

set

{

_includeRealm = value;

SetValue(nameof(IncludeRealm), value);

}

}

bool _includeRealm;

/// <summary>

/// Gets or sets a Boolean value that indicates if security-sensitive information, such as the password, is not returned as part of the connection if the connection is open or has ever been in an open state.

/// </summary>

[Category("Security")]

[Description("Gets or sets a Boolean value that indicates if security-sensitive information, such as the password, is not returned as part of the connection if the connection is open or has ever been in an open state.")]

[DisplayName("Persist Security Info")]

[NpgsqlConnectionStringProperty]

public bool PersistSecurityInfo

{

get => _persistSecurityInfo;

set

{

_persistSecurityInfo = value;

SetValue(nameof(PersistSecurityInfo), value);

}

}

bool _persistSecurityInfo;

/// <summary>

/// When enabled, parameter values are logged when commands are executed. Defaults to false.

/// </summary>

[Category("Security")]

[Description("When enabled, parameter values are logged when commands are executed. Defaults to false.")]

[DisplayName("Log Parameters")]

[NpgsqlConnectionStringProperty]

public bool LogParameters

{

get => _logParameters;

set

{

_logParameters = value;

SetValue(nameof(LogParameters), value);

}

}

bool _logParameters;

internal const string IncludeExceptionDetailDisplayName = "Include Error Detail";

/// <summary>

/// When enabled, PostgreSQL error details are included on <see cref="PostgresException.Detail" /> and

/// <see cref="PostgresNotice.Detail" />. These can contain sensitive data.

/// </summary>

[Category("Security")]

[Description("When enabled, PostgreSQL error and notice details are included on PostgresException.Detail and PostgresNotice.Detail. These can contain sensitive data.")]

[DisplayName(IncludeExceptionDetailDisplayName)]

[NpgsqlConnectionStringProperty]

public bool IncludeErrorDetail

{

get => _includeErrorDetail;

set

{

_includeErrorDetail = value;

SetValue(nameof(IncludeErrorDetail), value);

}

}

bool _includeErrorDetail;

#endregion

#region Properties - Pooling

/// <summary>

/// Whether connection pooling should be used.

/// </summary>

[Category("Pooling")]

[Description("Whether connection pooling should be used.")]

[DisplayName("Pooling")]

[NpgsqlConnectionStringProperty]

[DefaultValue(true)]

public bool Pooling

{

get => _pooling;

set

{

_pooling = value;

SetValue(nameof(Pooling), value);

}

}

bool _pooling;

/// <summary>

/// The minimum connection pool size.

/// </summary>

[Category("Pooling")]

[Description("The minimum connection pool size.")]

[DisplayName("Minimum Pool Size")]

[NpgsqlConnectionStringProperty]

[DefaultValue(0)]

public int MinPoolSize

{

get => _minPoolSize;

set

{

if (value < 0)

throw new ArgumentOutOfRangeException(nameof(value), value, "MinPoolSize can't be negative");

_minPoolSize = value;

SetValue(nameof(MinPoolSize), value);

}

}

int _minPoolSize;

/// <summary>

/// The maximum connection pool size.

/// </summary>

[Category("Pooling")]

[Description("The maximum connection pool size.")]

[DisplayName("Maximum Pool Size")]

[NpgsqlConnectionStringProperty]

[DefaultValue(100)]

public int MaxPoolSize

{

get => _maxPoolSize;

set

{

if (value < 0)

throw new ArgumentOutOfRangeException(nameof(value), value, "MaxPoolSize can't be negative");

_maxPoolSize = value;

SetValue(nameof(MaxPoolSize), value);

}

}

int _maxPoolSize;

/// <summary>

/// The time to wait before closing idle connections in the pool if the count

/// of all connections exceeds MinPoolSize.

/// </summary>

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

[Category("Pooling")]

[Description("The time to wait before closing unused connections in the pool if the count of all connections exceeds MinPoolSize.")]

[DisplayName("Connection Idle Lifetime")]

[NpgsqlConnectionStringProperty]

[DefaultValue(300)]

public int ConnectionIdleLifetime

{

get => _connectionIdleLifetime;

set

{

_connectionIdleLifetime = value;

SetValue(nameof(ConnectionIdleLifetime), value);

}

}

int _connectionIdleLifetime;

/// <summary>

/// How many seconds the pool waits before attempting to prune idle connections that are beyond

/// idle lifetime (<see cref="ConnectionIdleLifetime"/>.

/// </summary>

/// <value>The interval (in seconds). The default value is 10.</value>

[Category("Pooling")]

[Description("How many seconds the pool waits before attempting to prune idle connections that are beyond idle lifetime.")]

[DisplayName("Connection Pruning Interval")]

[NpgsqlConnectionStringProperty]

[DefaultValue(10)]

public int ConnectionPruningInterval

{

get => _connectionPruningInterval;

set

{

_connectionPruningInterval = value;

SetValue(nameof(ConnectionPruningInterval), value);

}

}

int _connectionPruningInterval;

/// <summary>

/// The total maximum lifetime of connections (in seconds). Connections which have exceeded this value will be

/// destroyed instead of returned from the pool. This is useful in clustered configurations to force load

/// balancing between a running server and a server just brought online.

/// </summary>

/// <value>The time (in seconds) to wait, or 0 to to make connections last indefinitely (the default).</value>

[Category("Pooling")]

[Description("The total maximum lifetime of connections (in seconds).")]

[DisplayName("Connection Lifetime")]

[NpgsqlConnectionStringProperty("Load Balance Timeout")]

public int ConnectionLifetime

{

get => _connectionLifetime;

set

{

_connectionLifetime = value;

SetValue(nameof(ConnectionLifetime), value);

}

}

int _connectionLifetime;

#endregion

#region Properties - Timeouts

/// <summary>

/// The time to wait (in seconds) while trying to establish a connection before terminating the attempt and generating an error.

/// Defaults to 15 seconds.

/// </summary>

[Category("Timeouts")]

[Description("The time to wait (in seconds) while trying to establish a connection before terminating the attempt and generating an error.")]

[DisplayName("Timeout")]

[NpgsqlConnectionStringProperty]

[DefaultValue(DefaultTimeout)]

public int Timeout

{

get => _timeout;

set

{

if (value < 0 || value > NpgsqlConnection.TimeoutLimit)

throw new ArgumentOutOfRangeException(nameof(value), value, "Timeout must be between 0 and " + NpgsqlConnection.TimeoutLimit);

_timeout = value;

SetValue(nameof(Timeout), value);

}

}

int _timeout;

internal const int DefaultTimeout = 15;

/// <summary>

/// The time to wait (in seconds) while trying to execute a command before terminating the attempt and generating an error.

/// Defaults to 30 seconds.

/// </summary>

[Category("Timeouts")]

[Description("The time to wait (in seconds) while trying to execute a command before terminating the attempt and generating an error. Set to zero for infinity.")]

[DisplayName("Command Timeout")]

[NpgsqlConnectionStringProperty]

[DefaultValue(NpgsqlCommand.DefaultTimeout)]

public int CommandTimeout

{

get => _commandTimeout;

set

{

if (value < 0)

throw new ArgumentOutOfRangeException(nameof(value), value, "CommandTimeout can't be negative");

_commandTimeout = value;

SetValue(nameof(CommandTimeout), value);

}

}

int _commandTimeout;

/// <summary>

/// The time to wait (in seconds) while trying to execute a an internal command before terminating the attempt and generating an error.

/// </summary>

[Category("Timeouts")]

[Description("The time to wait (in seconds) while trying to execute a an internal command before terminating the attempt and generating an error. -1 uses CommandTimeout, 0 means no timeout.")]

[DisplayName("Internal Command Timeout")]

[NpgsqlConnectionStringProperty]

[DefaultValue(-1)]

public int InternalCommandTimeout

{

get => _internalCommandTimeout;

set

{

if (value != 0 && value != -1 && value < NpgsqlConnector.MinimumInternalCommandTimeout)

throw new ArgumentOutOfRangeException(nameof(value), value,

$"InternalCommandTimeout must be >= {NpgsqlConnector.MinimumInternalCommandTimeout}, 0 (infinite) or -1 (use CommandTimeout)");

_internalCommandTimeout = value;

SetValue(nameof(InternalCommandTimeout), value);

}

}

int _internalCommandTimeout;

/// <summary>

/// The time to wait (in milliseconds) while trying to read a response for a cancellation request for a timed out or cancelled query, before terminating the attempt and generating an error.

/// Zero for infinity, -1 to skip the wait.

/// Defaults to 2000 milliseconds.

/// </summary>

[Category("Timeouts")]

[Description("After Command Timeout is reached (or user supplied cancellation token is cancelled) and command cancellation is attempted, Npgsql waits for this additional timeout (in milliseconds) before breaking the connection. Defaults to 2000, set to zero for infinity.")]

[DisplayName("Cancellation Timeout")]

[NpgsqlConnectionStringProperty]

[DefaultValue(2000)]

public int CancellationTimeout

{

get => _cancellationTimeout;

set

{

if (value < -1)

throw new ArgumentOutOfRangeException(nameof(value), value, $"{nameof(CancellationTimeout)} can't less than -1");

_cancellationTimeout = value;

SetValue(nameof(CancellationTimeout), value);

}

}

int _cancellationTimeout;

#endregion

#region Properties - Failover and load balancing

/// <summary>

/// Determines the preferred PostgreSQL target server type.

/// </summary>

[Category("Failover and load balancing")]

[Description("Determines the preferred PostgreSQL target server type.")]

[DisplayName("Target Session Attributes")]

[NpgsqlConnectionStringProperty]

public string? TargetSessionAttributes

{

get => TargetSessionAttributesParsed switch

{

Npgsql.TargetSessionAttributes.Any => "any",

Npgsql.TargetSessionAttributes.Primary => "primary",

Npgsql.TargetSessionAttributes.Standby => "standby",

Npgsql.TargetSessionAttributes.PreferPrimary => "prefer-primary",

Npgsql.TargetSessionAttributes.PreferStandby => "prefer-standby",

Npgsql.TargetSessionAttributes.ReadWrite => "read-write",

Npgsql.TargetSessionAttributes.ReadOnly => "read-only",

null => null,

_ => throw new ArgumentException($"Unhandled enum value '{TargetSessionAttributesParsed}'")

};

set

{

TargetSessionAttributesParsed = value is null ? null : ParseTargetSessionAttributes(value);

SetValue(nameof(TargetSessionAttributes), value);

}

}

internal TargetSessionAttributes? TargetSessionAttributesParsed { get; private set; }

internal static TargetSessionAttributes ParseTargetSessionAttributes(string s)

=> s switch

{

"any" => Npgsql.TargetSessionAttributes.Any,

"primary" => Npgsql.TargetSessionAttributes.Primary,

"standby" => Npgsql.TargetSessionAttributes.Standby,

"prefer-primary" => Npgsql.TargetSessionAttributes.PreferPrimary,

"prefer-standby" => Npgsql.TargetSessionAttributes.PreferStandby,

"read-write" => Npgsql.TargetSessionAttributes.ReadWrite,

"read-only" => Npgsql.TargetSessionAttributes.ReadOnly,

_ => throw new ArgumentException($"TargetSessionAttributes contains an invalid value '{s}'")

};

/// <summary>

/// Enables balancing between multiple hosts by round-robin.

/// </summary>

[Category("Failover and load balancing")]

[Description("Enables balancing between multiple hosts by round-robin.")]

[DisplayName("Load Balance Hosts")]

[NpgsqlConnectionStringProperty]

public bool LoadBalanceHosts

{

get => _loadBalanceHosts;

set

{

_loadBalanceHosts = value;

SetValue(nameof(LoadBalanceHosts), value);

}

}

bool _loadBalanceHosts;

/// <summary>

/// Controls for how long the host's cached state will be considered as valid.

/// </summary>

[Category("Failover and load balancing")]

[Description("Controls for how long the host's cached state will be considered as valid.")]

[DisplayName("Host Recheck Seconds")]

[DefaultValue(10)]

[NpgsqlConnectionStringProperty]

public int HostRecheckSeconds

{

get => _hostRecheckSeconds;

set

{

if (value < 0)

throw new ArgumentException($"{HostRecheckSeconds} cannot be negative", nameof(HostRecheckSeconds));

_hostRecheckSeconds = value;

SetValue(nameof(HostRecheckSeconds), value);

_hostRecheckSecondsTranslated = null;

}

}

int _hostRecheckSeconds;

#endregion Properties - Failover and load balancing

#region Properties - Entity Framework