# HG changeset patch # User nickolay # Date 1509117989 -10800 # Node ID 99cd4f3947d8b9475ee4eb12090673c997e10a9b # Parent 11b6da3795937a73c0fa09698437835a8099e79e Закомментированы строки мешающие добавлению авиа дежурств. diff -r 11b6da379593 -r 99cd4f3947d8 Source/DataAccess/SqlQueryT.cs --- 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 : 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(); - } - - 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 SelectAll(DbManager db) - { - if (_selectAllQuery == null) - _selectAllQuery = GetSqlQueryInfo(db, typeof(T), "SelectAll"); - - return db - .SetCommand(_selectAllQuery.QueryText) - .ExecuteList(); - } - - public virtual TL SelectAll(DbManager db, TL list) - where TL : IList - { - var query = GetSqlQueryInfo(db, typeof(T), "SelectAll"); - - return db - .SetCommand(query.QueryText) - .ExecuteList(list); - } - - public virtual TL SelectAll(DbManager db) - where TL : IList, new() - { - return SelectAll(db, new TL()); - } - - public virtual List SelectAll() - { - var db = GetDbManager(); - - try - { - return SelectAll(db); - } - finally - { - if (DisposeDbManager) - db.Dispose(); - } - } - - public virtual TL SelectAll(TL list) - where TL : IList - { - var db = GetDbManager(); - - try - { - return SelectAll(db, list); - } - finally - { - if (DisposeDbManager) - db.Dispose(); - } - } - - public virtual TL SelectAll() - where TL : IList, 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 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 list) - { - var db = GetDbManager(); - - try - { - return Insert(db, maxBatchSize, list); - } - finally - { - if (DisposeDbManager) - db.Dispose(); - } - } - - public virtual int Insert(DbManager db, IEnumerable list) - { - return Insert(db, int.MaxValue, list); - } - - public virtual int Insert(IEnumerable 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 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 list) - { - var db = GetDbManager(); - - try - { - return Update(db, maxBatchSize, list); - } - finally - { - if (DisposeDbManager) - db.Dispose(); - } - } - - public virtual int Update(DbManager db, IEnumerable list) - { - return Update(db, int.MaxValue, list); - } - - public virtual int Update(IEnumerable 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 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 list) - { - var db = GetDbManager(); - - try - { - return Delete(db, list); - } - finally - { - if (DisposeDbManager) - db.Dispose(); - } - } - - public virtual int Delete(DbManager db, IEnumerable list) - { - return Delete(db, int.MaxValue, list); - } - - public virtual int Delete(IEnumerable list) - { - return Delete(int.MaxValue, list); - } - - #endregion - - #region Helpers - - protected int ExecuteForEach( - DbManager db, - IEnumerable collection, - MemberMapper[] members, - int maxBatchSize, - DbManager.ParameterProvider 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 : 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(); + } + + 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 SelectAll(DbManager db) + { + if (_selectAllQuery == null) + _selectAllQuery = GetSqlQueryInfo(db, typeof(T), "SelectAll"); + + return db + .SetCommand(_selectAllQuery.QueryText) + .ExecuteList(); + } + + public virtual TL SelectAll(DbManager db, TL list) + where TL : IList + { + var query = GetSqlQueryInfo(db, typeof(T), "SelectAll"); + + return db + .SetCommand(query.QueryText) + .ExecuteList(list); + } + + public virtual TL SelectAll(DbManager db) + where TL : IList, new() + { + return SelectAll(db, new TL()); + } + + public virtual List SelectAll() + { + var db = GetDbManager(); + + try + { + return SelectAll(db); + } + finally + { + if (DisposeDbManager) + db.Dispose(); + } + } + + public virtual TL SelectAll(TL list) + where TL : IList + { + var db = GetDbManager(); + + try + { + return SelectAll(db, list); + } + finally + { + if (DisposeDbManager) + db.Dispose(); + } + } + + public virtual TL SelectAll() + where TL : IList, 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 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 list) + { + var db = GetDbManager(); + + try + { + return Insert(db, maxBatchSize, list); + } + finally + { + if (DisposeDbManager) + db.Dispose(); + } + } + + public virtual int Insert(DbManager db, IEnumerable list) + { + return Insert(db, int.MaxValue, list); + } + + public virtual int Insert(IEnumerable 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 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 list) + { + var db = GetDbManager(); + + try + { + return Update(db, maxBatchSize, list); + } + finally + { + if (DisposeDbManager) + db.Dispose(); + } + } + + public virtual int Update(DbManager db, IEnumerable list) + { + return Update(db, int.MaxValue, list); + } + + public virtual int Update(IEnumerable 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 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 list) + { + var db = GetDbManager(); + + try + { + return Delete(db, list); + } + finally + { + if (DisposeDbManager) + db.Dispose(); + } + } + + public virtual int Delete(DbManager db, IEnumerable list) + { + return Delete(db, int.MaxValue, list); + } + + public virtual int Delete(IEnumerable list) + { + return Delete(int.MaxValue, list); + } + + #endregion + + #region Helpers + + protected int ExecuteForEach( + DbManager db, + IEnumerable collection, + MemberMapper[] members, + int maxBatchSize, + DbManager.ParameterProvider getParameters) + { + return db.ExecuteForEach(collection, members, maxBatchSize, getParameters); + } + + #endregion + } +}