using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Data.Common;

using System.IO;

using System.Runtime.CompilerServices;

using System.Text;

using System.Threading;

using System.Threading.Tasks;

using Common.Logging;

using Npgsql.Localization;

using NpgsqlTypes;

namespace Npgsql

/// <summary>

/// Represents a SQL statement or function (stored procedure) to execute

/// against a PostgreSQL database. This class cannot be inherited.

/// </summary>

#if WITHDESIGN

[System.Drawing.ToolboxBitmapAttribute(typeof(NpgsqlCommand)), ToolboxItem(true)]

#endif

[System.ComponentModel.DesignerCategory("")]

public sealed partial class NpgsqlCommand : DbCommand, ICloneable

{

#region Fields

NpgsqlConnection _connection;

NpgsqlConnector _connector;

NpgsqlTransaction _transaction;

String _commandText;

int? _timeout;

readonly NpgsqlParameterCollection _parameters = new NpgsqlParameterCollection();

String _planName;

PrepareStatus _prepared = PrepareStatus.NotPrepared;

byte[] _preparedCommandText;

NpgsqlRowDescription _currentRowDescription;

long _lastInsertedOid;

// locals about function support so we don`t need to check it everytime a function is called.

bool _functionChecksDone;

bool _functionNeedsColumnListDefinition; // Functions don't return record by default.

UpdateRowSource _updateRowSource = UpdateRowSource.Both;

static readonly Array ParamNameCharTable;

internal Type[] ExpectedTypes { get; set; }

short[] _resultFormatCodes;

internal const int DefaultTimeout = 20;

const string AnonymousPortal = "";

static readonly ILog _log = LogManager.GetCurrentClassLogger();

#endregion Fields

#region Constructors

// Constructors

static NpgsqlCommand()

{

ParamNameCharTable = BuildParameterNameCharacterTable();

}

/// <summary>

/// Initializes a new instance of the <see cref="NpgsqlCommand">NpgsqlCommand</see> class.

/// </summary>

public NpgsqlCommand()

: this(String.Empty, null, null)

{

}

/// <summary>

/// Initializes a new instance of the <see cref="NpgsqlCommand">NpgsqlCommand</see> class with the text of the query.

/// </summary>

/// <param name="cmdText">The text of the query.</param>

public NpgsqlCommand(String cmdText)

: this(cmdText, null, null)

{

}

/// <summary>

/// Initializes a new instance of the <see cref="NpgsqlCommand">NpgsqlCommand</see> class with the text of the query and a <see cref="NpgsqlConnection">NpgsqlConnection</see>.

/// </summary>

/// <param name="cmdText">The text of the query.</param>

/// <param name="connection">A <see cref="NpgsqlConnection">NpgsqlConnection</see> that represents the connection to a PostgreSQL server.</param>

public NpgsqlCommand(String cmdText, NpgsqlConnection connection)

: this(cmdText, connection, null)

{

}

/// <summary>

/// Initializes a new instance of the <see cref="NpgsqlCommand">NpgsqlCommand</see> class with the text of the query, a <see cref="NpgsqlConnection">NpgsqlConnection</see>, and the <see cref="NpgsqlTransaction">NpgsqlTransaction</see>.

/// </summary>

/// <param name="cmdText">The text of the query.</param>

/// <param name="connection">A <see cref="NpgsqlConnection">NpgsqlConnection</see> that represents the connection to a PostgreSQL server.</param>

/// <param name="transaction">The <see cref="NpgsqlTransaction">NpgsqlTransaction</see> in which the <see cref="NpgsqlCommand">NpgsqlCommand</see> executes.</param>

public NpgsqlCommand(String cmdText, NpgsqlConnection connection, NpgsqlTransaction transaction)

}

/// <summary>

/// Used to execute internal commands.

/// </summary>

internal NpgsqlCommand(String cmdText, NpgsqlConnector connector, int commandTimeout = 20)

}

#endregion Constructors

#region Public properties

/// <summary>

/// Gets or sets the SQL statement or function (stored procedure) to execute at the data source.

/// </summary>

/// <value>The Transact-SQL statement or stored procedure to execute. The default is an empty string.</value>

[Category("Data"), DefaultValue("")]

public override String CommandText

}

/// <summary>

/// Gets or sets the wait time before terminating the attempt

/// to execute a command and generating an error.

/// </summary>

/// <value>The time (in seconds) to wait for the command to execute.

/// The default is 20 seconds.</value>

[DefaultValue(DefaultTimeout)]

public override int CommandTimeout

}

/// <summary>

/// Gets or sets a value indicating how the

/// <see cref="NpgsqlCommand.CommandText">CommandText</see> property is to be interpreted.

/// </summary>

/// <value>One of the <see cref="System.Data.CommandType">CommandType</see> values. The default is <see cref="System.Data.CommandType">CommandType.Text</see>.</value>

[Category("Data"), DefaultValue(CommandType.Text)]

public override CommandType CommandType { get; set; }

/// <summary>

/// DB connection.

/// </summary>

protected override DbConnection DbConnection

}

/// <summary>

/// Gets or sets the <see cref="NpgsqlConnection">NpgsqlConnection</see>

/// used by this instance of the <see cref="NpgsqlCommand">NpgsqlCommand</see>.

/// </summary>

/// <value>The connection to a data source. The default value is a null reference.</value>

[Category("Behavior"), DefaultValue(null)]

public new NpgsqlConnection Connection

}

/// <summary>

/// Design time visible.

/// </summary>

public override bool DesignTimeVisible { get; set; }

/// <summary>

/// Gets or sets how command results are applied to the <see cref="System.Data.DataRow">DataRow</see>

/// when used by the <see cref="System.Data.Common.DbDataAdapter.Update(DataSet)">Update</see>

/// method of the <see cref="System.Data.Common.DbDataAdapter">DbDataAdapter</see>.

/// </summary>

/// <value>One of the <see cref="System.Data.UpdateRowSource">UpdateRowSource</see> values.</value>

#if WITHDESIGN

[Category("Behavior"), DefaultValue(UpdateRowSource.Both)]

#endif

public override UpdateRowSource UpdatedRowSource

}

/// <summary>

/// Returns oid of inserted row. This is only updated when using executenonQuery and when command inserts just a single row. If table is created without oids, this will always be 0.

/// </summary>

public Int64 LastInsertedOID

{

get { return _lastInsertedOid; }

}

/// <summary>

/// Returns whether this query will execute as a prepared (compiled) query.

/// </summary>

public bool IsPrepared

}

#endregion Public properties

#region State management

volatile int _state;

/// <summary>

/// Gets the current state of the connector

/// </summary>

internal CommandState State

}

void OnConnectionStateChange(object sender, StateChangeEventArgs stateChangeEventArgs)

}

#endregion State management

#region Parameters

/// <summary>

/// Creates a new instance of an <see cref="System.Data.Common.DbParameter">DbParameter</see> object.

/// </summary>

/// <returns>An <see cref="System.Data.Common.DbParameter">DbParameter</see> object.</returns>

protected override DbParameter CreateDbParameter()

{

return CreateParameter();

}

/// <summary>

/// Creates a new instance of a <see cref="NpgsqlParameter">NpgsqlParameter</see> object.

/// </summary>

/// <returns>A <see cref="NpgsqlParameter">NpgsqlParameter</see> object.</returns>

public new NpgsqlParameter CreateParameter()

{

return new NpgsqlParameter();

}

/// <summary>

/// DB parameter collection.

/// </summary>

protected override DbParameterCollection DbParameterCollection

{

get { return Parameters; }

}

/// <summary>

/// Gets the <see cref="NpgsqlParameterCollection">NpgsqlParameterCollection</see>.

/// </summary>

/// <value>The parameters of the SQL statement or function (stored procedure). The default is an empty collection.</value>

#if WITHDESIGN

[Category("Data"), DesignerSerializationVisibility(DesignerSerializationVisibility.Content)]

#endif

public new NpgsqlParameterCollection Parameters { get { return _parameters; } }

static Array BuildParameterNameCharacterTable()

}

#endregion

#region Prepare

/// <summary>

/// Creates a prepared version of the command on a PostgreSQL server.

/// </summary>

public override void Prepare()

}

void PrepareInternal()

}

void UnPrepare()

}

#endregion Prepare

#region Query preparation

/// <summary>

/// This method substitutes the <see cref="NpgsqlCommand.Parameters">Parameters</see>, if exist, in the command

/// to their actual values.

/// The parameter name format is <b>:ParameterName</b>.

/// </summary>

/// <returns>A version of <see cref="NpgsqlCommand.CommandText">CommandText</see> with the <see cref="NpgsqlCommand.Parameters">Parameters</see> inserted.</returns>

internal byte[] GetCommandText()

{

return string.IsNullOrEmpty(_planName) ? GetCommandText(false) : GetExecuteCommandText();

}

bool CheckFunctionNeedsColumnDefinitionList()

}

void AddFunctionColumnListSupport(Stream st)

}

/// <summary>

/// Process this._commandText, trimming each distinct command and substituting paramater

/// tokens.

/// </summary>

/// <param name="prepare"></param>

/// <returns>UTF8 encoded command ready to be sent to the backend.</returns>

byte[] GetCommandText(bool prepare)

}

void AppendParameterPlaceHolders(Stream dest)

}

void AppendParameterPlaceHolder(Stream dest, NpgsqlParameter parameter, int paramNumber)

}

void AppendParameterValues(Stream dest)

}

void AppendParameterValue(Stream dest, NpgsqlParameter parameter)

}

static bool IsParamNameChar(char ch)

}

static bool IsLetter(char ch)

{

return 'a' <= ch && ch <= 'z' || 'A' <= ch && ch <= 'Z';

}

static bool IsIdentifierStart(char ch)

{

return 'a' <= ch && ch <= 'z' || 'A' <= ch && ch <= 'Z' || ch == '_' || 128 <= ch && ch <= 255;

}

static bool IsDollarTagIdentifier(char ch)

{

return 'a' <= ch && ch <= 'z' || 'A' <= ch && ch <= 'Z' || '0' <= ch && ch <= '9' || ch == '_' || 128 <= ch && ch <= 255;

}

static bool IsIdentifier(char ch)

{

return 'a' <= ch && ch <= 'z' || 'A' <= ch && ch <= 'Z' || '0' <= ch && ch <= '9' || ch == '_' || ch == '$' || 128 <= ch && ch <= 255;

}

/// <summary>

/// Append a region of a source command text to an output command, performing parameter token

/// substitutions.

/// </summary>

/// <param name="dest">Stream to which to append output.</param>

/// <param name="src">Command text.</param>

/// <param name="prepare"></param>

/// <param name="allowMultipleStatements"></param>

/// <returns>false if the query has multiple statements which are not allowed</returns>

bool AppendCommandReplacingParameterValues(Stream dest, string src, bool prepare, bool allowMultipleStatements)