Mercurial > pub > bltoolkit

changeset 7:99cd4f3947d8

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Закомментированы строки мешающие добавлению авиа дежурств.
author nickolay
date Fri, 27 Oct 2017 18:26:29 +0300
parents 11b6da379593
children a34cfdde80d6
files Source/DataAccess/SqlQueryT.cs
diffstat 1 files changed, 383 insertions(+), 383 deletions(-) [+]
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
+	}
+}