init

2020-05-29 18:26:08 +08:00
commit 383af1f98f
118 changed files with 32595 additions and 0 deletions
--- a/ContosoUniversity.DAL/SchoolInterceptorTransientErrors.cs
+++ b/ContosoUniversity.DAL/SchoolInterceptorTransientErrors.cs
@@ -0,0 +1,55 @@
+using System;
+using System.Data.Common;
+using System.Data.Entity;
+using System.Data.Entity.Infrastructure.Interception;
+using System.Data.Entity.SqlServer;
+using System.Data.SqlClient;
+using System.Diagnostics;
+using System.Reflection;
+using System.Linq;
+using ContosoUniversity.Logging;
+
+namespace ContosoUniversity.DAL
+{
+    public class SchoolInterceptorTransientErrors : DbCommandInterceptor
+    {
+        private int _counter = 0;
+        private ILogger _logger = new Logger();
+
+        public override void ReaderExecuting(DbCommand command, DbCommandInterceptionContext<DbDataReader> interceptionContext)
+        {
+            bool throwTransientErrors = false;
+            if (command.Parameters.Count > 0 && command.Parameters[0].Value.ToString() == "%Throw%")
+            {
+                throwTransientErrors = true;
+                command.Parameters[0].Value = "%an%";
+                command.Parameters[1].Value = "%an%";
+            }
+
+            if (throwTransientErrors && _counter < 4)
+            {
+                _logger.Information("Returning transient error for command: {0}", command.CommandText);
+                _counter++;
+                interceptionContext.Exception = CreateDummySqlException();
+            }
+        }
+
+        private SqlException CreateDummySqlException()
+        {
+            // The instance of SQL Server you attempted to connect to does not support encryption
+            var sqlErrorNumber = 20;
+
+            var sqlErrorCtor = typeof(SqlError).GetConstructors(BindingFlags.Instance | BindingFlags.NonPublic).Where(c => c.GetParameters().Count() == 7).Single();
+            var sqlError = sqlErrorCtor.Invoke(new object[] { sqlErrorNumber, (byte)0, (byte)0, "", "", "", 1 });
+
+            var errorCollection = Activator.CreateInstance(typeof(SqlErrorCollection), true);
+            var addMethod = typeof(SqlErrorCollection).GetMethod("Add", BindingFlags.Instance | BindingFlags.NonPublic);
+            addMethod.Invoke(errorCollection, new[] { sqlError });
+
+            var sqlExceptionCtor = typeof(SqlException).GetConstructors(BindingFlags.Instance | BindingFlags.NonPublic).Where(c => c.GetParameters().Count() == 4).Single();
+            var sqlException = (SqlException)sqlExceptionCtor.Invoke(new object[] { "Dummy", errorCollection, null, Guid.NewGuid() });
+
+            return sqlException;
+        }
+    }
+}