diff Source/DataAccess/SqlQueryT.cs @ 7:99cd4f3947d8

Закомментированы строки мешающие добавлению авиа дежурств.
author nickolay
date Fri, 27 Oct 2017 18:26:29 +0300
parents f990fcb411a9
children
line wrap: on
line diff
--- a/Source/DataAccess/SqlQueryT.cs	Mon Dec 05 05:50:52 2016 +0300
+++ b/Source/DataAccess/SqlQueryT.cs	Fri Oct 27 18:26:29 2017 +0300
@@ -1,383 +1,383 @@
-using System;
-using System.Collections.Generic;
-
-namespace BLToolkit.DataAccess
-{
-	using Data;
-	using Mapping;
-	using Reflection.Extension;
-
-	public class SqlQuery<T> : SqlQueryBase
-	{
-		#region Constructors
-
-		public SqlQuery()
-		{
-		}
-
-		public SqlQuery(DbManager dbManager)
-			: base(dbManager)
-		{
-		}
-
-		public SqlQuery(DbManager dbManager, bool dispose)
-			: base(dbManager, dispose)
-		{
-		}
-
-		public SqlQuery(ExtensionList extensions)
-		{
-			Extensions = extensions;
-		}
-
-		#endregion
-
-		#region Overrides
-
-		public SqlQueryInfo GetSqlQueryInfo(DbManager db, string actionName)
-		{
-			return base.GetSqlQueryInfo(db, typeof(T), actionName);
-		}
-
-		#endregion
-
-		#region SelectByKey
-
-		public virtual T SelectByKey(DbManager db, params object[] keys)
-		{
-			var query = GetSqlQueryInfo(db, typeof(T), "SelectByKey");
-
-			return db
-				.SetCommand(query.QueryText, query.GetParameters(db, keys))
-				.ExecuteObject<T>();
-		}
-
-		public virtual T SelectByKey(params object[] keys)
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return SelectByKey(db, keys);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		#endregion
-
-		#region SelectAll
-
-		static SqlQueryInfo _selectAllQuery;
-
-		public virtual List<T> SelectAll(DbManager db)
-		{
-			if (_selectAllQuery == null)
-				_selectAllQuery = GetSqlQueryInfo(db, typeof(T), "SelectAll");
-
-			return db
-				.SetCommand(_selectAllQuery.QueryText)
-				.ExecuteList<T>();
-		}
-
-		public virtual TL SelectAll<TL>(DbManager db, TL list)
-			where TL : IList<T>
-		{
-			var query = GetSqlQueryInfo(db, typeof(T), "SelectAll");
-
-			return db
-				.SetCommand(query.QueryText)
-				.ExecuteList<TL,T>(list);
-		}
-
-		public virtual TL SelectAll<TL>(DbManager db)
-			where TL : IList<T>, new()
-		{
-			return SelectAll(db, new TL());
-		}
-
-		public virtual List<T> SelectAll()
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return SelectAll(db);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		public virtual TL SelectAll<TL>(TL list)
-			where TL : IList<T>
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return SelectAll(db, list);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		public virtual TL SelectAll<TL>()
-			where TL : IList<T>, new()
-		{
-			return SelectAll(new TL());
-		}
-
-		#endregion
-
-		#region Insert
-
-		public virtual int Insert(DbManager db, T obj)
-		{
-			var query = GetSqlQueryInfo(db, obj.GetType(), "Insert");
-
-			return db
-				.SetCommand(query.QueryText, query.GetParameters(db, obj))
-				.ExecuteNonQuery();
-		}
-
-		public virtual int Insert(T obj)
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return Insert(db, obj);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		public virtual int Insert(DbManager db, int maxBatchSize, IEnumerable<T> list)
-		{
-			var query = GetSqlQueryInfo(db, typeof(T), "InsertBatch");
-
-			return db.DataProvider.InsertBatch(
-				db,
-				query.QueryText,
-				list,
-				query.GetMemberMappers(),
-				maxBatchSize,
-				obj => query.GetParameters(db, obj));
-		}
-
-		public virtual int Insert(int maxBatchSize, IEnumerable<T> list)
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return Insert(db, maxBatchSize, list);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		public virtual int Insert(DbManager db, IEnumerable<T> list)
-		{
-			return Insert(db, int.MaxValue, list);
-		}
-
-		public virtual int Insert(IEnumerable<T> list)
-		{
-			return Insert(int.MaxValue, list);
-		}
-
-		#endregion
-
-		#region Update
-
-		public virtual int Update(DbManager db, T obj)
-		{
-			var query = GetSqlQueryInfo(db, obj.GetType(), "Update");
-
-			return db
-				.SetCommand(query.QueryText, query.GetParameters(db, obj))
-				.ExecuteNonQuery();
-		}
-
-		public virtual int Update(T obj)
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return Update(db, obj);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		public virtual int Update(DbManager db, int maxBatchSize, IEnumerable<T> list)
-		{
-			var query = GetSqlQueryInfo(db, typeof(T), "UpdateBatch");
-
-			db.SetCommand(query.QueryText);
-
-			return ExecuteForEach(
-				db,
-				list,
-				query.GetMemberMappers(),
-				maxBatchSize,
-				obj => query.GetParameters(db, obj));
-		}
-
-		public virtual int Update(int maxBatchSize, IEnumerable<T> list)
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return Update(db, maxBatchSize, list);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		public virtual int Update(DbManager db, IEnumerable<T> list)
-		{
-			return Update(db, int.MaxValue, list);
-		}
-
-		public virtual int Update(IEnumerable<T> list)
-		{
-			return Update(int.MaxValue, list);
-		}
-
-		#endregion
-
-		#region DeleteByKey
-
-		public virtual int DeleteByKey(DbManager db, params object[] key)
-		{
-			var query = GetSqlQueryInfo(db, typeof(T), "Delete");
-
-			return db
-				.SetCommand(query.QueryText, query.GetParameters(db, key))
-				.ExecuteNonQuery();
-		}
-
-		public virtual int DeleteByKey(params object[] key)
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return DeleteByKey(db, key);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		#endregion
-
-		#region Delete
-
-		public virtual int Delete(DbManager db, T obj)
-		{
-			var query = GetSqlQueryInfo(db, obj.GetType(), "Delete");
-
-			return db
-				.SetCommand(query.QueryText, query.GetParameters(db, obj))
-				.ExecuteNonQuery();
-		}
-
-		public virtual int Delete(T obj)
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return Delete(db, obj);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		public virtual int Delete(DbManager db, int maxBatchSize, IEnumerable<T> list)
-		{
-			var query = GetSqlQueryInfo(db, typeof(T), "DeleteBatch");
-
-			db.SetCommand(query.QueryText);
-
-			return ExecuteForEach(
-				db,
-				list,
-				query.GetMemberMappers(),
-				maxBatchSize,
-				obj => query.GetParameters(db, obj));
-		}
-
-		public virtual int Delete(int maxBatchSize, IEnumerable<T> list)
-		{
-			var db = GetDbManager();
-
-			try
-			{
-				return Delete(db, list);
-			}
-			finally
-			{
-				if (DisposeDbManager)
-					db.Dispose();
-			}
-		}
-
-		public virtual int Delete(DbManager db, IEnumerable<T> list)
-		{
-			return Delete(db, int.MaxValue, list);
-		}
-
-		public virtual int Delete(IEnumerable<T> list)
-		{
-			return Delete(int.MaxValue, list);
-		}
-
-		#endregion
-
-		#region Helpers
-
-		protected int ExecuteForEach(
-			DbManager      db,
-			IEnumerable<T> collection,
-			MemberMapper[] members,
-			int            maxBatchSize,
-			DbManager.ParameterProvider<T> getParameters)
-		{
-			return db.ExecuteForEach(collection, members, maxBatchSize, getParameters);
-		}
-
-		#endregion
-	}
-}
+using System;
+using System.Collections.Generic;
+
+namespace BLToolkit.DataAccess
+{
+	using Data;
+	using Mapping;
+	using Reflection.Extension;
+
+	public class SqlQuery<T> : SqlQueryBase
+	{
+		#region Constructors
+
+		public SqlQuery()
+		{
+		}
+
+		public SqlQuery(DbManager dbManager)
+			: base(dbManager)
+		{
+		}
+
+		public SqlQuery(DbManager dbManager, bool dispose)
+			: base(dbManager, dispose)
+		{
+		}
+
+		public SqlQuery(ExtensionList extensions)
+		{
+			Extensions = extensions;
+		}
+
+		#endregion
+
+		#region Overrides
+
+		public SqlQueryInfo GetSqlQueryInfo(DbManager db, string actionName)
+		{
+			return base.GetSqlQueryInfo(db, typeof(T), actionName);
+		}
+
+		#endregion
+
+		#region SelectByKey
+
+		public virtual T SelectByKey(DbManager db, params object[] keys)
+		{
+			var query = GetSqlQueryInfo(db, typeof(T), "SelectByKey");
+
+			return db
+				.SetCommand(query.QueryText, query.GetParameters(db, keys))
+				.ExecuteObject<T>();
+		}
+
+		public virtual T SelectByKey(params object[] keys)
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return SelectByKey(db, keys);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		#endregion
+
+		#region SelectAll
+
+		static SqlQueryInfo _selectAllQuery;
+
+		public virtual List<T> SelectAll(DbManager db)
+		{
+			if (_selectAllQuery == null)
+				_selectAllQuery = GetSqlQueryInfo(db, typeof(T), "SelectAll");
+
+			return db
+				.SetCommand(_selectAllQuery.QueryText)
+				.ExecuteList<T>();
+		}
+
+		public virtual TL SelectAll<TL>(DbManager db, TL list)
+			where TL : IList<T>
+		{
+			var query = GetSqlQueryInfo(db, typeof(T), "SelectAll");
+
+			return db
+				.SetCommand(query.QueryText)
+				.ExecuteList<TL,T>(list);
+		}
+
+		public virtual TL SelectAll<TL>(DbManager db)
+			where TL : IList<T>, new()
+		{
+			return SelectAll(db, new TL());
+		}
+
+		public virtual List<T> SelectAll()
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return SelectAll(db);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		public virtual TL SelectAll<TL>(TL list)
+			where TL : IList<T>
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return SelectAll(db, list);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		public virtual TL SelectAll<TL>()
+			where TL : IList<T>, new()
+		{
+			return SelectAll(new TL());
+		}
+
+		#endregion
+
+		#region Insert
+
+		public virtual int Insert(DbManager db, T obj)
+		{
+			var query = GetSqlQueryInfo(db, obj.GetType(), "Insert");
+
+			return db
+				.SetCommand(query.QueryText, query.GetParameters(db, obj))
+				.ExecuteNonQuery();
+		}
+
+		public virtual int Insert(T obj)
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return Insert(db, obj);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		public virtual int Insert(DbManager db, int maxBatchSize, IEnumerable<T> list)
+		{
+			var query = GetSqlQueryInfo(db, typeof(T), "InsertBatch");
+
+			return db.DataProvider.InsertBatch(
+				db,
+				query.QueryText,
+				list,
+				query.GetMemberMappers(),
+				maxBatchSize,
+				obj => query.GetParameters(db, obj));
+		}
+
+		public virtual int Insert(int maxBatchSize, IEnumerable<T> list)
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return Insert(db, maxBatchSize, list);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		public virtual int Insert(DbManager db, IEnumerable<T> list)
+		{
+			return Insert(db, int.MaxValue, list);
+		}
+
+		public virtual int Insert(IEnumerable<T> list)
+		{
+			return Insert(int.MaxValue, list);
+		}
+
+		#endregion
+
+		#region Update
+
+		public virtual int Update(DbManager db, T obj)
+		{
+			var query = GetSqlQueryInfo(db, obj.GetType(), "Update");
+
+			return db
+				.SetCommand(query.QueryText, query.GetParameters(db, obj))
+				.ExecuteNonQuery();
+		}
+
+		public virtual int Update(T obj)
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return Update(db, obj);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		public virtual int Update(DbManager db, int maxBatchSize, IEnumerable<T> list)
+		{
+			var query = GetSqlQueryInfo(db, typeof(T), "UpdateBatch");
+
+			db.SetCommand(query.QueryText);
+
+			return ExecuteForEach(
+				db,
+				list,
+				query.GetMemberMappers(),
+				maxBatchSize,
+				obj => query.GetParameters(db, obj));
+		}
+
+		public virtual int Update(int maxBatchSize, IEnumerable<T> list)
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return Update(db, maxBatchSize, list);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		public virtual int Update(DbManager db, IEnumerable<T> list)
+		{
+			return Update(db, int.MaxValue, list);
+		}
+
+		public virtual int Update(IEnumerable<T> list)
+		{
+			return Update(int.MaxValue, list);
+		}
+
+		#endregion
+
+		#region DeleteByKey
+
+		public virtual int DeleteByKey(DbManager db, params object[] key)
+		{
+			var query = GetSqlQueryInfo(db, typeof(T), "Delete");
+
+			return db
+				.SetCommand(query.QueryText, query.GetParameters(db, key))
+				.ExecuteNonQuery();
+		}
+
+		public virtual int DeleteByKey(params object[] key)
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return DeleteByKey(db, key);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		#endregion
+
+		#region Delete
+
+		public virtual int Delete(DbManager db, T obj)
+		{
+			var query = GetSqlQueryInfo(db, obj.GetType(), "Delete");
+
+			return db
+				.SetCommand(query.QueryText, query.GetParameters(db, obj))
+				.ExecuteNonQuery();
+		}
+
+		public virtual int Delete(T obj)
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return Delete(db, obj);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		public virtual int Delete(DbManager db, int maxBatchSize, IEnumerable<T> list)
+		{
+			var query = GetSqlQueryInfo(db, typeof(T), "DeleteBatch");
+
+			db.SetCommand(query.QueryText);
+
+			return ExecuteForEach(
+				db,
+				list,
+				query.GetMemberMappers(),
+				maxBatchSize,
+				obj => query.GetParameters(db, obj));
+		}
+
+		public virtual int Delete(int maxBatchSize, IEnumerable<T> list)
+		{
+			var db = GetDbManager();
+
+			try
+			{
+				return Delete(db, list);
+			}
+			finally
+			{
+				if (DisposeDbManager)
+					db.Dispose();
+			}
+		}
+
+		public virtual int Delete(DbManager db, IEnumerable<T> list)
+		{
+			return Delete(db, int.MaxValue, list);
+		}
+
+		public virtual int Delete(IEnumerable<T> list)
+		{
+			return Delete(int.MaxValue, list);
+		}
+
+		#endregion
+
+		#region Helpers
+
+		protected int ExecuteForEach(
+			DbManager      db,
+			IEnumerable<T> collection,
+			MemberMapper[] members,
+			int            maxBatchSize,
+			DbManager.ParameterProvider<T> getParameters)
+		{
+			return db.ExecuteForEach(collection, members, maxBatchSize, getParameters);
+		}
+
+		#endregion
+	}
+}