using System; using System.Collections.Generic; using System.Data; using System.Linq; using Kreta.Framework; using Kreta.Framework.Collections; using Kreta.Framework.Collections.Generic; using Kreta.Framework.Entities; using Kreta.Framework.Entities.Associations; using Kreta.Framework.Entities.Generic; namespace SDA.Kreta.Entities { internal sealed class CimDBHelper : EntityDBHelper { private Dictionary dynamicColumns = new Dictionary() { { "CimTipusa", "T_CIM_OSSZES.C_CIMTIPUSA" }, { "Orszag", "T_CIM_OSSZES.C_ORSZAG" }, { "IranyitoSzam", "T_CIM_OSSZES.C_IRANYITOSZAM" }, { "Varos", "T_CIM_OSSZES.C_VAROS" }, { "Megye", "T_CIM_OSSZES.C_MEGYE" }, { "Kozterulet", "T_CIM_OSSZES.C_KOZTERULET" }, { "Hazszam", "T_CIM_OSSZES.C_HAZSZAM" }, { "Epulet", "T_CIM_OSSZES.C_EPULET" }, { "Lepcsohaz", "T_CIM_OSSZES.C_LEPCSOHAZ" }, { "Emelet", "T_CIM_OSSZES.C_EMELET" }, { "Ajto", "T_CIM_OSSZES.C_AJTO" }, { "OsszetettCim", "T_CIM_OSSZES.C_OSSZETETTCIM" }, { "Alapertelmezett", "T_CIM_OSSZES.C_ALAPERTELMEZETT" }, { "KozteruletJellegeNev", "T_CIM_OSSZES.C_KOZTERULETJELLEGENEV" }, }; private const string dynamicQueryCommandText = "select " + "T_CIM_OSSZES.ID, " + "{COLUMNS}" + // Cim betöltése // Cim kapcsoló mezői "T_CIM_OSSZES.C_FELHASZNALOID, " + /* Kötelező asszociációs kapcsolómező */ "T_CIM_OSSZES.C_GONDVISELOID, " + /* Opcionális asszociációs kapcsolómező */ "T_CIM_OSSZES.C_INTEZMENYID, " + /* Kötelező asszociációs kapcsolómező */ "T_CIM_OSSZES.C_TANEVID, " + /* Kötelező asszociációs kapcsolómező */ "T_CIM_OSSZES.TOROLT, " + "T_CIM_OSSZES.SERIAL, " + "T_CIM_OSSZES.CREATED, " + "T_CIM_OSSZES.CREATOR, " + "T_CIM_OSSZES.LASTCHANGED, " + "T_CIM_OSSZES.MODIFIER " + "from " + "T_CIM_OSSZES " + "where " + "(1 = 1) "; private const string emptyQueryCommandText = "select " + "T_CIM_OSSZES.ID, " + // Cim betöltése // Cim mezői "T_CIM_OSSZES.C_CIMTIPUSA, " + "T_CIM_OSSZES.C_ORSZAG, " + "T_CIM_OSSZES.C_IRANYITOSZAM, " + "T_CIM_OSSZES.C_VAROS, " + "T_CIM_OSSZES.C_MEGYE, " + "T_CIM_OSSZES.C_KOZTERULET, " + "T_CIM_OSSZES.C_HAZSZAM, " + "T_CIM_OSSZES.C_EPULET, " + "T_CIM_OSSZES.C_LEPCSOHAZ, " + "T_CIM_OSSZES.C_EMELET, " + "T_CIM_OSSZES.C_AJTO, " + "T_CIM_OSSZES.C_OSSZETETTCIM, " + "T_CIM_OSSZES.C_ALAPERTELMEZETT, " + "T_CIM_OSSZES.C_KOZTERULETJELLEGENEV, " + // Cim kapcsoló mezői "T_CIM_OSSZES.C_FELHASZNALOID, " + /* Kötelező asszociációs kapcsolómező */ "T_CIM_OSSZES.C_GONDVISELOID, " + /* Opcionális asszociációs kapcsolómező */ "T_CIM_OSSZES.C_INTEZMENYID, " + /* Kötelező asszociációs kapcsolómező */ "T_CIM_OSSZES.C_TANEVID, " + /* Kötelező asszociációs kapcsolómező */ "T_CIM_OSSZES.TOROLT, " + "T_CIM_OSSZES.SERIAL, " + "T_CIM_OSSZES.CREATED, " + "T_CIM_OSSZES.CREATOR, " + "T_CIM_OSSZES.LASTCHANGED, " + "T_CIM_OSSZES.MODIFIER " + "from " + "T_CIM_OSSZES " + "where " + "(1 = 1) "; public override string EmptyQueryCommandText { get { return emptyQueryCommandText; } } public override string DynamicQueryCommandText { get { return dynamicQueryCommandText; } } public override IDictionary DynamicColumns { get { return dynamicColumns; } } protected override Cim CreateEntityInstance() { return Cim.GiveAnInstance(); } #region Lekérdezés public override void LoadEntityFields(Cim entity, SDA.DataProvider.SDADataReader reader) { // Cim betöltése // Cim mezői entity.m_CimTipusa = DAUtil.ReadIntegerAttribute(reader, 1, -1); entity.m_Orszag = DAUtil.ReadIntegerAttribute(reader, 2, -1); entity.m_IranyitoSzam = DAUtil.ReadStringAttribute(reader, 3); entity.m_Varos = DAUtil.ReadStringAttribute(reader, 4); entity.m_Megye = DAUtil.ReadStringAttribute(reader, 5); entity.m_Kozterulet = DAUtil.ReadStringAttribute(reader, 6); entity.m_Hazszam = DAUtil.ReadStringAttribute(reader, 7); entity.m_Epulet = DAUtil.ReadStringAttribute(reader, 8); entity.m_Lepcsohaz = DAUtil.ReadStringAttribute(reader, 9); entity.m_Emelet = DAUtil.ReadStringAttribute(reader, 10); entity.m_Ajto = DAUtil.ReadStringAttribute(reader, 11); entity.m_OsszetettCim = DAUtil.ReadStringAttribute(reader, 12); entity.m_Alapertelmezett = DAUtil.ReadBooleanAttribute(reader, 13, false); entity.m_KozteruletJellegeNev = DAUtil.ReadStringAttribute(reader, 14); // Cim kapcsoló mezői DAUtil.ReadIDAttribute(reader, 15, ref entity.m_FelhasznaloId, 0); DAUtil.ReadIDAttribute(reader, 16, ref entity.m_GondviseloId, -1); DAUtil.ReadIDAttribute(reader, 17, ref entity.m_IntezmenyId, 0); DAUtil.ReadIDAttribute(reader, 18, ref entity.m_TanevId, 0); } public override void LoadEntityFields(Cim entity, SDA.DataProvider.SDADataReader reader, ColumnFilterMode columnFilterMode, IEnumerable columns) { int index = 1; if (columns == null) { columns = new List(index); } // Cim betöltése // Cim mezői if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("CimTipusa")))) { entity.m_CimTipusa = DAUtil.ReadIntegerAttribute(reader, index++, -1); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Orszag")))) { entity.m_Orszag = DAUtil.ReadIntegerAttribute(reader, index++, -1); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("IranyitoSzam")))) { entity.m_IranyitoSzam = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Varos")))) { entity.m_Varos = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Megye")))) { entity.m_Megye = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Kozterulet")))) { entity.m_Kozterulet = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Hazszam")))) { entity.m_Hazszam = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Epulet")))) { entity.m_Epulet = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Lepcsohaz")))) { entity.m_Lepcsohaz = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Emelet")))) { entity.m_Emelet = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Ajto")))) { entity.m_Ajto = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("OsszetettCim")))) { entity.m_OsszetettCim = DAUtil.ReadStringAttribute(reader, index++); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("Alapertelmezett")))) { entity.m_Alapertelmezett = DAUtil.ReadBooleanAttribute(reader, index++, false); } if (((columnFilterMode == ColumnFilterMode.DEFAULT_ALLOWED) ^ (columns.Contains("KozteruletJellegeNev")))) { entity.m_KozteruletJellegeNev = DAUtil.ReadStringAttribute(reader, index++); } // Cim kapcsoló mezői DAUtil.ReadIDAttribute(reader, index++, ref entity.m_FelhasznaloId, 0); DAUtil.ReadIDAttribute(reader, index++, ref entity.m_GondviseloId, -1); DAUtil.ReadIDAttribute(reader, index++, ref entity.m_IntezmenyId, 0); DAUtil.ReadIDAttribute(reader, index++, ref entity.m_TanevId, 0); } #endregion #region Paraméter kötés public override void BindAttributes(Cim entity, SDA.DataProvider.SDACommand command) { DAUtil.BindParameter(command, "pCIMTIPUSA", SDA.DataProvider.SDADBType.Int /* DictionaryItem */, 15, entity.m_CimTipusa, false); DAUtil.BindParameter(command, "pORSZAG", SDA.DataProvider.SDADBType.Int /* DictionaryItem */, 40, entity.m_Orszag, false); DAUtil.BindParameter(command, "pIRANYITOSZAM", SDA.DataProvider.SDADBType.String, 20, entity.m_IranyitoSzam, entity.m_IranyitoSzam == null); DAUtil.BindParameter(command, "pVAROS", SDA.DataProvider.SDADBType.String, 50, entity.m_Varos, entity.m_Varos == null); DAUtil.BindParameter(command, "pMEGYE", SDA.DataProvider.SDADBType.String, 40, entity.m_Megye, entity.m_Megye == null); DAUtil.BindParameter(command, "pKOZTERULET", SDA.DataProvider.SDADBType.String, 40, entity.m_Kozterulet, entity.m_Kozterulet == null); DAUtil.BindParameter(command, "pHAZSZAM", SDA.DataProvider.SDADBType.String, 30, entity.m_Hazszam, entity.m_Hazszam == null); DAUtil.BindParameter(command, "pEPULET", SDA.DataProvider.SDADBType.String, 6, entity.m_Epulet, entity.m_Epulet == null); DAUtil.BindParameter(command, "pLEPCSOHAZ", SDA.DataProvider.SDADBType.String, 6, entity.m_Lepcsohaz, entity.m_Lepcsohaz == null); DAUtil.BindParameter(command, "pEMELET", SDA.DataProvider.SDADBType.String, 40, entity.m_Emelet, entity.m_Emelet == null); DAUtil.BindParameter(command, "pAJTO", SDA.DataProvider.SDADBType.String, 30, entity.m_Ajto, entity.m_Ajto == null); DAUtil.BindParameter(command, "pOSSZETETTCIM", SDA.DataProvider.SDADBType.String, 512, entity.m_OsszetettCim, entity.m_OsszetettCim == null); DAUtil.BindParameter(command, "pALAPERTELMEZETT", SDA.DataProvider.SDADBType.Boolean /* Boolean */, 1, entity.m_Alapertelmezett, false); DAUtil.BindParameter(command, "pKOZTERULETJELLEGENEV", SDA.DataProvider.SDADBType.String, 50, entity.m_KozteruletJellegeNev, entity.m_KozteruletJellegeNev == null); } public override void DynamicBindAttributes(Cim entity, SDA.DataProvider.SDACommand command) { System.Text.StringBuilder sb = new System.Text.StringBuilder(); if (entity.HasChanged("CimTipusa")) { sb.Append("C_CIMTIPUSA = :pCIMTIPUSA,"); DAUtil.BindParameter(command, "pCIMTIPUSA", SDA.DataProvider.SDADBType.Int /* DictionaryItem */, 15, entity.m_CimTipusa, false); } if (entity.HasChanged("Orszag")) { sb.Append("C_ORSZAG = :pORSZAG,"); DAUtil.BindParameter(command, "pORSZAG", SDA.DataProvider.SDADBType.Int /* DictionaryItem */, 40, entity.m_Orszag, false); } if (entity.HasChanged("IranyitoSzam")) { sb.Append("C_IRANYITOSZAM = :pIRANYITOSZAM,"); DAUtil.BindParameter(command, "pIRANYITOSZAM", SDA.DataProvider.SDADBType.String, 20, entity.m_IranyitoSzam, entity.m_IranyitoSzam == null); } if (entity.HasChanged("Varos")) { sb.Append("C_VAROS = :pVAROS,"); DAUtil.BindParameter(command, "pVAROS", SDA.DataProvider.SDADBType.String, 50, entity.m_Varos, entity.m_Varos == null); } if (entity.HasChanged("Megye")) { sb.Append("C_MEGYE = :pMEGYE,"); DAUtil.BindParameter(command, "pMEGYE", SDA.DataProvider.SDADBType.String, 40, entity.m_Megye, entity.m_Megye == null); } if (entity.HasChanged("Kozterulet")) { sb.Append("C_KOZTERULET = :pKOZTERULET,"); DAUtil.BindParameter(command, "pKOZTERULET", SDA.DataProvider.SDADBType.String, 40, entity.m_Kozterulet, entity.m_Kozterulet == null); } if (entity.HasChanged("Hazszam")) { sb.Append("C_HAZSZAM = :pHAZSZAM,"); DAUtil.BindParameter(command, "pHAZSZAM", SDA.DataProvider.SDADBType.String, 30, entity.m_Hazszam, entity.m_Hazszam == null); } if (entity.HasChanged("Epulet")) { sb.Append("C_EPULET = :pEPULET,"); DAUtil.BindParameter(command, "pEPULET", SDA.DataProvider.SDADBType.String, 6, entity.m_Epulet, entity.m_Epulet == null); } if (entity.HasChanged("Lepcsohaz")) { sb.Append("C_LEPCSOHAZ = :pLEPCSOHAZ,"); DAUtil.BindParameter(command, "pLEPCSOHAZ", SDA.DataProvider.SDADBType.String, 6, entity.m_Lepcsohaz, entity.m_Lepcsohaz == null); } if (entity.HasChanged("Emelet")) { sb.Append("C_EMELET = :pEMELET,"); DAUtil.BindParameter(command, "pEMELET", SDA.DataProvider.SDADBType.String, 40, entity.m_Emelet, entity.m_Emelet == null); } if (entity.HasChanged("Ajto")) { sb.Append("C_AJTO = :pAJTO,"); DAUtil.BindParameter(command, "pAJTO", SDA.DataProvider.SDADBType.String, 30, entity.m_Ajto, entity.m_Ajto == null); } if (entity.HasChanged("OsszetettCim")) { sb.Append("C_OSSZETETTCIM = :pOSSZETETTCIM,"); DAUtil.BindParameter(command, "pOSSZETETTCIM", SDA.DataProvider.SDADBType.String, 512, entity.m_OsszetettCim, entity.m_OsszetettCim == null); } if (entity.HasChanged("Alapertelmezett")) { sb.Append("C_ALAPERTELMEZETT = :pALAPERTELMEZETT,"); DAUtil.BindParameter(command, "pALAPERTELMEZETT", SDA.DataProvider.SDADBType.Boolean /* Boolean */, 1, entity.m_Alapertelmezett, false); } if (entity.HasChanged("KozteruletJellegeNev")) { sb.Append("C_KOZTERULETJELLEGENEV = :pKOZTERULETJELLEGENEV,"); DAUtil.BindParameter(command, "pKOZTERULETJELLEGENEV", SDA.DataProvider.SDADBType.String, 50, entity.m_KozteruletJellegeNev, entity.m_KozteruletJellegeNev == null); } command.CommandText = command.CommandText.Replace("{COLUMNS}", sb.ToString()); } public override void BindAssociations(Cim entity, SDA.DataProvider.SDACommand command) { DAUtil.BindIdParameter(command, "pFELHASZNALOID", entity.InternalFelhasznaloId); DAUtil.BindIdParameter(command, "pGONDVISELOID", entity.InternalGondviseloId); DAUtil.BindIdParameter(command, "pINTEZMENYID", entity.InternalIntezmenyId); DAUtil.BindIdParameter(command, "pTANEVID", entity.InternalTanevId); } #endregion } internal class CimDA : EntityDataAccessor { private static CimDBHelper m_dbhelper = new CimDBHelper(); protected override IEntityDBHelper dbhelper { get { return m_dbhelper; } } #region Load public override bool LoadEntity(Cim entity, int entityId) { return LoadById(entity, entityId); } public override bool FilteredLoadEntity(Cim entity, int entityId, ColumnFilterMode columnFilterMode, IEnumerable columns) { return LoadById(entity, entityId, columnFilterMode, columns); } public bool LoadById(Cim entity, int entityId) { using (SDA.DataProvider.SDACommand command = dbhelper.CreateEmptyQueryCommand()) { command.CommandText += " and (T_CIM_OSSZES.ID = :pID) "; command.Parameters.Add("pID", SDA.DataProvider.SDADBType.Int).Value = entityId; return dbhelper.LoadSingleEntity(entity, command); } } public bool LoadById(Cim entity, int entityId, ColumnFilterMode columnFilterMode, IEnumerable columns) { using (SDA.DataProvider.SDACommand command = dbhelper.CreateDynamicQueryCommand(columnFilterMode, columns)) { command.CommandText += " and (T_CIM_OSSZES.ID = :pID) "; command.Parameters.Add("pID", SDA.DataProvider.SDADBType.Int).Value = entityId; return dbhelper.LoadSingleEntity(entity, command, columnFilterMode, columns); } } [Obsolete("Ezt ne használjátok, mert mindenhova bele kellene fogalmazni a tanév szűrést is! Meg fog majd szűnni!")] public override void LoadWithFilter(IEntityCollection collection, string filter, Dictionary commandParameters = null) { using (SDA.DataProvider.SDACommand command = dbhelper.CreateEmptyQueryCommand()) { command.CommandText += filter; dbhelper.CreateParameterBinding(command, commandParameters); dbhelper.LoadEntityCollection(collection, command); } } [Obsolete("Ezt ne használjátok, mert mindenhova bele kellene fogalmazni a tanév szűrést is! Meg fog majd szűnni!")] public override void LoadWithFilter(IEntityCollection collection, string filter, ColumnFilterMode columnFilterMode, IEnumerable columns, Dictionary commandParameters = null) { using (SDA.DataProvider.SDACommand command = dbhelper.CreateDynamicQueryCommand(columnFilterMode, columns)) { command.CommandText += filter; dbhelper.CreateParameterBinding(command, commandParameters); dbhelper.LoadEntityCollection(collection, command, columnFilterMode, columns); } } #endregion #region InsertEntity private const string m_InsertCommandText = @" insert into T_CIM_OSSZES ( C_CIMTIPUSA, C_ORSZAG, C_IRANYITOSZAM, C_VAROS, C_MEGYE, C_KOZTERULET, C_HAZSZAM, C_EPULET, C_LEPCSOHAZ, C_EMELET, C_AJTO, C_OSSZETETTCIM, C_ALAPERTELMEZETT, C_KOZTERULETJELLEGENEV, C_FELHASZNALOID, C_GONDVISELOID, C_INTEZMENYID, C_TANEVID, TOROLT, SERIAL, CREATED, CREATOR) values ( :pCIMTIPUSA, :pORSZAG, :pIRANYITOSZAM, :pVAROS, :pMEGYE, :pKOZTERULET, :pHAZSZAM, :pEPULET, :pLEPCSOHAZ, :pEMELET, :pAJTO, :pOSSZETETTCIM, :pALAPERTELMEZETT, :pKOZTERULETJELLEGENEV, :pFELHASZNALOID, :pGONDVISELOID, :pINTEZMENYID, :pTANEVID, :pTOROLT, :pSERIAL, :pCREATED, :pCREATOR); SELECT SCOPE_IDENTITY() as ID; "; public override void InsertEntity(Cim entity) { entity.Serial = 0; SetEntityCreator(entity, DateTime.Now, UserContext.Instance.UniqueIdentifier); using (SDA.DataProvider.SDACommand command = DAUtil.CreateCommand(m_InsertCommandText)) { dbhelper.BindAttributes(entity, command); dbhelper.BindAssociations(entity, command); command.Parameters.Add("pTOROLT", SDA.DataProvider.SDADBType.Boolean /* Boolean */).Value = false; command.Parameters.Add("pSERIAL", SDA.DataProvider.SDADBType.Int).Value = 0; command.Parameters.Add("pCREATED", SDA.DataProvider.SDADBType.DateTime).Value = entity.EntityCreated; command.Parameters.Add("pCREATOR", SDA.DataProvider.SDADBType.Int).Value = entity.EntityCreator; entity.ID = Convert.ToInt32(command.ExecuteScalar()); } } #endregion #region UpdateEntity private const string m_UpdateAttributesCommandText = @" update T_CIM_OSSZES set {COLUMNS} SERIAL = ISNULL(SERIAL,0) + 1, LASTCHANGED = :pLASTCHANGED, MODIFIER = :pMODIFIER, TOROLT = :pTOROLT where (ID = :pID) and (ISNULL(SERIAL,0) = :pSERIAL) "; public override bool UpdateEntity(Cim entity) { using (SDA.DataProvider.SDACommand command = DAUtil.CreateCommand(m_UpdateAttributesCommandText)) { bool result = true; dbhelper.DynamicBindAttributes(entity, command); SetEntityModifier(entity, DateTime.Now, UserContext.Instance.UniqueIdentifier); command.Parameters.Add("pID", SDA.DataProvider.SDADBType.Int).Value = entity.ID; command.Parameters.Add("pSERIAL", SDA.DataProvider.SDADBType.Int).Value = entity.Serial; command.Parameters.Add("pLASTCHANGED", SDA.DataProvider.SDADBType.DateTime).Value = entity.EntityLastChanged; command.Parameters.Add("pMODIFIER", SDA.DataProvider.SDADBType.Int).Value = entity.EntityModifier; command.Parameters.Add("pTOROLT", SDA.DataProvider.SDADBType.Boolean /* Boolean */).Value = entity.Torolt; result = (command.ExecuteNonQuery() == 1); if (result == true) entity.Serial++; return result; } } #endregion #region DeleteEntity private const string m_FizikaiDeleteCommandText = @"DELETE FROM T_CIM_OSSZES WHERE (ID = :pID) "; private const string m_LogikaiDeleteCommandText = @" UPDATE T_CIM_OSSZES SET TOROLT = 'T' , SERIAL = SERIAL + 1, LASTCHANGED = :pLASTCHANGED, MODIFIER = :pMODIFIER WHERE (ID = :pID) "; public override void DeleteEntity(Cim entity, bool logikai = true) { var _deleteCommandText = logikai ? m_LogikaiDeleteCommandText : m_FizikaiDeleteCommandText; using (SDA.DataProvider.SDACommand command = DAUtil.CreateCommand(_deleteCommandText)) { command.Parameters.Add("pID", SDA.DataProvider.SDADBType.Int).Value = entity.ID; if (logikai) { DateTime lastchanged = DateTime.Now; var modifier = UserContext.Instance.UniqueIdentifier; command.Parameters.Add("pLASTCHANGED", SDA.DataProvider.SDADBType.DateTime).Value = lastchanged; command.Parameters.Add("pMODIFIER", SDA.DataProvider.SDADBType.Int).Value = modifier; } if (command.ExecuteNonQuery() != 1) { throw new EntityNotFoundException("Cim", entity.ID); } } } #endregion #region UpdateAssociations private const string m_UpdateAssociationCommandText = @" update T_CIM_OSSZES set C_FELHASZNALOID = :pFELHASZNALOID, C_GONDVISELOID = :pGONDVISELOID, C_INTEZMENYID = :pINTEZMENYID, C_TANEVID = :pTANEVID, SERIAL = ISNULL(SERIAL,0) + 1, LASTCHANGED = :pLASTCHANGED, MODIFIER = :pMODIFIER where (ID = :pID) and (ISNULL(SERIAL,0) = :pSERIAL) "; public override bool UpdateAssociations(Cim entity) { using (SDA.DataProvider.SDACommand command = DAUtil.CreateCommand(m_UpdateAssociationCommandText)) { dbhelper.BindAssociations(entity, command); DateTime lastchanged = DateTime.Now; var modifier = UserContext.Instance.UniqueIdentifier; command.Parameters.Add("pID", SDA.DataProvider.SDADBType.Int).Value = entity.ID; command.Parameters.Add("pSERIAL", SDA.DataProvider.SDADBType.Int).Value = entity.Serial; command.Parameters.Add("pLASTCHANGED", SDA.DataProvider.SDADBType.DateTime).Value = lastchanged; command.Parameters.Add("pMODIFIER", SDA.DataProvider.SDADBType.Int).Value = modifier; bool result = (command.ExecuteNonQuery() == 1); if (result == true) { entity.Serial++; SetEntityModifier(entity, lastchanged, modifier); } return result; } } #endregion #region Asszociációkkal kapcsolatos adatbázisműveletek (entitásspecifikus) #region Mint asszociációs osztály #endregion #endregion } /// /// Az osztály elvégzi az UML modell 'Felhasznalo -> Cim (Cim)' /// asszociációjának teljes kezelését. /// internal class Felhasznalo_Cim_DA : EntityCollectionDA { internal protected Felhasznalo_Cim_DA(Felhasznalo owner) : base(owner) { } // Nincs kapcsolótábla private const string m_Filter = @" and (T_CIM_OSSZES.C_FELHASZNALOID = :pID) "; public override void LoadCollection(IAssociatedEntityCollection collection) { new CimDBHelper().LoadByPartnerId(collection, m_Filter, Owner.ID); } private static SDA.DataProvider.SDACommand CreateInsertCimCommand() { SDA.DataProvider.SDACommand result = new SDA.DataProvider.SDACommand(); // nincs kapcsolótábla... result.CommandText = @"update T_CIM_OSSZES set C_FELHASZNALOID = :pFELHASZNALOID where (ID = :pCIMID)"; result.Parameters.Add("pFELHASZNALOID", SDA.DataProvider.SDADBType.Int); result.Parameters.Add("pCIMID", SDA.DataProvider.SDADBType.Int); return result; } private void DoAdd(Felhasznalo owner, Cim partner) { using (SDA.DataProvider.SDACommand command = CreateInsertCimCommand()) { command.Connection = UserContext.Instance.SDAConnection; command.Transaction = UserContext.Instance.SDATransaction; command.Parameters["pFELHASZNALOID"].Value = owner.ID; command.Parameters["pCIMID"].Value = partner.ID; command.ExecuteNonQuery(); } } public override void AddItem(Cim entity) { var assochandler = AssociationHandlerManager.Create("Cim_Felhasznalo"); assochandler.BeforeInsert(entity, this.Owner); entity.ModifyFelhasznalo(this.Owner); if (entity.State == EntityState.Modified) { entity.UpdateAssociations(true); } else { entity.Insert(true); } assochandler.AfterInsert(entity, this.Owner); } private static SDA.DataProvider.SDACommand CreateDeleteCimCommand() { SDA.DataProvider.SDACommand result = new SDA.DataProvider.SDACommand(); // nincs kapcsolótábla... result.CommandText = @"update T_CIM_OSSZES set C_FELHASZNALOID = null where (C_FELHASZNALOID = :pFELHASZNALOID and ID = :pCIMID)"; result.Parameters.Add("pFELHASZNALOID", SDA.DataProvider.SDADBType.Int); result.Parameters.Add("pCIMID", SDA.DataProvider.SDADBType.Int); return result; } private void DoRemove(Felhasznalo owner, Cim partner) { using (SDA.DataProvider.SDACommand command = CreateDeleteCimCommand()) { command.Connection = UserContext.Instance.SDAConnection; command.Transaction = UserContext.Instance.SDATransaction; command.Parameters["pFELHASZNALOID"].Value = owner.ID; command.Parameters["pCIMID"].Value = partner.ID; command.ExecuteNonQuery(); } } public override void DeleteItem(Cim entity) { var assochandler = AssociationHandlerManager.Create("Cim_Felhasznalo"); assochandler.BeforeDelete(entity, this.Owner); entity.Delete(true); assochandler.AfterDelete(entity, this.Owner); } } /// /// Az osztály elvégzi az UML modell 'Gondviselo -> Cim (Cim)' /// asszociációjának teljes kezelését. /// internal class Gondviselo_Cim_DA : EntityCollectionDA { internal protected Gondviselo_Cim_DA(Gondviselo owner) : base(owner) { } // Nincs kapcsolótábla private const string m_Filter = @" and (T_CIM_OSSZES.C_GONDVISELOID = :pID) "; public override void LoadCollection(IAssociatedEntityCollection collection) { new CimDBHelper().LoadByPartnerId(collection, m_Filter, Owner.ID); } private static SDA.DataProvider.SDACommand CreateInsertCimCommand() { SDA.DataProvider.SDACommand result = new SDA.DataProvider.SDACommand(); // nincs kapcsolótábla... result.CommandText = @"update T_CIM_OSSZES set C_GONDVISELOID = :pGONDVISELOID where (ID = :pCIMID)"; result.Parameters.Add("pGONDVISELOID", SDA.DataProvider.SDADBType.Int); result.Parameters.Add("pCIMID", SDA.DataProvider.SDADBType.Int); return result; } private void DoAdd(Gondviselo owner, Cim partner) { using (SDA.DataProvider.SDACommand command = CreateInsertCimCommand()) { command.Connection = UserContext.Instance.SDAConnection; command.Transaction = UserContext.Instance.SDATransaction; command.Parameters["pGONDVISELOID"].Value = owner.ID; command.Parameters["pCIMID"].Value = partner.ID; command.ExecuteNonQuery(); } } public override void AddItem(Cim entity) { var assochandler = AssociationHandlerManager.Create("Gondviselo_Cim"); assochandler.BeforeInsert(this.Owner, entity); this.DoAdd(this.Owner, entity); assochandler.AfterInsert(this.Owner, entity); } private static SDA.DataProvider.SDACommand CreateDeleteCimCommand() { SDA.DataProvider.SDACommand result = new SDA.DataProvider.SDACommand(); // nincs kapcsolótábla... result.CommandText = @"update T_CIM_OSSZES set C_GONDVISELOID = null where (C_GONDVISELOID = :pGONDVISELOID and ID = :pCIMID)"; result.Parameters.Add("pGONDVISELOID", SDA.DataProvider.SDADBType.Int); result.Parameters.Add("pCIMID", SDA.DataProvider.SDADBType.Int); return result; } private void DoRemove(Gondviselo owner, Cim partner) { using (SDA.DataProvider.SDACommand command = CreateDeleteCimCommand()) { command.Connection = UserContext.Instance.SDAConnection; command.Transaction = UserContext.Instance.SDATransaction; command.Parameters["pGONDVISELOID"].Value = owner.ID; command.Parameters["pCIMID"].Value = partner.ID; command.ExecuteNonQuery(); } } public override void DeleteItem(Cim entity) { var assochandler = AssociationHandlerManager.Create("Gondviselo_Cim"); assochandler.BeforeDelete(this.Owner, entity); this.DoRemove(this.Owner, entity); assochandler.AfterDelete(this.Owner, entity); } } /// /// Az osztály elvégzi az UML modell 'Intezmeny -> Cim (Cim)' /// asszociációjának teljes kezelését. /// internal class Intezmeny_Cim_DA : EntityCollectionDA { internal protected Intezmeny_Cim_DA(Intezmeny owner) : base(owner) { } // Nincs kapcsolótábla private const string m_Filter = @" and (T_CIM_OSSZES.C_INTEZMENYID = :pID) "; public override void LoadCollection(IAssociatedEntityCollection collection) { new CimDBHelper().LoadByPartnerId(collection, m_Filter, Owner.ID); } private static SDA.DataProvider.SDACommand CreateInsertCimCommand() { SDA.DataProvider.SDACommand result = new SDA.DataProvider.SDACommand(); // nincs kapcsolótábla... result.CommandText = @"update T_CIM_OSSZES set C_INTEZMENYID = :pINTEZMENYID where (ID = :pCIMID)"; result.Parameters.Add("pINTEZMENYID", SDA.DataProvider.SDADBType.Int); result.Parameters.Add("pCIMID", SDA.DataProvider.SDADBType.Int); return result; } private void DoAdd(Intezmeny owner, Cim partner) { using (SDA.DataProvider.SDACommand command = CreateInsertCimCommand()) { command.Connection = UserContext.Instance.SDAConnection; command.Transaction = UserContext.Instance.SDATransaction; command.Parameters["pINTEZMENYID"].Value = owner.ID; command.Parameters["pCIMID"].Value = partner.ID; command.ExecuteNonQuery(); } } public override void AddItem(Cim entity) { var assochandler = AssociationHandlerManager.Create("Cim_Intezmeny"); assochandler.BeforeInsert(entity, this.Owner); entity.ModifyIntezmeny(this.Owner); if (entity.State == EntityState.Modified) { entity.UpdateAssociations(true); } else { entity.Insert(true); } assochandler.AfterInsert(entity, this.Owner); } private static SDA.DataProvider.SDACommand CreateDeleteCimCommand() { SDA.DataProvider.SDACommand result = new SDA.DataProvider.SDACommand(); // nincs kapcsolótábla... result.CommandText = @"update T_CIM_OSSZES set C_INTEZMENYID = null where (C_INTEZMENYID = :pINTEZMENYID and ID = :pCIMID)"; result.Parameters.Add("pINTEZMENYID", SDA.DataProvider.SDADBType.Int); result.Parameters.Add("pCIMID", SDA.DataProvider.SDADBType.Int); return result; } private void DoRemove(Intezmeny owner, Cim partner) { using (SDA.DataProvider.SDACommand command = CreateDeleteCimCommand()) { command.Connection = UserContext.Instance.SDAConnection; command.Transaction = UserContext.Instance.SDATransaction; command.Parameters["pINTEZMENYID"].Value = owner.ID; command.Parameters["pCIMID"].Value = partner.ID; command.ExecuteNonQuery(); } } public override void DeleteItem(Cim entity) { var assochandler = AssociationHandlerManager.Create("Cim_Intezmeny"); assochandler.BeforeDelete(entity, this.Owner); entity.Delete(true); assochandler.AfterDelete(entity, this.Owner); } } /// /// Az osztály elvégzi az UML modell 'Tanev -> Cim (Cim)' /// asszociációjának teljes kezelését. /// internal class Tanev_Cim_DA : EntityCollectionDA { internal protected Tanev_Cim_DA(Tanev owner) : base(owner) { } // Nincs kapcsolótábla private const string m_Filter = @" and (T_CIM_OSSZES.C_TANEVID = :pID) "; public override void LoadCollection(IAssociatedEntityCollection collection) { new CimDBHelper().LoadByPartnerId(collection, m_Filter, Owner.ID); } private static SDA.DataProvider.SDACommand CreateInsertCimCommand() { SDA.DataProvider.SDACommand result = new SDA.DataProvider.SDACommand(); // nincs kapcsolótábla... result.CommandText = @"update T_CIM_OSSZES set C_TANEVID = :pTANEVID where (ID = :pCIMID)"; result.Parameters.Add("pTANEVID", SDA.DataProvider.SDADBType.Int); result.Parameters.Add("pCIMID", SDA.DataProvider.SDADBType.Int); return result; } private void DoAdd(Tanev owner, Cim partner) { using (SDA.DataProvider.SDACommand command = CreateInsertCimCommand()) { command.Connection = UserContext.Instance.SDAConnection; command.Transaction = UserContext.Instance.SDATransaction; command.Parameters["pTANEVID"].Value = owner.ID; command.Parameters["pCIMID"].Value = partner.ID; command.ExecuteNonQuery(); } } public override void AddItem(Cim entity) { var assochandler = AssociationHandlerManager.Create("Cim_Tanev"); assochandler.BeforeInsert(entity, this.Owner); entity.ModifyTanev(this.Owner); if (entity.State == EntityState.Modified) { entity.UpdateAssociations(true); } else { entity.Insert(true); } assochandler.AfterInsert(entity, this.Owner); } private static SDA.DataProvider.SDACommand CreateDeleteCimCommand() { SDA.DataProvider.SDACommand result = new SDA.DataProvider.SDACommand(); // nincs kapcsolótábla... result.CommandText = @"update T_CIM_OSSZES set C_TANEVID = null where (C_TANEVID = :pTANEVID and ID = :pCIMID)"; result.Parameters.Add("pTANEVID", SDA.DataProvider.SDADBType.Int); result.Parameters.Add("pCIMID", SDA.DataProvider.SDADBType.Int); return result; } private void DoRemove(Tanev owner, Cim partner) { using (SDA.DataProvider.SDACommand command = CreateDeleteCimCommand()) { command.Connection = UserContext.Instance.SDAConnection; command.Transaction = UserContext.Instance.SDATransaction; command.Parameters["pTANEVID"].Value = owner.ID; command.Parameters["pCIMID"].Value = partner.ID; command.ExecuteNonQuery(); } } public override void DeleteItem(Cim entity) { var assochandler = AssociationHandlerManager.Create("Cim_Tanev"); assochandler.BeforeDelete(entity, this.Owner); entity.Delete(true); assochandler.AfterDelete(entity, this.Owner); } } }