laatzen/LaaProductionWeb/LaaProductionWeb.Data/SqlReader.cs

namespace LaaProductionWeb.Data
{
    using LaaProductionWeb.Data.Interfaces;

    using System;
    using System.Data.SqlClient;

    public class SqlReader : ISqlReader, IDisposable
    {
        private readonly SqlDataReader sqlDataReader;

        private int column;

        private SqlReader(SqlDataReader sqlDataReader) 
            => this.sqlDataReader = sqlDataReader;

        public void Dispose()
        {
            this.sqlDataReader.Close();
            this.sqlDataReader.Dispose();
        }

        public byte[] GetBytes(int index = -1)
        {
            var bytes = default(byte[]);

            if (index < 0)
            {
                index = this.column++;
            }

            if (!this.sqlDataReader.IsDBNull(index))
            {
                bytes = this.sqlDataReader.GetFieldValue<byte[]>(0);
            }

            return bytes ?? Array.Empty<byte>();
        }

        internal string[] GetColumns()
        {
            var columnsCount = this.sqlDataReader.FieldCount;
            var columns = new string[columnsCount];

            for (int i = 0; i < columnsCount; i++)
            {
                columns[i] = this.sqlDataReader.GetName(i);
            }

            return columns;
        }

        public string GetString(int index = -1)
        {
            if (index < 0)
            {
                index = this.column++;
            }

            if (!this.sqlDataReader.IsDBNull(index))
            {
                return $"{this.sqlDataReader.GetValue(index)}";
            }

            return default(string);
        }

        public T GetValue<T>(int index = -1)
        {
            if (index < 0)
            {
                index = this.column++;
            }

            if (!this.sqlDataReader.IsDBNull(index))
            {
                if (this.sqlDataReader.GetValue(index) is T value)
                {
                    return value;
                }
            }

            return default(T);
        }

        internal bool Read()
        {
            this.column = 0;

            return this.sqlDataReader.Read();
        }

        public static implicit operator SqlReader(SqlDataReader sqlDataReader)
            => new SqlReader(sqlDataReader);
    }
}