npgsql | C# Online Compiler

npgsql by ebebeb

namespace Nebula
{
    using System;
    using System.Collections.Generic;
    using System.Data.Common;
    using System.Data;
    using System.Data.SqlClient;
    using System.Reflection;
    using System.Reflection.Emit;
    using System.Threading;
    using ICOMARCHeShop.Helpers;

    //mockup
    internal sealed class NpgsqlConnection : DbConnection
    {

        protected override DbTransaction BeginDbTransaction(System.Data.IsolationLevel isolationLevel)
        {
            return BeginTransaction(isolationLevel);
        }

        public new NpgsqlTransaction BeginTransaction(IsolationLevel level)
        {
            return new NpgsqlTransaction();
        }

        public override void ChangeDatabase(string databaseName)
        {
            throw new NotImplementedException();
        }

        public override void Close()
        {
            throw new NotImplementedException();
        }

        public override string ConnectionString
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        protected override DbCommand CreateDbCommand()
        {
            throw new NotImplementedException();
        }

        public override string DataSource
        {
            get { throw new NotImplementedException(); }
        }

        public override string Database
        {
            get { throw new NotImplementedException(); }
        }

        public override void Open()
        {
            throw new NotImplementedException();
        }

        public override string ServerVersion
        {
            get { throw new NotImplementedException(); }
        }

        public override System.Data.ConnectionState State
        {
            get { throw new NotImplementedException(); }
        }
    }

    internal sealed class NpgsqlCommand : DbCommand
    {
        public override void Cancel()
        {
            throw new NotImplementedException();
        }

        public override string CommandText
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override int CommandTimeout
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override CommandType CommandType
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        protected override DbParameter CreateDbParameter()
        {
            throw new NotImplementedException();
        }

        protected override DbConnection DbConnection
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        protected override DbParameterCollection DbParameterCollection
        {
            get { throw new NotImplementedException(); }
        }

        protected override DbTransaction DbTransaction
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override bool DesignTimeVisible
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        protected override DbDataReader ExecuteDbDataReader(CommandBehavior behavior)
        {
            return this.ExecuteReader(behavior);
        }

        public new NpgsqlDataReader ExecuteReader(CommandBehavior cb)
        {
            return new NpgsqlDataReader();
        }

        public override int ExecuteNonQuery()
        {
            throw new NotImplementedException();
        }

        public override object ExecuteScalar()
        {
            throw new NotImplementedException();
        }

        public override void Prepare()
        {
            throw new NotImplementedException();
        }

        public override UpdateRowSource UpdatedRowSource
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
    }

    internal sealed class NpgsqlParameter : DbParameter
    {

        public override DbType DbType
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override ParameterDirection Direction
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override bool IsNullable
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override string ParameterName
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override void ResetDbType()
        {
            throw new NotImplementedException();
        }

        public override int Size
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override string SourceColumn
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override bool SourceColumnNullMapping
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override DataRowVersion SourceVersion
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override object Value
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
    }

    internal sealed class NpgsqlDataReader : DbDataReader
    {

        public override void Close()
        {
            throw new NotImplementedException();
        }

        public override int Depth
        {
            get { throw new NotImplementedException(); }
        }

        public override int FieldCount
        {
            get { throw new NotImplementedException(); }
        }

        public override bool GetBoolean(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override byte GetByte(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override long GetBytes(int ordinal, long dataOffset, byte[] buffer, int bufferOffset, int length)
        {
            throw new NotImplementedException();
        }

        public override char GetChar(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override long GetChars(int ordinal, long dataOffset, char[] buffer, int bufferOffset, int length)
        {
            throw new NotImplementedException();
        }

        public override string GetDataTypeName(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override DateTime GetDateTime(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override decimal GetDecimal(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override double GetDouble(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override System.Collections.IEnumerator GetEnumerator()
        {
            throw new NotImplementedException();
        }

        public override Type GetFieldType(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override float GetFloat(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override Guid GetGuid(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override short GetInt16(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override int GetInt32(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override long GetInt64(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override string GetName(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override int GetOrdinal(string name)
        {
            throw new NotImplementedException();
        }

        public override DataTable GetSchemaTable()
        {
            throw new NotImplementedException();
        }

        public override string GetString(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override object GetValue(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override int GetValues(object[] values)
        {
            throw new NotImplementedException();
        }

        public override bool HasRows
        {
            get { throw new NotImplementedException(); }
        }

        public override bool IsClosed
        {
            get { throw new NotImplementedException(); }
        }

        public override bool IsDBNull(int ordinal)
        {
            throw new NotImplementedException();
        }

        public override bool NextResult()
        {
            throw new NotImplementedException();
        }

        public override bool Read()
        {
            throw new NotImplementedException();
        }

        public override int RecordsAffected
        {
            get { throw new NotImplementedException(); }
        }

        public override object this[string name]
        {
            get { throw new NotImplementedException(); }
        }

        public override object this[int ordinal]
        {
            get { throw new NotImplementedException(); }
        }
    }

    internal sealed class NpgsqlTransaction : DbTransaction
    {
        public override void Commit()
        {
            throw new NotImplementedException();
        }

        protected override DbConnection DbConnection
        {
            get { throw new NotImplementedException(); }
        }

        public override IsolationLevel IsolationLevel
        {
            get { throw new NotImplementedException(); }
        }

        public override void Rollback()
        {
            throw new NotImplementedException();
        }
    }








    internal abstract class DbConnectionW : IDisposable
    {
        internal static int FailuresCount = 0;


        public abstract void Dispose();
    }

    internal abstract class DbConnectionW<CONN, COMM> : DbConnectionW
        where CONN : DbConnection
        where COMM : DbCommand
    {
        protected readonly CONN _conn;

        internal DbConnectionW(string cs2)
        {
            _conn = CreateConnection(cs2);
            OpenConnectionPv();

#if DEBUG
            var skipTypes = new[] { typeof(Nebula.Search.Crawl), typeof(Nebula.PriceComparison.XmlHandler) };
            if (System.Linq.Enumerable.All(new System.Diagnostics.StackTrace().GetFrames(), z => !System.Linq.Enumerable.Contains(skipTypes, z.GetMethod().DeclaringType)))
            {
                var t = System.Runtime.Remoting.Messaging.CallContext.LogicalGetData(_conn.ConnectionString);
                if (t != null)
                {
                    if (t.ToString() == _conn.ConnectionString)
                    {
                        throw new InvalidOperationException("DbConnectionW nested");
                    }
                }

                System.Runtime.Remoting.Messaging.CallContext.LogicalSetData(_conn.ConnectionString, _conn.ConnectionString);
            }
#endif
        }

        private void OpenConnectionPv()
        {
            try
            {
                OpenConnection();
                FailuresCount = 0;//TODO SQL_PGSQL ??????????????????
            }
            catch (SqlException)
            {
                Interlocked.Increment(ref FailuresCount);
                throw;
            }
        }

        protected abstract CONN CreateConnection(string cs);
        protected abstract void OpenConnection();

        internal abstract COMM CreateCommand();

        public sealed override void Dispose()
        {
#if DEBUG
            System.Runtime.Remoting.Messaging.CallContext.LogicalSetData(_conn.ConnectionString, null);
#endif

            _conn.Dispose();
        }
    }

    internal sealed class MsSqlConnection : DbConnectionW<SqlConnection, SqlCommand>
    {
        private static readonly Action<SqlConnection> __DisableReset;
        private static readonly Func<SqlConnection, bool> __GetInnerPV;

        static MsSqlConnection()
        {
            var tSqlConn = typeof(SqlConnection);
            var inner = tSqlConn.GetField("_innerConnection", BindingFlags.Instance | BindingFlags.NonPublic);
            var innerFieldReset = Assembly.GetAssembly(tSqlConn).GetType("System.Data.SqlClient.SqlInternalConnectionTds").GetField("_fResetConnection", BindingFlags.Instance | BindingFlags.NonPublic);

            var dynM = new DynamicMethod(string.Empty, typeof(void), new Type[] { typeof(SqlConnection) }, typeof(SqlConnection).Module, true);
            var ilGen = dynM.GetILGenerator();
            ilGen.Emit(OpCodes.Ldarg_0);
            ilGen.Emit(OpCodes.Ldfld, inner);
            ilGen.Emit(OpCodes.Ldc_I4_0);
            ilGen.Emit(OpCodes.Stfld, innerFieldReset);
            ilGen.Emit(OpCodes.Ret);

            __DisableReset = (Action<SqlConnection>)dynM.CreateDelegate(typeof(Action<SqlConnection>));

            var dm = new DynamicMethod(string.Empty, typeof(bool), new Type[] { typeof(SqlConnection) }, typeof(SqlConnection).Module, true);
            var il = dm.GetILGenerator();

            il.Emit(OpCodes.Ldarg_0);
            il.Emit(OpCodes.Ldfld, inner);
            il.Emit(OpCodes.Ldfld, innerFieldReset);
            il.Emit(OpCodes.Ret);

            __GetInnerPV = (Func<SqlConnection, bool>)dm.CreateDelegate(typeof(Func<SqlConnection, bool>));
        }

        internal MsSqlConnection(string cs)
            : base(cs)
        {

        }

        protected sealed override SqlConnection CreateConnection(string cs)
        {
            return new SqlConnection(cs);
        }

        protected override void OpenConnection()
        {
            try
            {
                _conn.Open();

                if (__GetInnerPV(_conn))
                {
                    __DisableReset(_conn);
                    using (var comm = _conn.CreateCommand())
                    {
                        comm.CommandText = "SET ARITHABORT ON;";
                        var iar = comm.BeginExecuteNonQuery();
                        comm.EndExecuteNonQuery(iar);
                    }

                    //FailuresCount = 0; //TODO SQL_PGSQL ??????????????????
                }
            }
            catch (SqlException)
            {
                Interlocked.Increment(ref FailuresCount);
                throw;
            }
        }

        internal override SqlCommand CreateCommand()
        {
            //TODO SQL_PGSQL ??????????????????
            throw new NotImplementedException();
        }

        internal SqlCommand CreateCommand(string commandText, params SqlParameter[] parameters)
        {
            var command = _conn.CreateCommand();
            command.CommandTimeout = 600;
            command.CommandType = CommandType.StoredProcedure;
            command.CommandText = commandText;
            command.Parameters.AddRange(parameters);

            return command;
        }
    }

    internal sealed class PgSqlConnection : DbConnectionW<NpgsqlConnection, NpgsqlCommand>
    {
        internal PgSqlConnection(string cs)
            : base(cs)
        {

        }

        protected override NpgsqlConnection CreateConnection(string cs)
        {
            return new NpgsqlConnection();
        }

        protected override void OpenConnection()
        {
            _conn.Open();
        }

        internal NpgsqlTransaction BeginTransaction()
        {
            return _conn.BeginTransaction(IsolationLevel.Snapshot);
        }

        internal override NpgsqlCommand CreateCommand()
        {
            //TODO SQL_PGSQL ??????????????????
            throw new NotImplementedException();
        }
    }


    internal abstract class DbWrapper<CONNW, CONN, COMM, PARAM, RDR>
        where CONNW : DbConnectionW<CONN, COMM>
        where CONN : DbConnection
        where COMM : DbCommand
        where PARAM : DbParameter
        where RDR : DbDataReader
    {
        protected readonly string _cs;

        internal DbWrapper(string cs)
        {
            _cs = cs;
        }

        public void ExecuteNonQuery()
        {
            using (var sqlConn = CreateConnection())
            using (var comm = sqlConn.CreateCommand())
            {
                ExecuteNonQueryPt(comm);
            }
        }

        public object ExecuteScalar()
        {
            object o = null;

            ExecuteReader(r =>
            {
                if (r.Read())
                {
                    o = r[0];
                    if (o == DBNull.Value)
                    {
                        o = null;
                    }
                }
            }, CommandBehavior.SequentialAccess | CommandBehavior.SingleResult | CommandBehavior.SingleRow);

            return o;
        }

        public void ExecuteReader(Action<RDR> a, CommandBehavior cb)
        {
            using (var sqlConn = CreateConnection())
            using (var comm = sqlConn.CreateCommand())
            {
                ExecuteReaderPt(comm, cb, a);
            }
        }

        public virtual void ExecuteReader_refcursor(Action<RDR> a, CommandBehavior cb)
        {
            ExecuteReader(a, cb);
        }

        protected abstract CONNW CreateConnection();

        protected abstract void ExecuteReaderPt(COMM comm, CommandBehavior cb, Action<RDR> a);
        protected abstract void ExecuteNonQueryPt(COMM comm);
    }

    internal sealed class MsSqlDbWrapper : DbWrapper<MsSqlConnection, SqlConnection, SqlCommand, SqlParameter, SqlDataReader>
    {
        internal MsSqlDbWrapper(string cs)
            : base(cs)
        {

        }

        protected sealed override MsSqlConnection CreateConnection()
        {
            return new MsSqlConnection(_cs);
        }

        protected override void ExecuteNonQueryPt(SqlCommand comm)
        {
            var iar = comm.BeginExecuteNonQuery();
            comm.EndExecuteNonQuery(iar);
        }

        protected override void ExecuteReaderPt(SqlCommand comm, CommandBehavior cb, Action<SqlDataReader> a)
        {
            var iar = comm.BeginExecuteReader(cb);

            using (var r = comm.EndExecuteReader(iar))
            {
                a(r);
            }
        }
    }

    internal sealed class PgSqlDbWrapper : DbWrapper<PgSqlConnection, NpgsqlConnection, NpgsqlCommand, NpgsqlParameter, NpgsqlDataReader>
    {
        internal PgSqlDbWrapper(string cs)
            : base(cs)
        {

        }

        protected sealed override PgSqlConnection CreateConnection()
        {
            return new PgSqlConnection(_cs);
        }

        protected sealed override void ExecuteNonQueryPt(NpgsqlCommand comm)
        {
            comm.ExecuteNonQuery();
        }

        protected override void ExecuteReaderPt(NpgsqlCommand comm, CommandBehavior cb, Action<NpgsqlDataReader> a)
        {
            using (var r = comm.ExecuteReader(cb))
            {
                a(r);
            }
        }

        public override void ExecuteReader_refcursor(Action<NpgsqlDataReader> a, CommandBehavior cb)
        {
            using (var sqlConn = CreateConnection())
            using (var comm = sqlConn.CreateCommand())
            {
                using (var t = sqlConn.BeginTransaction())
                {
                    var portals = new FastForwardList<string>();

                    using (var r = comm.ExecuteReader(CommandBehavior.SequentialAccess))
                    {
                        do
                        {
                            while (r.Read())
                            {
                                for (int i = 0; i != r.FieldCount; i++)
                                {
                                    portals.Add(r[i].ToString());
                                }
                            }
                        } while (r.NextResult());
                    }

                    foreach (var portal in portals)
                    {
                        using (var commInn = sqlConn.CreateCommand())
                        {
                            commInn.CommandText = "FETCH ALL IN \"" + portal + "\";";

                            using (var rInn = commInn.ExecuteReader(CommandBehavior.SingleResult | cb))
                            {
                                while (rInn.Read())
                                {
                                    a(rInn);
                                }
                            }
                        }
                    }
                }
            }
        }
    }

    internal enum AbstractCommandResultType
    {
        None,
        Scalar,
        ResultSet,
        ResultSet_refcursor
    }

    internal enum AbstractCommandType
    {
        Text, //
        Function, //comm.CommandType = CommandType.StoredProcedure, npgsql -> SELECT + comm.CommandText...
        StoredProcedure //CALL
    }

    //internal class AbstractCommand
    //{
    //    AbstractCommandResultType ResultType;
    //    AbstractCommandType Type;

    //    string Text;
    //    IEnumerable<AbstractCommandResultType> Parameters;
    //}

    //internal abstract class AbstractCommandParameter
    //{
    //    string Name;
    //    ParameterDirection Direction;
    //}

    //internal class AbstractCommandParameter<T> : AbstractCommand
    //{
    //    internal AbstractCommandParameter(T val)
    //    {
    //        Value = val;
    //    }

    //    T Value;
    //    DbType /*?????*/ DbType;
    //}





}

​x
 
namespace Nebula
{
    using System;
    using System.Collections.Generic;
    using System.Data.Common;
    using System.Data;
    using System.Data.SqlClient;
    using System.Reflection;
    using System.Reflection.Emit;
    using System.Threading;
    using ICOMARCHeShop.Helpers;
​
    //mockup
    internal sealed class NpgsqlConnection : DbConnection
    {
​
        protected override DbTransaction BeginDbTransaction(System.Data.IsolationLevel isolationLevel)
        {
            return BeginTransaction(isolationLevel);
        }
​
        public new NpgsqlTransaction BeginTransaction(IsolationLevel level)
        {
            return new NpgsqlTransaction();
        }
​
        public override void ChangeDatabase(string databaseName)
        {
            throw new NotImplementedException();
        }
​
        public override void Close()
        {
            throw new NotImplementedException();
        }
​
        public override string ConnectionString
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        protected override DbCommand CreateDbCommand()
        {
            throw new NotImplementedException();
        }
​
        public override string DataSource
        {
            get { throw new NotImplementedException(); }
        }
​
        public override string Database
        {
            get { throw new NotImplementedException(); }
        }
​
        public override void Open()
        {
            throw new NotImplementedException();
        }
​
        public override string ServerVersion
        {
            get { throw new NotImplementedException(); }
        }
​
        public override System.Data.ConnectionState State
        {
            get { throw new NotImplementedException(); }
        }
    }
​
    internal sealed class NpgsqlCommand : DbCommand
    {
        public override void Cancel()
        {
            throw new NotImplementedException();
        }
​
        public override string CommandText
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override int CommandTimeout
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override CommandType CommandType
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        protected override DbParameter CreateDbParameter()
        {
            throw new NotImplementedException();
        }
​
        protected override DbConnection DbConnection
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        protected override DbParameterCollection DbParameterCollection
        {
            get { throw new NotImplementedException(); }
        }
​
        protected override DbTransaction DbTransaction
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override bool DesignTimeVisible
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        protected override DbDataReader ExecuteDbDataReader(CommandBehavior behavior)
        {
            return this.ExecuteReader(behavior);
        }
​
        public new NpgsqlDataReader ExecuteReader(CommandBehavior cb)
        {
            return new NpgsqlDataReader();
        }
​
        public override int ExecuteNonQuery()
        {
            throw new NotImplementedException();
        }
​
        public override object ExecuteScalar()
        {
            throw new NotImplementedException();
        }
​
        public override void Prepare()
        {
            throw new NotImplementedException();
        }
​
        public override UpdateRowSource UpdatedRowSource
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
    }
​
    internal sealed class NpgsqlParameter : DbParameter
    {
​
        public override DbType DbType
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override ParameterDirection Direction
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override bool IsNullable
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override string ParameterName
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override void ResetDbType()
        {
            throw new NotImplementedException();
        }
​
        public override int Size
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override string SourceColumn
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override bool SourceColumnNullMapping
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override DataRowVersion SourceVersion
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
​
        public override object Value
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }
    }
​
    internal sealed class NpgsqlDataReader : DbDataReader
    {
​
        public override void Close()
        {
            throw new NotImplementedException();
        }
​
        public override int Depth
        {
            get { throw new NotImplementedException(); }
        }
​
        public override int FieldCount
        {
            get { throw new NotImplementedException(); }
        }
​
        public override bool GetBoolean(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override byte GetByte(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override long GetBytes(int ordinal, long dataOffset, byte[] buffer, int bufferOffset, int length)
        {
            throw new NotImplementedException();
        }
​
        public override char GetChar(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override long GetChars(int ordinal, long dataOffset, char[] buffer, int bufferOffset, int length)
        {
            throw new NotImplementedException();
        }
​
        public override string GetDataTypeName(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override DateTime GetDateTime(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override decimal GetDecimal(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override double GetDouble(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override System.Collections.IEnumerator GetEnumerator()
        {
            throw new NotImplementedException();
        }
​
        public override Type GetFieldType(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override float GetFloat(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override Guid GetGuid(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override short GetInt16(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override int GetInt32(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override long GetInt64(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override string GetName(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override int GetOrdinal(string name)
        {
            throw new NotImplementedException();
        }
​
        public override DataTable GetSchemaTable()
        {
            throw new NotImplementedException();
        }
​
        public override string GetString(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override object GetValue(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override int GetValues(object[] values)
        {
            throw new NotImplementedException();
        }
​
        public override bool HasRows
        {
            get { throw new NotImplementedException(); }
        }
​
        public override bool IsClosed
        {
            get { throw new NotImplementedException(); }
        }
​
        public override bool IsDBNull(int ordinal)
        {
            throw new NotImplementedException();
        }
​
        public override bool NextResult()
        {
            throw new NotImplementedException();
        }
​
        public override bool Read()
        {
            throw new NotImplementedException();
        }
​
        public override int RecordsAffected
        {
            get { throw new NotImplementedException(); }
        }
​
        public override object this[string name]
        {
            get { throw new NotImplementedException(); }
        }
​
        public override object this[int ordinal]
        {
            get { throw new NotImplementedException(); }
        }
    }
​
    internal sealed class NpgsqlTransaction : DbTransaction
    {
        public override void Commit()
        {
            throw new NotImplementedException();
        }
​
        protected override DbConnection DbConnection
        {
            get { throw new NotImplementedException(); }
        }
​
        public override IsolationLevel IsolationLevel
        {
            get { throw new NotImplementedException(); }
        }
​
        public override void Rollback()
        {
            throw new NotImplementedException();
        }
    }
​
​
​
​
​
​
​
​
    internal abstract class DbConnectionW : IDisposable
    {
        internal static int FailuresCount = 0;
​
​
        public abstract void Dispose();
    }
​
    internal abstract class DbConnectionW<CONN, COMM> : DbConnectionW
        where CONN : DbConnection
        where COMM : DbCommand
    {
        protected readonly CONN _conn;
​
        internal DbConnectionW(string cs2)
        {
            _conn = CreateConnection(cs2);
            OpenConnectionPv();
​
#if DEBUG
            var skipTypes = new[] { typeof(Nebula.Search.Crawl), typeof(Nebula.PriceComparison.XmlHandler) };
            if (System.Linq.Enumerable.All(new System.Diagnostics.StackTrace().GetFrames(), z => !System.Linq.Enumerable.Contains(skipTypes, z.GetMethod().DeclaringType)))
            {
                var t = System.Runtime.Remoting.Messaging.CallContext.LogicalGetData(_conn.ConnectionString);
                if (t != null)
                {
                    if (t.ToString() == _conn.ConnectionString)
                    {
                        throw new InvalidOperationException("DbConnectionW nested");
                    }
                }
​
                System.Runtime.Remoting.Messaging.CallContext.LogicalSetData(_conn.ConnectionString, _conn.ConnectionString);
            }
#endif
        }
​
        private void OpenConnectionPv()
        {
            try
            {
                OpenConnection();
                FailuresCount = 0;//TODO SQL_PGSQL ??????????????????
            }
            catch (SqlException)
            {
                Interlocked.Increment(ref FailuresCount);
                throw;
            }
        }
​
        protected abstract CONN CreateConnection(string cs);
        protected abstract void OpenConnection();
​
        internal abstract COMM CreateCommand();
​
        public sealed override void Dispose()
        {
#if DEBUG
            System.Runtime.Remoting.Messaging.CallContext.LogicalSetData(_conn.ConnectionString, null);
#endif
​
            _conn.Dispose();
        }
    }
​
    internal sealed class MsSqlConnection : DbConnectionW<SqlConnection, SqlCommand>
    {
        private static readonly Action<SqlConnection> __DisableReset;
        private static readonly Func<SqlConnection, bool> __GetInnerPV;
​
        static MsSqlConnection()
        {
            var tSqlConn = typeof(SqlConnection);
            var inner = tSqlConn.GetField("_innerConnection", BindingFlags.Instance | BindingFlags.NonPublic);
            var innerFieldReset = Assembly.GetAssembly(tSqlConn).GetType("System.Data.SqlClient.SqlInternalConnectionTds").GetField("_fResetConnection", BindingFlags.Instance | BindingFlags.NonPublic);
​
            var dynM = new DynamicMethod(string.Empty, typeof(void), new Type[] { typeof(SqlConnection) }, typeof(SqlConnection).Module, true);
            var ilGen = dynM.GetILGenerator();
            ilGen.Emit(OpCodes.Ldarg_0);
            ilGen.Emit(OpCodes.Ldfld, inner);
            ilGen.Emit(OpCodes.Ldc_I4_0);
            ilGen.Emit(OpCodes.Stfld, innerFieldReset);
            ilGen.Emit(OpCodes.Ret);
​
            __DisableReset = (Action<SqlConnection>)dynM.CreateDelegate(typeof(Action<SqlConnection>));
​
            var dm = new DynamicMethod(string.Empty, typeof(bool), new Type[] { typeof(SqlConnection) }, typeof(SqlConnection).Module, true);
            var il = dm.GetILGenerator();
​
            il.Emit(OpCodes.Ldarg_0);
            il.Emit(OpCodes.Ldfld, inner);
            il.Emit(OpCodes.Ldfld, innerFieldReset);
            il.Emit(OpCodes.Ret);
​
            __GetInnerPV = (Func<SqlConnection, bool>)dm.CreateDelegate(typeof(Func<SqlConnection, bool>));
        }
​
        internal MsSqlConnection(string cs)
            : base(cs)
        {
​
        }
​
        protected sealed override SqlConnection CreateConnection(string cs)
        {
            return new SqlConnection(cs);
        }
​
        protected override void OpenConnection()
        {
            try
            {
                _conn.Open();
​
                if (__GetInnerPV(_conn))
                {
                    __DisableReset(_conn);
                    using (var comm = _conn.CreateCommand())
                    {
                        comm.CommandText = "SET ARITHABORT ON;";
                        var iar = comm.BeginExecuteNonQuery();
                        comm.EndExecuteNonQuery(iar);
                    }
​
                    //FailuresCount = 0; //TODO SQL_PGSQL ??????????????????
                }
            }
            catch (SqlException)
            {
                Interlocked.Increment(ref FailuresCount);
                throw;
            }
        }
​
        internal override SqlCommand CreateCommand()
        {
            //TODO SQL_PGSQL ??????????????????
            throw new NotImplementedException();
        }
​
        internal SqlCommand CreateCommand(string commandText, params SqlParameter[] parameters)
        {
            var command = _conn.CreateCommand();
            command.CommandTimeout = 600;
            command.CommandType = CommandType.StoredProcedure;
            command.CommandText = commandText;
            command.Parameters.AddRange(parameters);
​
            return command;
        }
    }
​
    internal sealed class PgSqlConnection : DbConnectionW<NpgsqlConnection, NpgsqlCommand>
    {
        internal PgSqlConnection(string cs)
            : base(cs)
        {
​
        }
​
        protected override NpgsqlConnection CreateConnection(string cs)
        {
            return new NpgsqlConnection();
        }
​
        protected override void OpenConnection()
        {
            _conn.Open();
        }
​
        internal NpgsqlTransaction BeginTransaction()
        {
            return _conn.BeginTransaction(IsolationLevel.Snapshot);
        }
​
        internal override NpgsqlCommand CreateCommand()
        {
            //TODO SQL_PGSQL ??????????????????
            throw new NotImplementedException();
        }
    }
​
​
    internal abstract class DbWrapper<CONNW, CONN, COMM, PARAM, RDR>
        where CONNW : DbConnectionW<CONN, COMM>
        where CONN : DbConnection
        where COMM : DbCommand
        where PARAM : DbParameter
        where RDR : DbDataReader
    {
        protected readonly string _cs;
​
        internal DbWrapper(string cs)
        {
            _cs = cs;
        }
​
        public void ExecuteNonQuery()
        {
            using (var sqlConn = CreateConnection())
            using (var comm = sqlConn.CreateCommand())
            {
                ExecuteNonQueryPt(comm);
            }
        }
​
        public object ExecuteScalar()
        {
            object o = null;
​
            ExecuteReader(r =>
            {
                if (r.Read())
                {
                    o = r[0];
                    if (o == DBNull.Value)
                    {
                        o = null;
                    }
                }
            }, CommandBehavior.SequentialAccess | CommandBehavior.SingleResult | CommandBehavior.SingleRow);
​
            return o;
        }
​
        public void ExecuteReader(Action<RDR> a, CommandBehavior cb)
        {
            using (var sqlConn = CreateConnection())
            using (var comm = sqlConn.CreateCommand())
            {
                ExecuteReaderPt(comm, cb, a);
            }
        }
​
        public virtual void ExecuteReader_refcursor(Action<RDR> a, CommandBehavior cb)
        {
            ExecuteReader(a, cb);
        }
​
        protected abstract CONNW CreateConnection();
​
        protected abstract void ExecuteReaderPt(COMM comm, CommandBehavior cb, Action<RDR> a);
        protected abstract void ExecuteNonQueryPt(COMM comm);
    }
​
    internal sealed class MsSqlDbWrapper : DbWrapper<MsSqlConnection, SqlConnection, SqlCommand, SqlParameter, SqlDataReader>
    {
        internal MsSqlDbWrapper(string cs)
            : base(cs)
        {
​
        }
​
        protected sealed override MsSqlConnection CreateConnection()
        {
            return new MsSqlConnection(_cs);
        }
​
        protected override void ExecuteNonQueryPt(SqlCommand comm)
        {
            var iar = comm.BeginExecuteNonQuery();
            comm.EndExecuteNonQuery(iar);
        }
​
        protected override void ExecuteReaderPt(SqlCommand comm, CommandBehavior cb, Action<SqlDataReader> a)
        {
            var iar = comm.BeginExecuteReader(cb);
​
            using (var r = comm.EndExecuteReader(iar))
            {
                a(r);
            }
        }
    }
​
    internal sealed class PgSqlDbWrapper : DbWrapper<PgSqlConnection, NpgsqlConnection, NpgsqlCommand, NpgsqlParameter, NpgsqlDataReader>
    {
        internal PgSqlDbWrapper(string cs)
            : base(cs)
        {
​
        }
​
        protected sealed override PgSqlConnection CreateConnection()
        {
            return new PgSqlConnection(_cs);
        }
​
        protected sealed override void ExecuteNonQueryPt(NpgsqlCommand comm)
        {
            comm.ExecuteNonQuery();
        }
​
        protected override void ExecuteReaderPt(NpgsqlCommand comm, CommandBehavior cb, Action<NpgsqlDataReader> a)
        {
            using (var r = comm.ExecuteReader(cb))
            {
                a(r);
            }
        }
​
        public override void ExecuteReader_refcursor(Action<NpgsqlDataReader> a, CommandBehavior cb)
        {
            using (var sqlConn = CreateConnection())
            using (var comm = sqlConn.CreateCommand())
            {
                using (var t = sqlConn.BeginTransaction())
                {
                    var portals = new FastForwardList<string>();
​
                    using (var r = comm.ExecuteReader(CommandBehavior.SequentialAccess))
                    {
                        do
                        {
                            while (r.Read())
                            {
                                for (int i = 0; i != r.FieldCount; i++)
                                {
                                    portals.Add(r[i].ToString());
                                }
                            }
                        } while (r.NextResult());
                    }
​
                    foreach (var portal in portals)
                    {
                        using (var commInn = sqlConn.CreateCommand())
                        {
                            commInn.CommandText = "FETCH ALL IN \"" + portal + "\";";
​
                            using (var rInn = commInn.ExecuteReader(CommandBehavior.SingleResult | cb))
                            {
                                while (rInn.Read())
                                {
                                    a(rInn);
                                }
                            }
                        }
                    }
                }
            }
        }
    }
​
    internal enum AbstractCommandResultType
    {
        None,
        Scalar,
        ResultSet,
        ResultSet_refcursor
    }
​
    internal enum AbstractCommandType
    {
        Text, //
        Function, //comm.CommandType = CommandType.StoredProcedure, npgsql -> SELECT + comm.CommandText...
        StoredProcedure //CALL
    }
​
    //internal class AbstractCommand
    //{
    //    AbstractCommandResultType ResultType;
    //    AbstractCommandType Type;
​
    //    string Text;
    //    IEnumerable<AbstractCommandResultType> Parameters;
    //}
​
    //internal abstract class AbstractCommandParameter
    //{
    //    string Name;
    //    ParameterDirection Direction;
    //}
​
    //internal class AbstractCommandParameter<T> : AbstractCommand
    //{
    //    internal AbstractCommandParameter(T val)
    //    {
    //        Value = val;
    //    }
​
    //    T Value;
    //    DbType /*?????*/ DbType;
    //}
​
​
​
​
​
}

"AQID"
[1,2,3]
True

Last Run:	9:44:45 am
Compile:	0.01s
Execute:	0.09s
Memory:	8.34Mb
CPU:	0.1s

View IL Code