SafeSqlDataReader.cs

Go to the documentation of this file.

//-----------------------------------------------------------------------
// <copyright file="SafeSqlDataReader.cs" company="Marimer LLC">
//     Copyright (c) Marimer LLC. All rights reserved.
//     Website: https://cslanet.com
// </copyright>
// <summary>This is a SqlDataReader based on SafeDataReader</summary>
//-----------------------------------------------------------------------
using System;
using System.Data;
#if NETFX
using System.Data.SqlClient;
#else
using Microsoft.Data.SqlClient;
#endif
using System.Threading.Tasks;
 
namespace Csla.Data.SqlClient
{
  public class SafeSqlDataReader : SafeDataReader
  {
    public SqlDataReader SqlDataReader { get; }
 
    public SafeSqlDataReader(IDataReader dataReader)
      :base(dataReader)
    {
      SqlDataReader = DataReader as SqlDataReader;
    }
 
    public Task<T> GetFieldValueAsync<T>(int ordinal)
    {
      if (SqlDataReader == null)
        throw new NotSupportedException("GetFieldValueAsync");
      return SqlDataReader.GetFieldValueAsync<T>(ordinal);
    }
 
    public Task<T> GetFieldValueAsync<T>(int ordinal, System.Threading.CancellationToken cancellationToken)
    {
      if (SqlDataReader == null)
        throw new NotSupportedException("GetFieldValueAsync");
      return SqlDataReader.GetFieldValueAsync<T>(ordinal, cancellationToken);
    }
 
    public Task<bool> IsDbNullAsync(int ordinal)
    {
      if (SqlDataReader == null)
        throw new NotSupportedException("IsDbNullAsync");
      return SqlDataReader.IsDBNullAsync(ordinal);
    }
 
    public Task<bool> IsDbNullAsync(int ordinal, System.Threading.CancellationToken cancellationToken)
    {
      if (SqlDataReader == null)
        throw new NotSupportedException("IsDbNullAsync");
      return SqlDataReader.IsDBNullAsync(ordinal, cancellationToken);
    }
 
    public Task<bool> NextResultAsync()
    {
      if (SqlDataReader == null)
        throw new NotSupportedException("NextResultAsync");
      return SqlDataReader.NextResultAsync();
    }
 
    public Task<bool> NextResultAsync(System.Threading.CancellationToken cancellationToken)
    {
      if (SqlDataReader == null)
        throw new NotSupportedException("NextResultAsync");
      return SqlDataReader.NextResultAsync(cancellationToken);
    }
 
    public Task<bool> ReadAsync()
    {
      if (SqlDataReader == null)
        throw new NotSupportedException("NextResultAsync");
      return SqlDataReader.ReadAsync();
    }
 
    public Task<bool> ReadAsync(System.Threading.CancellationToken cancellationToken)
    {
      if (SqlDataReader == null)
        throw new NotSupportedException("NextResultAsync");
      return SqlDataReader.ReadAsync(cancellationToken);
    }
  }
}