// ======================================================================== // Copyright 2007 - Volian Enterprises, Inc. All rights reserved. // Volian Enterprises - Proprietary Information - DO NOT COPY OR DISTRIBUTE // ------------------------------------------------------------------------ // $Workfile: $ $Revision: $ // $Author: $ $Date: $ // // $History: $ // ======================================================================== using System; using System.Data; using System.Data.SqlClient; using Csla; using Csla.Data; using System.Configuration; using System.IO; using System.ComponentModel; using System.Collections.Generic; using Csla.Validation; namespace VEPROMS.CSLA.Library { /// /// Owner Generated by MyGeneration using the CSLA Object Mapping template /// [Serializable()] [TypeConverter(typeof(OwnerConverter))] public partial class Owner : BusinessBase, IDisposable, IVEHasBrokenRules { #region Log4Net private static readonly log4net.ILog _MyLog = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); #endregion #region Refresh private List _RefreshOwners = new List(); private void AddToRefreshList(List refreshOwners) { if (IsDirty) refreshOwners.Add(this); } private void ClearRefreshList() { _RefreshOwners = new List(); } private void BuildRefreshList() { ClearRefreshList(); AddToRefreshList(_RefreshOwners); } private void ProcessRefreshList() { foreach (Owner tmp in _RefreshOwners) { OwnerInfo.Refresh(tmp); } ClearRefreshList(); } #endregion #region Collection private static List _CacheList = new List(); protected static void AddToCache(Owner owner) { if (!_CacheList.Contains(owner)) _CacheList.Add(owner); // In AddToCache } protected static void RemoveFromCache(Owner owner) { while (_CacheList.Contains(owner)) _CacheList.Remove(owner); // In RemoveFromCache } private static Dictionary> _CacheByPrimaryKey = new Dictionary>(); private static void ConvertListToDictionary() { while (_CacheList.Count > 0) // Move Owner(s) from temporary _CacheList to _CacheByPrimaryKey { Owner tmp = _CacheList[0]; // Get the first Owner string pKey = tmp.OwnerID.ToString(); if (!_CacheByPrimaryKey.ContainsKey(pKey)) { _CacheByPrimaryKey[pKey] = new List(); // Add new list for PrimaryKey } _CacheByPrimaryKey[pKey].Add(tmp); // Add to Primary Key list _CacheList.RemoveAt(0); // Remove the first Owner } } protected static Owner GetCachedByPrimaryKey(int ownerID) { ConvertListToDictionary(); string key = ownerID.ToString(); if (_CacheByPrimaryKey.ContainsKey(key)) return _CacheByPrimaryKey[key][0]; return null; } #endregion #region Business Methods private string _ErrorMessage = string.Empty; public string ErrorMessage { get { return _ErrorMessage; } } private static int _nextOwnerID = -1; public static int NextOwnerID { get { return _nextOwnerID--; } } private int _OwnerID; [System.ComponentModel.DataObjectField(true, true)] public int OwnerID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _OwnerID; } } private int _SessionID; public int SessionID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _SessionID; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_SessionID != value) { _SessionID = value; PropertyHasChanged(); } } } private byte _OwnerType; public byte OwnerType { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _OwnerType; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_OwnerType != value) { _OwnerType = value; PropertyHasChanged(); } } } private int _OwnerItemID; public int OwnerItemID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _OwnerItemID; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_OwnerItemID != value) { _OwnerItemID = value; PropertyHasChanged(); } } } private DateTime _DTSStart = new DateTime(); public DateTime DTSStart { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _DTSStart; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_DTSStart != value) { _DTSStart = value; PropertyHasChanged(); } } } private byte[] _LastChanged = new byte[8];//timestamp public override bool IsDirty { get { return base.IsDirty; } } public bool IsDirtyList(List list) { return base.IsDirty; } public override bool IsValid { get { return (IsNew && !IsDirty) ? true : base.IsValid; } } public bool IsValidList(List list) { return (IsNew && !IsDirty) ? true : base.IsValid; } // CSLATODO: Replace base Owner.ToString function as necessary /// /// Overrides Base ToString /// /// A string representation of current Owner //public override string ToString() //{ // return base.ToString(); //} // CSLATODO: Check Owner.GetIdValue to assure that the ID returned is unique /// /// Overrides Base GetIdValue - Used internally by CSLA to determine equality /// /// A Unique ID for the current Owner protected override object GetIdValue() { return MyOwnerUnique; // Absolutely Unique ID } #endregion #region ValidationRules [NonSerialized] private bool _CheckingBrokenRules = false; public IVEHasBrokenRules HasBrokenRules { get { if (_CheckingBrokenRules) return null; if ((IsDirty || !IsNew) && BrokenRulesCollection.Count > 0) return this; try { _CheckingBrokenRules = true; IVEHasBrokenRules hasBrokenRules = null; return hasBrokenRules; } finally { _CheckingBrokenRules = false; } } } public BrokenRulesCollection BrokenRules { get { IVEHasBrokenRules hasBrokenRules = HasBrokenRules; if (this.Equals(hasBrokenRules)) return BrokenRulesCollection; return (hasBrokenRules != null ? hasBrokenRules.BrokenRules : null); } } protected override void AddBusinessRules() { //ValidationRules.AddDependantProperty("x", "y"); _OwnerExtension.AddValidationRules(ValidationRules); // CSLATODO: Add other validation rules } protected override void AddInstanceBusinessRules() { _OwnerExtension.AddInstanceValidationRules(ValidationRules); // CSLATODO: Add other validation rules } // Sample data comparison validation rule //private bool StartDateGTEndDate(object target, Csla.Validation.RuleArgs e) //{ // if (_started > _ended) // { // e.Description = "Start date can't be after end date"; // return false; // } // else // return true; //} #endregion #region Authorization Rules protected override void AddAuthorizationRules() { //CSLATODO: Who can read/write which fields //AuthorizationRules.AllowRead(OwnerID, ""); //AuthorizationRules.AllowRead(SessionID, ""); //AuthorizationRules.AllowRead(OwnerType, ""); //AuthorizationRules.AllowRead(OwnerItemID, ""); //AuthorizationRules.AllowRead(DTSStart, ""); //AuthorizationRules.AllowWrite(SessionID, ""); //AuthorizationRules.AllowWrite(OwnerType, ""); //AuthorizationRules.AllowWrite(OwnerItemID, ""); //AuthorizationRules.AllowWrite(DTSStart, ""); _OwnerExtension.AddAuthorizationRules(AuthorizationRules); } protected override void AddInstanceAuthorizationRules() { //CSLATODO: Who can read/write which fields _OwnerExtension.AddInstanceAuthorizationRules(AuthorizationRules); } public static bool CanAddObject() { // CSLATODO: Can Add Authorization //return Csla.ApplicationContext.User.IsInRole("ProjectManager"); return true; } public static bool CanGetObject() { // CSLATODO: CanGet Authorization return true; } public static bool CanDeleteObject() { // CSLATODO: CanDelete Authorization //bool result = false; //if (Csla.ApplicationContext.User.IsInRole("ProjectManager"))result = true; //if (Csla.ApplicationContext.User.IsInRole("Administrator"))result = true; //return result; return true; } public static bool CanEditObject() { // CSLATODO: CanEdit Authorization //return Csla.ApplicationContext.User.IsInRole("ProjectManager"); return true; } #endregion #region Factory Methods public int CurrentEditLevel { get { return EditLevel; } } private static int _OwnerUnique = 0; protected static int OwnerUnique { get { return ++_OwnerUnique; } } private int _MyOwnerUnique = OwnerUnique; public int MyOwnerUnique // Absolutely Unique ID - Editable { get { return _MyOwnerUnique; } } protected Owner() {/* require use of factory methods */ AddToCache(this); } private bool _Disposed = false; private static int _CountCreated = 0; private static int _CountDisposed = 0; private static int _CountFinalized = 0; private static int IncrementCountCreated { get { return ++_CountCreated; } } private int _CountWhenCreated = IncrementCountCreated; public static int CountCreated { get { return _CountCreated; } } public static int CountNotDisposed { get { return _CountCreated - _CountDisposed; } } public static int CountNotFinalized { get { return _CountCreated - _CountFinalized; } } ~Owner() { _CountFinalized++; } public void Dispose() { if (_Disposed) return; _CountDisposed++; _Disposed = true; RemoveFromDictionaries(); } private void RemoveFromDictionaries() { RemoveFromCache(this); if (_CacheByPrimaryKey.ContainsKey(OwnerID.ToString())) { List listOwner = _CacheByPrimaryKey[OwnerID.ToString()]; // Get the list of items while (listOwner.Contains(this)) listOwner.Remove(this); // Remove the item from the list if (listOwner.Count == 0) //If there are no items left in the list _CacheByPrimaryKey.Remove(OwnerID.ToString()); // remove the list } } public static Owner New() { if (!CanAddObject()) throw new System.Security.SecurityException("User not authorized to add a Owner"); try { return DataPortal.Create(); } catch (Exception ex) { throw new DbCslaException("Error on Owner.New", ex); } } public static Owner New(int sessionID, byte ownerType, int ownerItemID, DateTime dTSStart) { Owner tmp = Owner.New(); tmp.SessionID = sessionID; tmp.OwnerType = ownerType; tmp.OwnerItemID = ownerItemID; tmp.DTSStart = dTSStart; return tmp; } public static Owner MakeOwner(int sessionID, byte ownerType, int ownerItemID, DateTime dTSStart) { Owner tmp = Owner.New(sessionID, ownerType, ownerItemID, dTSStart); if (tmp.IsSavable) tmp = tmp.Save(); else { Csla.Validation.BrokenRulesCollection brc = tmp.ValidationRules.GetBrokenRules(); tmp._ErrorMessage = "Failed Validation:"; foreach (Csla.Validation.BrokenRule br in brc) { tmp._ErrorMessage += "\r\n\tFailure: " + br.RuleName; } } return tmp; } public static Owner Get(int ownerID) { if (!CanGetObject()) throw new System.Security.SecurityException("User not authorized to view a Owner"); try { Owner tmp = GetCachedByPrimaryKey(ownerID); if (tmp == null) { tmp = DataPortal.Fetch(new PKCriteria(ownerID)); AddToCache(tmp); } if (tmp.ErrorMessage == "No Record Found") { tmp.Dispose(); // Clean-up Owner tmp = null; } return tmp; } catch (Exception ex) { throw new DbCslaException("Error on Owner.Get", ex); } } public static Owner Get(SafeDataReader dr) { if (dr.Read()) return new Owner(dr); return null; } internal Owner(SafeDataReader dr) { ReadData(dr); } public static void Delete(int ownerID) { if (!CanDeleteObject()) throw new System.Security.SecurityException("User not authorized to remove a Owner"); try { DataPortal.Delete(new PKCriteria(ownerID)); } catch (Exception ex) { throw new DbCslaException("Error on Owner.Delete", ex); } } public override Owner Save() { if (IsDeleted && !CanDeleteObject()) throw new System.Security.SecurityException("User not authorized to remove a Owner"); else if (IsNew && !CanAddObject()) throw new System.Security.SecurityException("User not authorized to add a Owner"); else if (!CanEditObject()) throw new System.Security.SecurityException("User not authorized to update a Owner"); try { BuildRefreshList(); Owner owner = base.Save(); RemoveFromDictionaries(); // if save is successful remove the previous Folder from the cache AddToCache(owner);//Refresh the item in AllList ProcessRefreshList(); return owner; } catch (Exception ex) { throw new DbCslaException("Error on CSLA Save", ex); } } #endregion #region Data Access Portal [Serializable()] protected class PKCriteria { private int _OwnerID; public int OwnerID { get { return _OwnerID; } } public PKCriteria(int ownerID) { _OwnerID = ownerID; } } // CSLATODO: If Create needs to access DB - It should not be marked RunLocal [RunLocal()] private new void DataPortal_Create() { _OwnerID = NextOwnerID; // Database Defaults _SessionID = _OwnerExtension.DefaultSessionID; _OwnerType = _OwnerExtension.DefaultOwnerType; _OwnerItemID = _OwnerExtension.DefaultOwnerItemID; _DTSStart = _OwnerExtension.DefaultDTSStart; // CSLATODO: Add any defaults that are necessary ValidationRules.CheckRules(); } private void ReadData(SafeDataReader dr) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.ReadData", GetHashCode()); try { _OwnerID = dr.GetInt32("OwnerID"); _SessionID = dr.GetInt32("SessionID"); _OwnerType = dr.GetByte("OwnerType"); _OwnerItemID = dr.GetInt32("OwnerItemID"); _DTSStart = dr.GetDateTime("DTSStart"); dr.GetBytes("LastChanged", 0, _LastChanged, 0, 8); MarkOld(); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.ReadData", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Owner.ReadData", ex); } } private void DataPortal_Fetch(PKCriteria criteria) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.DataPortal_Fetch", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { ApplicationContext.LocalContext["cn"] = cn; using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "getOwner"; cm.Parameters.AddWithValue("@OwnerID", criteria.OwnerID); using (SafeDataReader dr = new SafeDataReader(cm.ExecuteReader())) { if (!dr.Read()) { _ErrorMessage = "No Record Found"; return; } ReadData(dr); } } // removing of item only needed for local data portal if (ApplicationContext.ExecutionLocation == ApplicationContext.ExecutionLocations.Client) ApplicationContext.LocalContext.Remove("cn"); } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.DataPortal_Fetch", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Owner.DataPortal_Fetch", ex); } } [Transactional(TransactionalTypes.TransactionScope)] protected override void DataPortal_Insert() { try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { ApplicationContext.LocalContext["cn"] = cn; SQLInsert(); // removing of item only needed for local data portal if (ApplicationContext.ExecutionLocation == ApplicationContext.ExecutionLocations.Client) ApplicationContext.LocalContext.Remove("cn"); } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.DataPortal_Insert", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Owner.DataPortal_Insert", ex); } finally { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.DataPortal_Insert", GetHashCode()); } } [Transactional(TransactionalTypes.TransactionScope)] internal void SQLInsert() { if (!this.IsDirty) return; try { SqlConnection cn = (SqlConnection)ApplicationContext.LocalContext["cn"]; using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "addOwner"; // Input All Fields - Except Calculated Columns cm.Parameters.AddWithValue("@SessionID", _SessionID); cm.Parameters.AddWithValue("@OwnerType", _OwnerType); cm.Parameters.AddWithValue("@OwnerItemID", _OwnerItemID); if (_DTSStart.Year >= 1753 && _DTSStart.Year <= 9999) cm.Parameters.AddWithValue("@DTSStart", _DTSStart); // Output Calculated Columns SqlParameter param_OwnerID = new SqlParameter("@newOwnerID", SqlDbType.Int); param_OwnerID.Direction = ParameterDirection.Output; cm.Parameters.Add(param_OwnerID); SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp); param_LastChanged.Direction = ParameterDirection.Output; cm.Parameters.Add(param_LastChanged); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure _OwnerID = (int)cm.Parameters["@newOwnerID"].Value; _LastChanged = (byte[])cm.Parameters["@newLastChanged"].Value; } MarkOld(); // update child objects if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.SQLInsert", GetHashCode()); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.SQLInsert", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Owner.SQLInsert", ex); } } [Transactional(TransactionalTypes.TransactionScope)] public static byte[] Add(SqlConnection cn, ref int ownerID, int sessionID, byte ownerType, int ownerItemID, DateTime dTSStart) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.Add", 0); try { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "addOwner"; // Input All Fields - Except Calculated Columns cm.Parameters.AddWithValue("@SessionID", sessionID); cm.Parameters.AddWithValue("@OwnerType", ownerType); cm.Parameters.AddWithValue("@OwnerItemID", ownerItemID); if (dTSStart.Year >= 1753 && dTSStart.Year <= 9999) cm.Parameters.AddWithValue("@DTSStart", dTSStart); // Output Calculated Columns SqlParameter param_OwnerID = new SqlParameter("@newOwnerID", SqlDbType.Int); param_OwnerID.Direction = ParameterDirection.Output; cm.Parameters.Add(param_OwnerID); SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp); param_LastChanged.Direction = ParameterDirection.Output; cm.Parameters.Add(param_LastChanged); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure ownerID = (int)cm.Parameters["@newOwnerID"].Value; return (byte[])cm.Parameters["@newLastChanged"].Value; } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.Add", ex); throw new DbCslaException("Owner.Add", ex); } } [Transactional(TransactionalTypes.TransactionScope)] protected override void DataPortal_Update() { if (!IsDirty) return; // If not dirty - nothing to do if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.DataPortal_Update", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { ApplicationContext.LocalContext["cn"] = cn; SQLUpdate(); // removing of item only needed for local data portal if (ApplicationContext.ExecutionLocation == ApplicationContext.ExecutionLocations.Client) ApplicationContext.LocalContext.Remove("cn"); } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.DataPortal_Update", ex); _ErrorMessage = ex.Message; if (!ex.Message.EndsWith("has been edited by another user.")) throw ex; } } [Transactional(TransactionalTypes.TransactionScope)] internal void SQLUpdate() { if (!IsDirty) return; // If not dirty - nothing to do if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.SQLUpdate", GetHashCode()); try { SqlConnection cn = (SqlConnection)ApplicationContext.LocalContext["cn"]; if (base.IsDirty) { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "updateOwner"; // All Fields including Calculated Fields cm.Parameters.AddWithValue("@OwnerID", _OwnerID); cm.Parameters.AddWithValue("@SessionID", _SessionID); cm.Parameters.AddWithValue("@OwnerType", _OwnerType); cm.Parameters.AddWithValue("@OwnerItemID", _OwnerItemID); if (_DTSStart.Year >= 1753 && _DTSStart.Year <= 9999) cm.Parameters.AddWithValue("@DTSStart", _DTSStart); cm.Parameters.AddWithValue("@LastChanged", _LastChanged); // Output Calculated Columns SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp); param_LastChanged.Direction = ParameterDirection.Output; cm.Parameters.Add(param_LastChanged); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure _LastChanged = (byte[])cm.Parameters["@newLastChanged"].Value; } } MarkOld(); // use the open connection to update child objects } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.SQLUpdate", ex); _ErrorMessage = ex.Message; if (!ex.Message.EndsWith("has been edited by another user.")) throw ex; } } internal void Update() { if (!this.IsDirty) return; if (base.IsDirty) { SqlConnection cn = (SqlConnection)ApplicationContext.LocalContext["cn"]; if (IsNew) _LastChanged = Owner.Add(cn, ref _OwnerID, _SessionID, _OwnerType, _OwnerItemID, _DTSStart); else _LastChanged = Owner.Update(cn, ref _OwnerID, _SessionID, _OwnerType, _OwnerItemID, _DTSStart, ref _LastChanged); MarkOld(); } } [Transactional(TransactionalTypes.TransactionScope)] public static byte[] Update(SqlConnection cn, ref int ownerID, int sessionID, byte ownerType, int ownerItemID, DateTime dTSStart, ref byte[] lastChanged) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.Update", 0); try { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "updateOwner"; // Input All Fields - Except Calculated Columns cm.Parameters.AddWithValue("@OwnerID", ownerID); cm.Parameters.AddWithValue("@SessionID", sessionID); cm.Parameters.AddWithValue("@OwnerType", ownerType); cm.Parameters.AddWithValue("@OwnerItemID", ownerItemID); if (dTSStart.Year >= 1753 && dTSStart.Year <= 9999) cm.Parameters.AddWithValue("@DTSStart", dTSStart); cm.Parameters.AddWithValue("@LastChanged", lastChanged); // Output Calculated Columns SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp); param_LastChanged.Direction = ParameterDirection.Output; cm.Parameters.Add(param_LastChanged); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure return (byte[])cm.Parameters["@newLastChanged"].Value; } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.Update", ex); throw new DbCslaException("Owner.Update", ex); } } [Transactional(TransactionalTypes.TransactionScope)] protected override void DataPortal_DeleteSelf() { DataPortal_Delete(new PKCriteria(_OwnerID)); } [Transactional(TransactionalTypes.TransactionScope)] private void DataPortal_Delete(PKCriteria criteria) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.DataPortal_Delete", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "deleteOwner"; cm.Parameters.AddWithValue("@OwnerID", criteria.OwnerID); cm.ExecuteNonQuery(); } } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.DataPortal_Delete", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Owner.DataPortal_Delete", ex); } } [Transactional(TransactionalTypes.TransactionScope)] public static void Remove(SqlConnection cn, int ownerID) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.Remove", 0); try { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "deleteOwner"; // Input PK Fields cm.Parameters.AddWithValue("@OwnerID", ownerID); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.Remove", ex); throw new DbCslaException("Owner.Remove", ex); } } #endregion #region Exists public static bool Exists(int ownerID) { ExistsCommand result; try { result = DataPortal.Execute(new ExistsCommand(ownerID)); return result.Exists; } catch (Exception ex) { throw new DbCslaException("Error on Owner.Exists", ex); } } [Serializable()] private class ExistsCommand : CommandBase { private int _OwnerID; private bool _exists; public bool Exists { get { return _exists; } } public ExistsCommand(int ownerID) { _OwnerID = ownerID; } protected override void DataPortal_Execute() { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Owner.DataPortal_Execute", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { cn.Open(); using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "existsOwner"; cm.Parameters.AddWithValue("@OwnerID", _OwnerID); int count = (int)cm.ExecuteScalar(); _exists = (count > 0); } } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Owner.DataPortal_Execute", ex); throw new DbCslaException("Owner.DataPortal_Execute", ex); } } } #endregion // Standard Default Code #region extension OwnerExtension _OwnerExtension = new OwnerExtension(); [Serializable()] partial class OwnerExtension : extensionBase { } [Serializable()] class extensionBase { // Default Values public virtual int DefaultSessionID { get { return 0; } } public virtual byte DefaultOwnerType { get { return 0; } } public virtual int DefaultOwnerItemID { get { return 0; } } public virtual DateTime DefaultDTSStart { get { return DateTime.Now; } } // Authorization Rules public virtual void AddAuthorizationRules(Csla.Security.AuthorizationRules rules) { // Needs to be overriden to add new authorization rules } // Instance Authorization Rules public virtual void AddInstanceAuthorizationRules(Csla.Security.AuthorizationRules rules) { // Needs to be overriden to add new authorization rules } // Validation Rules public virtual void AddValidationRules(Csla.Validation.ValidationRules rules) { // Needs to be overriden to add new validation rules } // InstanceValidation Rules public virtual void AddInstanceValidationRules(Csla.Validation.ValidationRules rules) { // Needs to be overriden to add new validation rules } } #endregion } // Class #region Converter internal class OwnerConverter : ExpandableObjectConverter { public override object ConvertTo(ITypeDescriptorContext context, System.Globalization.CultureInfo culture, object value, Type destType) { if (destType == typeof(string) && value is Owner) { // Return the ToString value return ((Owner)value).ToString(); } return base.ConvertTo(context, culture, value, destType); } } #endregion } // Namespace //// The following is a sample Extension File. You can use it to create OwnerExt.cs //using System; //using System.Collections.Generic; //using System.Text; //using Csla; //namespace VEPROMS.CSLA.Library //{ // public partial class Owner // { // partial class OwnerExtension : extensionBase // { // // CSLATODO: Override automatic defaults // public virtual int DefaultSessionID // { // get { return 0; } // } // public virtual byte DefaultOwnerType // { // get { return 0; } // } // public virtual int DefaultOwnerItemID // { // get { return 0; } // } // public virtual DateTime DefaultDTSStart // { // get { return DateTime.Now; } // } // public new void AddAuthorizationRules(Csla.Security.AuthorizationRules rules) // { // //rules.AllowRead(Dbid, ""); // } // public new void AddInstanceAuthorizationRules(Csla.Security.AuthorizationRules rules) // { // //rules.AllowInstanceRead(Dbid, ""); // } // public new void AddValidationRules(Csla.Validation.ValidationRules rules) // { // rules.AddRule( // Csla.Validation.CommonRules.StringMaxLength, // new Csla.Validation.CommonRules.MaxLengthRuleArgs("Name", 100)); // } // public new void AddInstanceValidationRules(Csla.Validation.ValidationRules rules) // { // rules.AddInstanceRule(/* Instance Validation Rule */); // } // } // } //}