#region License

#endregion

using System;

using System.Collections;

using System.Collections.Generic;

using System.Data;

using System.Data.Common;

using System.Diagnostics.Contracts;

using System.IO;

using System.Linq;

using System.Runtime.CompilerServices;

using System.Reflection;

using System.Text;

using System.Threading;

using System.Threading.Tasks;

using AsyncRewriter;

using Npgsql.BackendMessages;

using Npgsql.TypeHandlers;

using Npgsql.TypeHandlers.NumericHandlers;

using Npgsql.Logging;

using NpgsqlTypes;

namespace Npgsql

/// <summary>

/// Reads a forward-only stream of rows from a data source.

/// </summary>

public partial class NpgsqlDataReader : DbDataReader

{

internal NpgsqlCommand Command { get; private set; }

readonly NpgsqlConnector _connector;

readonly NpgsqlConnection _connection;

readonly CommandBehavior _behavior;

ReaderState State { get; set; }

/// <summary>

/// Holds the list of statements being executed by this reader.

/// </summary>

readonly List<NpgsqlStatement> _statements;

/// <summary>

/// The index of the current query resultset we're processing (within a multiquery)

/// </summary>

int _statementIndex;

/// <summary>

/// The RowDescription message for the current resultset being processed

/// </summary>

RowDescriptionMessage _rowDescription;

DataRowMessage _row;

uint? _recordsAffected;

/// <summary>

/// Indicates that at least one row has been read across all result sets

/// </summary>

bool _readOneRow;

/// <summary>

/// Whether the current result set has rows

/// </summary>

bool? _hasRows;

/// <summary>

/// If HasRows was called before any rows were read, it was forced to read messages. A pending

/// message may be stored here for processing in the next Read() or NextResult().

/// </summary>

IBackendMessage _pendingMessage;

#if !DNXCORE50

/// <summary>

/// If <see cref="GetSchemaTable"/> has been called, its results are cached here.

/// </summary>

DataTable _cachedSchemaTable;

#endif

/// <summary>

/// Is raised whenever Close() is called.

/// </summary>

public event EventHandler ReaderClosed;

/// <summary>

/// In non-sequential mode, contains the cached values already read from the current row

/// </summary>

readonly RowCache _rowCache;

// static readonly NpgsqlLogger Log = NpgsqlLogManager.GetCurrentClassLogger();

internal bool IsSequential { get { return (_behavior & CommandBehavior.SequentialAccess) != 0; } }

internal bool IsCaching { get { return !IsSequential; } }

internal bool IsSchemaOnly { get { return (_behavior & CommandBehavior.SchemaOnly) != 0; } }

internal NpgsqlDataReader(NpgsqlCommand command, CommandBehavior behavior, List<NpgsqlStatement> statements)

}

[RewriteAsync]

internal void Init()

}

#region Read

/// <summary>

/// Advances the reader to the next record in a result set.

/// </summary>

/// <returns><b>true</b> if there are more rows; otherwise <b>false</b>.</returns>

/// <remarks>

/// The default position of a data reader is before the first record. Therefore, you must call Read to begin accessing data.

/// </remarks>

public override bool Read()

{

return ReadInternal();

}

/// <summary>

/// This is the asynchronous version of <see cref="Read"/> The cancellation token is currently ignored.

/// </summary>

/// <param name="cancellationToken">Ignored for now.</param>

/// <returns>A task representing the asynchronous operation.</returns>

public override async Task<bool> ReadAsync(CancellationToken cancellationToken)

{

return await ReadInternalAsync().ConfigureAwait(false);

}

[RewriteAsync]

bool ReadInternal()

}

ReadResult ProcessMessage(IBackendMessage msg)

}

#endregion

#region NextResult

/// <summary>

/// Advances the reader to the next result when reading the results of a batch of statements.

/// </summary>

/// <returns></returns>

public override sealed bool NextResult()

{

return IsSchemaOnly ? NextResultSchemaOnly() : NextResultInternal();

}

/// <summary>

/// This is the asynchronous version of NextResult.

/// The <paramref name="cancellationToken"/> parameter is currently ignored.

/// </summary>

/// <param name="cancellationToken">Currently ignored.</param>

/// <returns>A task representing the asynchronous operation.</returns>

public override async sealed Task<bool> NextResultAsync(CancellationToken cancellationToken)

{

return IsSchemaOnly ? NextResultSchemaOnly() : await NextResultInternalAsync().ConfigureAwait(false);

}

[RewriteAsync]

bool NextResultInternal()

}

/// <summary>

/// Note that in SchemaOnly mode there are no resultsets, and we read nothing from the backend (all

/// RowDescriptions have already been processed and are available)

/// </summary>

bool NextResultSchemaOnly()

}

#endregion

[RewriteAsync]

IBackendMessage ReadMessage()

}

[RewriteAsync]

IBackendMessage SkipUntil(BackendMessageCode stopAt)

}

[RewriteAsync]

IBackendMessage SkipUntil(BackendMessageCode stopAt1, BackendMessageCode stopAt2)

}

/// <summary>

/// Gets a value indicating the depth of nesting for the current row. Always returns zero.

/// </summary>

public override Int32 Depth

{

get { return 0; }

}

/// <summary>

/// Gets a value indicating whether the data reader is closed.

/// </summary>

public override bool IsClosed

{

get { return State == ReaderState.Closed; }

}

/// <summary>

/// Gets the number of rows changed, inserted, or deleted by execution of the SQL statement.

/// </summary>

public override int RecordsAffected

{

get { return _recordsAffected.HasValue ? (int)_recordsAffected.Value : -1; }

}

/// <summary>

/// Returns details about each statement that this reader will or has executed.

/// </summary>

/// <remarks>

/// Note that some fields (i.e. rows and oid) are only populated as the reader

/// traverses the result.

///

/// For commands with multiple queries, this exposes the number of rows affected on

/// a statement-by-statement basis, unlike <see cref="NpgsqlDataReader.RecordsAffected"/>

/// which exposes an aggregation across all statements.

/// </remarks>

public IReadOnlyList<NpgsqlStatement> Statements { get { return _statements.AsReadOnly(); } }

/// <summary>

/// Gets a value that indicates whether this DbDataReader contains one or more rows.

/// </summary>

public override bool HasRows

}

/// <summary>

/// Indicates whether the reader is currently positioned on a row, i.e. whether reading a

/// column is possible.

/// This property is different from <see cref="HasRows"/> in that <see cref="HasRows"/> will

/// return true even if attempting to read a column will fail, e.g. before <see cref="Read"/>

/// has been called

/// </summary>

public bool IsOnRow { get { return _row != null; } }

/// <summary>

/// Gets the name of the column, given the zero-based column ordinal.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The name of the specified column.</returns>

public override string GetName(int ordinal)

}

/// <summary>

/// Gets the number of columns in the current row.

/// </summary>

public override int FieldCount

}

#region Cleanup / Dispose

/// <summary>

/// Consumes all result sets for this reader, leaving the connector ready for sending and processing further

/// queries

/// </summary>

[RewriteAsync]

void Consume()

}

/// <summary>

/// Closes the <see cref="NpgsqlDataReader"/> object.

/// </summary>

public override void Close()

}

internal void Cleanup()

}

#endregion

/// <summary>

/// Returns the current row, or throws an exception if a row isn't available

/// </summary>

private DataRowMessage Row

}

#region Simple value getters

/// <summary>

/// Gets the value of the specified column as a Boolean.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override bool GetBoolean(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a byte.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override byte GetByte(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a single character.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override char GetChar(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a 16-bit signed integer.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override short GetInt16(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a 32-bit signed integer.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override int GetInt32(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a 64-bit signed integer.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override long GetInt64(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a <see cref="DateTime"/> object.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override DateTime GetDateTime(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as an instance of <see cref="string"/>.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override string GetString(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a <see cref="decimal"/> object.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override decimal GetDecimal(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a double-precision floating point number.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override double GetDouble(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a single-precision floating point number.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override float GetFloat(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a globally-unique identifier (GUID).

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override Guid GetGuid(int ordinal)

}

/// <summary>

/// Populates an array of objects with the column values of the current row.

/// </summary>

/// <param name="values">An array of Object into which to copy the attribute columns.</param>

/// <returns>The number of instances of <see cref="object"/> in the array.</returns>

public override int GetValues(object[] values)

}

/// <summary>

/// Gets the value of the specified column as an instance of <see cref="object"/>.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public override object this[int ordinal]

{

get

{

CheckRowAndOrdinal(ordinal);

Contract.EndContractBlock();

return GetValue(ordinal);

}

}

#endregion

#region Provider-specific type getters

/// <summary>

/// Gets the value of the specified column as an <see cref="NpgsqlDate"/>,

/// Npgsql's provider-specific type for dates.

/// </summary>

/// <remarks>

/// PostgreSQL's date type represents dates from 4713 BC to 5874897 AD, while .NET's DateTime

/// only supports years from 1 to 1999. If you require years outside this range use this accessor.

/// The standard <see cref="GetProviderSpecificValue"/> method will also return this type, but has

/// the disadvantage of boxing the value.

/// See http://www.postgresql.org/docs/current/static/datatype-datetime.html

/// </remarks>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public NpgsqlDate GetDate(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as a TimeSpan,

/// </summary>

/// <remarks>

/// PostgreSQL's interval type has has a resolution of 1 microsecond and ranges from

/// -178000000 to 178000000 years, while .NET's TimeSpan has a resolution of 100 nanoseconds

/// and ranges from roughly -29247 to 29247 years.

/// See http://www.postgresql.org/docs/current/static/datatype-datetime.html

/// </remarks>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public TimeSpan GetTimeSpan(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as an <see cref="NpgsqlTimeSpan"/>,

/// Npgsql's provider-specific type for time spans.

/// </summary>

/// <remarks>

/// PostgreSQL's interval type has has a resolution of 1 microsecond and ranges from

/// -178000000 to 178000000 years, while .NET's TimeSpan has a resolution of 100 nanoseconds

/// and ranges from roughly -29247 to 29247 years. If you require values from outside TimeSpan's

/// range use this accessor.

/// The standard ADO.NET <see cref="GetProviderSpecificValue"/> method will also return this

/// type, but has the disadvantage of boxing the value.

/// See http://www.postgresql.org/docs/current/static/datatype-datetime.html

/// </remarks>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public NpgsqlTimeSpan GetInterval(int ordinal)

}

/// <summary>

/// Gets the value of the specified column as an <see cref="NpgsqlDateTime"/>,

/// Npgsql's provider-specific type for date/time timestamps. Note that this type covers

/// both PostgreSQL's "timestamp with time zone" and "timestamp without time zone" types,

/// which differ only in how they are converted upon input/output.

/// </summary>

/// <remarks>

/// PostgreSQL's timestamp type represents dates from 4713 BC to 5874897 AD, while .NET's DateTime

/// only supports years from 1 to 1999. If you require years outside this range use this accessor.

/// The standard <see cref="GetProviderSpecificValue"/> method will also return this type, but has

/// the disadvantage of boxing the value.

/// See http://www.postgresql.org/docs/current/static/datatype-datetime.html

/// </remarks>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The value of the specified column.</returns>

public NpgsqlDateTime GetTimeStamp(int ordinal)

}

#endregion

#region Special binary getters

/// <summary>

/// Reads a stream of bytes from the specified column, starting at location indicated by dataOffset, into the buffer, starting at the location indicated by bufferOffset.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <param name="dataOffset">The index within the row from which to begin the read operation.</param>

/// <param name="buffer">The buffer into which to copy the data.</param>

/// <param name="bufferOffset">The index with the buffer to which the data will be copied.</param>

/// <param name="length">The maximum number of characters to read.</param>

/// <returns>The actual number of bytes read.</returns>

public override long GetBytes(int ordinal, long dataOffset, byte[] buffer, int bufferOffset, int length)

}

/// <summary>

/// Retrieves data as a <see cref="Stream"/>.

/// </summary>

/// <param name="ordinal">The zero-based column ordinal.</param>

/// <returns>The returned object.</returns>

#if NET40

public Stream GetStream(int ordinal)

#else

public override Stream GetStream(int ordinal)