This is a migrated thread and some comments may be shown as answers.

Updates not working

1 Answer 78 Views

Development (API, general questions)

This is a migrated thread and some comments may be shown as answers.

This question is locked. New answers and comments are not allowed.

Dave asked on 30 Jun 2016, 01:55 PM

I have the following code. The inserts work, the updates do not. Please advise. ( I have the project with all source code zipped up and ready to send you, but that doesn't seem possible in this forum.)

static void Main(string[] args)

{

using (FluentModel dbContext = new FluentModel ())

{

// Inserts do work

_Interface _iNew = new _Interface(dbContext);

_iNew.Caption = "Dave New";

_iNew.Save();

}

using (FluentModel dbContext = new FluentModel())

{

// Updates don't work!!!

_Interface _iUpdate = new _Interface(dbContext, 1060);

_iUpdate.Caption = "Dave Update";

_iUpdate.Save();

}

Here are the supporting classes:

_Interface.cs

using System;

using System.Collections.Generic;

using System.Linq;

using System.Reflection;

using System.Text;

using System.Threading.Tasks;

using SWMonitorDAL;

using Telerik.OpenAccess;

namespace SWMonitorBLL

{

public class _Interface : _MonitorBase

{

public int ID{get;set;}

public int SWInterfaceID{get;set;}

public int SWNodeID{get;set;}

public string Name{get;set;}

public string TypeName{get;set;}

public string TypeDescription{get;set;}

public double Speed{get;set;}

public DateTime? LastChange{get;set;}

public string PhysicalAddress{get;set;}

public int AdminStatus{get;set;}

public int OperStatus{get;set;}

public long BandwidthIn{get;set;}

public long BandwidthOut { get; set; }

public string Caption{get;set;}

public string FullName{get;set;}

public Single BPSOut{get;set;}

public Single BPSIn{get;set;}

public Single PercentUtilOut{get;set;}

public Single PercentUtilIn{get;set;}

public Single PPSOut{get;set;}

public Single PPSIn{get;set;}

public int PacketSizeOut{get;set;}

public int PacketSizeIn{get;set;}

public Single UcastPPSOut{get;set;}

public Single UcastPPSIn{get;set;}

public Single McastPPSOut{get;set;}

public Single McastPPSIn{get;set;}

public Single DiscardsThisHourOut{get;set;}

public Single DiscardsThisHourIn{get;set;}

public Single DiscardsTodayOut{get;set;}

public Single DiscardsTodayIn{get;set;}

public Single ErrorsThisHourOut{get;set;}

public Single ErrorsThisHourIn{get;set;}

public Single ErrorsTodayOut{get;set;}

public Single ErrorsTodayIn{get;set;}

public Single MaxInBPSToday{get;set;}

public Single MaxOutBPSToday{get;set;}

public DateTime? MaxInBPSTime{get;set;}

public DateTime? MaxOutBPSTime{get;set;}

public DateTime? LastSync{get;set;}

public string Alias{get;set;}

public string MAC{get;set;}

public TimePeriod ValidFor { get; set; }

private SolarWindsInterface InterfaceDAO;

public _Interface(FluentModel dbC) {

dbContext = dbC;

}

public _Interface(FluentModel dbC, int interfaceId, int swIntId = 0)

{

dbContext = dbC;

fill(interfaceId, swIntId);

}

public _Interface(FluentModel dbC,_Interface _oldInt)

{

dbContext = dbC;

CopyFrom(_oldInt);

}

public void fill(int interfaceId, int swIntId = 0)

{

SolarWindsInterface intf = null;

if (swIntId != 0)

{

this.SWInterfaceID = swIntId;

intf = (from swInt in dbContext.Scope.Extent<SolarWindsInterface>()

where swInt.SWInterfaceID == swIntId

&& (swInt.ValidFor.StartDateTime <= DateTime.Now && swInt.ValidFor.EndDateTime >= DateTime.Now)

select swInt).FirstOrDefault<SolarWindsInterface>();

}

else

{

this.ID = interfaceId;

intf = (from intfc in dbContext.Scope.Extent<SolarWindsInterface>()

where intfc.ID == interfaceId

select intfc).FirstOrDefault<SolarWindsInterface>();

}

if (intf == null)

{

this.Error = "Interface not found";

return;

}

InterfaceDAO = intf;

this.AdminStatus = intf.AdminStatus;

this.Alias = intf.Alias;

this.BandwidthIn = intf.BandwidthIn;

this.BandwidthOut = intf.BandwidthOut;

this.BPSIn = intf.BPSIn;

this.BPSOut = intf.BPSOut;

this.Caption = intf.Caption;

this.DiscardsThisHourIn = intf.DiscardsThisHourIn;

this.DiscardsThisHourOut = intf.DiscardsThisHourOut;

this.DiscardsTodayIn = intf.DiscardsTodayIn;

this.DiscardsTodayOut = intf.DiscardsTodayOut;

this.ErrorsThisHourIn = intf.ErrorsThisHourIn;

this.ErrorsThisHourOut = intf.ErrorsThisHourOut;

this.ErrorsTodayIn = intf.ErrorsTodayIn;

this.ErrorsTodayOut = intf.ErrorsTodayOut;

this.FullName = intf.FullName;

this.ID = intf.ID;

this.LastChange = intf.LastChange;

this.LastSync = intf.LastSync;

this.MAC = intf.MAC;

this.MaxInBPSTime = intf.MaxInBPSTime;

this.MaxInBPSToday = intf.MaxInBPSToday;

this.MaxOutBPSTime = intf.MaxOutBPSTime;

this.MaxOutBPSToday = intf.MaxOutBPSToday;

this.McastPPSIn = intf.McastPPSIn;

this.McastPPSOut = intf.McastPPSOut;

this.Name = intf.Name;

this.OperStatus = intf.OperStatus;

this.PacketSizeIn = intf.PacketSizeIn;

this.PacketSizeOut = intf.PacketSizeOut;

this.PercentUtilIn = intf.PercentUtilIn;

this.PercentUtilOut = intf.PercentUtilOut;

this.PhysicalAddress = intf.PhysicalAddress;

this.PPSIn = intf.PPSIn;

this.PPSOut = intf.PPSOut;

this.Speed = intf.Speed;

this.SWInterfaceID = intf.SWInterfaceID;

this.SWNodeID = intf.SWNodeID;

this.TypeDescription = intf.TypeDescription;

this.TypeName = intf.TypeName;

this.UcastPPSIn = intf.UcastPPSIn;

this.UcastPPSOut = intf.UcastPPSOut;

this.ValidFor = intf.ValidFor;

}

public int Save()

{

//Scope.Transaction.Begin();

try

{

SolarWindsInterface intf = transform();

if (intf.ID == 0)

{

dbContext.Add(intf);

dbContext.FlushChanges();

ID = intf.ID;

}

dbContext.SaveChanges();

}

catch (Exception ex)

{

dbContext.ClearChanges();

}

return ID;

}

public SolarWindsInterface transform()

{

SolarWindsInterface intf;

if (InterfaceDAO != null)

intf = InterfaceDAO;

else

intf = new SolarWindsInterface();

intf.AdminStatus = AdminStatus;

intf.Alias = Alias;

intf.BandwidthIn = BandwidthIn;

intf.BandwidthOut = BandwidthOut;

intf.BPSIn = BPSIn;

intf.BPSOut = BPSOut;

intf.Caption = Caption;

intf.DiscardsThisHourIn = DiscardsThisHourIn;

intf.DiscardsThisHourOut = DiscardsThisHourOut;

intf.DiscardsTodayIn = DiscardsTodayIn;

intf.DiscardsTodayOut = DiscardsTodayOut;

intf.ErrorsThisHourIn = ErrorsThisHourIn;

intf.ErrorsThisHourOut = ErrorsThisHourOut;

intf.ErrorsTodayIn = ErrorsTodayIn;

intf.ErrorsTodayOut = ErrorsTodayOut;

intf.FullName = FullName;

intf.ID = ID;

intf.LastChange = LastChange;

intf.LastSync = LastSync;

intf.MAC = MAC;

intf.MaxInBPSTime = MaxInBPSTime;

intf.MaxInBPSToday = MaxInBPSToday;

intf.MaxOutBPSTime = MaxOutBPSTime;

intf.MaxOutBPSToday = MaxOutBPSToday;

intf.McastPPSIn = McastPPSIn;

intf.McastPPSOut = McastPPSOut;

intf.Name = Name;

intf.OperStatus = OperStatus;

intf.PacketSizeIn = PacketSizeIn;

intf.PacketSizeOut = PacketSizeOut;

intf.PercentUtilIn = PercentUtilIn;

intf.PercentUtilOut = PercentUtilOut;

intf.PhysicalAddress = PhysicalAddress;

intf.PPSIn = PPSIn;

intf.PPSOut = PPSOut;

intf.Speed = Speed;

intf.SWInterfaceID = SWInterfaceID;

intf.SWNodeID = SWNodeID;

intf.TypeDescription = TypeDescription;

intf.TypeName = TypeName;

intf.UcastPPSIn = UcastPPSIn;

intf.UcastPPSOut = UcastPPSOut;

if (ID == 0)

intf.ValidFor = new TimePeriod();

else

intf.ValidFor = ValidFor;

return intf;

}

public List<_Interface> GetInterfacesBySWNodeID(int swNodeID)

{

List<_Interface> _ints = new List<_Interface>();

var interfaceIDs = (from i in dbContext.Scope.Extent<SolarWindsInterface>()

where i.SWNodeID == swNodeID

&& (i.ValidFor.StartDateTime <= DateTime.Now && i.ValidFor.EndDateTime >= DateTime.Now)

select i.ID).ToList<int>();

foreach (int interfaceID in interfaceIDs)

{

_Interface _intf = new _Interface(dbContext,interfaceID);

_ints.Add(_intf);

}

return _ints;

}

public bool isChanged(_Interface _importCandiateInt)

{

PropertyInfo[] properties = typeof(_Interface).GetProperties();

foreach (PropertyInfo property in properties)

{

var currentValue = property.GetValue(_importCandiateInt);

var existingValue = property.GetValue(this);

if (property.Name != "ID" && property.Name != "ValidFor" && property.Name != "Error")

{

if ((currentValue == null && existingValue != null) || (existingValue == null && currentValue != null))

{

return true;

}

if (property.PropertyType == typeof(int))

{

if (Convert.ToInt32(currentValue) != Convert.ToInt32(existingValue))

return true;

}

else if (property.PropertyType == typeof(string))

{

if (currentValue.ToString() != existingValue.ToString())

return true;

}

else if (property.PropertyType == typeof(DateTime))

{

if (Convert.ToDateTime(currentValue) != Convert.ToDateTime(existingValue))

return true;

}

return false;

}

public void ExpireInterfaces(int swId)

{

try

{

//Scope.Transaction.Begin();

var intfs = (from swInt in dbContext.Scope.Extent<SolarWindsInterface>()

where swInt.SWInterfaceID == swId

&& (swInt.ValidFor.StartDateTime <= DateTime.Now && swInt.ValidFor.EndDateTime >= DateTime.Now)

select swInt).ToList<SolarWindsInterface>();

foreach (SolarWindsInterface swInt in intfs)

{

swInt.ValidFor.EndDateTime = DateTime.Now;

}

dbContext.SaveChanges();

}

catch (Exception ex)

{

dbContext .ClearChanges();

}

private void CopyFrom(_Interface _importCandiateInt)

{

PropertyInfo[] properties = typeof(_Interface).GetProperties();

foreach (PropertyInfo property in properties)

{

var importedValue = property.GetValue(_importCandiateInt);

if (property.Name != "ID")

property.SetValue(this, importedValue);

else

property.SetValue(this, 0);

}

public _Interface GetActiveIntfBySWIntfID(int swId)

{

var intfID = (from i in dbContext.Scope.Extent<SolarWindsInterface>()

where i.SWInterfaceID == swId

&& (i.ValidFor.StartDateTime <= DateTime.Now && i.ValidFor.EndDateTime >= DateTime.Now)

select i.ID).FirstOrDefault<int>();

return new _Interface(dbContext,intfID);

}

_MonitorBase.cs:

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Telerik.OpenAccess;

namespace SWMonitorBLL

{

public abstract class _MonitorBase

{

public string Error { get; set; }

protected FluentModel dbContext;

}

Please advise ASAP. Fyi, all projects are enhanced. It would be much easier if I could send you the project and database and you could run it and see for yourself. Without that, I really don't see how we're going to isolate this problem without going back and forth a million times and still getting nowhere.

Thanks,

Dave

1 Answer, 1 is accepted

answered on 30 Jun 2016, 02:28 PM

And here are my FluentModel.cs and FluentModelMetadataSource.cs files:

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Telerik.OpenAccess;

using Telerik.OpenAccess.Metadata;

using Telerik.OpenAccess.Metadata.Fluent;

using Telerik.OpenAccess.Metadata.Fluent.Advanced;

public partial class FluentModel : OpenAccessContext

{

static MetadataSource metadataSource = new FluentModelMetadataSource();

static BackendConfiguration backend = GetBackendConfiguration();

private const string connectionStringName = "SWMonitorConnection";

public FluentModel() : base(connectionStringName, backend, metadataSource)

{

BackendConfiguration.ConnectionPoolConfiguration connectionPoolConfig = backend.ConnectionPool;

}

public static BackendConfiguration GetBackendConfiguration()

{

BackendConfiguration backend = new BackendConfiguration();

backend.Backend = "MsSql";

backend.ProviderName = "System.Data.SqlClient";

backend.HighLowKeyGenerator.KeyColumnName = "table_name";

backend.HighLowKeyGenerator.ValueColumnName = "last_used_id";

return backend;

}

public void UpdateSchema()

{

ISchemaHandler handler = this.GetSchemaHandler();

String script = null;

try{

script = handler.CreateUpdateDDLScript(null);

}

catch(Exception ex){

Boolean throwException = false;

try{

handler.CreateDatabase();

script = handler.CreateDDLScript();

}

catch{

throwException = true;

}

if (throwException){

throw;

}

if (!String.IsNullOrEmpty(script)){

handler.ExecuteDDLScript(script);

}

public IObjectScope Scope

{

get

{

return base.GetScope();

}

using System.Collections.Generic;

using Telerik.OpenAccess.Metadata.Fluent;

using Telerik.OpenAccess.Metadata.Fluent.Advanced;

using Telerik.OpenAccess.Metadata;

using Telerik.OpenAccess;

using SWMonitorDAL;

public partial class FluentModelMetadataSource : FluentMetadataSource

{

protected override MetadataContainer CreateModel()

{

MetadataContainer _metadataContainer = base.CreateModel();

MetaNameGenerator _metaNameGenerator = _metadataContainer.NameGenerator;

_metaNameGenerator.RemoveCamelCase = false;

_metaNameGenerator.ResolveReservedWords = false;

_metaNameGenerator.SourceStrategy = NamingSourceStrategy.Field;

return _metadataContainer;

}

protected override System.Collections.Generic.IList<MappingConfiguration> PrepareMapping()

{

List<MappingConfiguration> configurations = new List<MappingConfiguration>();

///''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''

MappingConfiguration<ConfigSettings> configsettingsConfig = new MappingConfiguration<ConfigSettings>();

configsettingsConfig.FieldNamingRules.CaseMode = CaseChangeModes.CamelCase;

configsettingsConfig.MapType().ToTable("ConfigSettings");

configsettingsConfig.HasField("settingName");

configsettingsConfig.HasField("settingValue");

MappingConfiguration<SWError> swerrorConfig = new MappingConfiguration<SWError>();

swerrorConfig.FieldNamingRules.CaseMode = CaseChangeModes.CamelCase;

swerrorConfig.MapType().ToTable("SWError");

swerrorConfig.HasPrimitiveField("ID").IsIdentity(KeyGenerator.HighLow);

swerrorConfig.HasField("SWNodeID");

swerrorConfig.HasField("SWInterfaceID");

swerrorConfig.HasField("DateTime");

swerrorConfig.HasField("Archive");

swerrorConfig.HasField("InErrors");

swerrorConfig.HasField("InDiscards");

swerrorConfig.HasField("OutErrors");

swerrorConfig.HasField("OutDiscards");

swerrorConfig.HasField("ObservationFrequency");

swerrorConfig.HasField("ObservationTimeStamp");

swerrorConfig.HasField("Uri");

MappingConfiguration<Traffic> trafficConfig = new MappingConfiguration<Traffic>();

trafficConfig.FieldNamingRules.CaseMode = CaseChangeModes.CamelCase;

trafficConfig.MapType().ToTable("Traffic");

trafficConfig.HasPrimitiveField("ID").IsIdentity(KeyGenerator.HighLow);

trafficConfig.HasField("SWNodeID");

trafficConfig.HasField("SWInterfaceID");

trafficConfig.HasField("DateTime");

trafficConfig.HasField("Archive");

trafficConfig.HasField("InAveragebps");

trafficConfig.HasField("InMinbps");

trafficConfig.HasField("InMaxbps");

trafficConfig.HasField("InTotalBytes");

trafficConfig.HasField("InTotalPkts");

trafficConfig.HasField("InAvgUniCastPkts");

trafficConfig.HasField("InMinUniCastPkts");

trafficConfig.HasField("InMaxUniCastPkts");

trafficConfig.HasField("InAvgMultiCastPkts");

trafficConfig.HasField("InMinMultiCastPkts");

trafficConfig.HasField("InMaxMultiCastPkts");

trafficConfig.HasField("OutAveragebps");

trafficConfig.HasField("OutMinbps");

trafficConfig.HasField("OutMaxbps");

trafficConfig.HasField("OutTotalBytes");

trafficConfig.HasField("OutTotalPkts");

trafficConfig.HasField("OutAvgUniCastPkts");

trafficConfig.HasField("OutMaxUniCastPkts");

trafficConfig.HasField("OutMinUniCastPkts");

trafficConfig.HasField("OutAvgMultiCastPkts");

trafficConfig.HasField("OutMinMultiCastPkts");

trafficConfig.HasField("OutMaxMultiCastPkts");

MappingConfiguration<SolarWindsInterface> solarwindsinterfaceConfig = new MappingConfiguration<SolarWindsInterface>();

solarwindsinterfaceConfig.FieldNamingRules.CaseMode = CaseChangeModes.CamelCase;

solarwindsinterfaceConfig.MapType().ToTable("SolarWindsInterface");

solarwindsinterfaceConfig.HasPrimitiveField("ID").IsIdentity(KeyGenerator.HighLow);

solarwindsinterfaceConfig.HasField("SWInterfaceID");

solarwindsinterfaceConfig.HasField("SWNodeID");

solarwindsinterfaceConfig.HasField("Name");

solarwindsinterfaceConfig.HasField("TypeName");

solarwindsinterfaceConfig.HasField("TypeDescription");

solarwindsinterfaceConfig.HasField("Speed");

solarwindsinterfaceConfig.HasField("LastChange");

solarwindsinterfaceConfig.HasField("PhysicalAddress");

solarwindsinterfaceConfig.HasField("AdminStatus");

solarwindsinterfaceConfig.HasField("OperStatus");

solarwindsinterfaceConfig.HasField("BandwidthIn");

solarwindsinterfaceConfig.HasField("BandwidthOut");

solarwindsinterfaceConfig.HasField("Caption");

solarwindsinterfaceConfig.HasField("FullName");

solarwindsinterfaceConfig.HasField("BPSOut");

solarwindsinterfaceConfig.HasField("BPSIn");

solarwindsinterfaceConfig.HasField("PercentUtilOut");

solarwindsinterfaceConfig.HasField("PercentUtilIn");

solarwindsinterfaceConfig.HasField("PPSOut");

solarwindsinterfaceConfig.HasField("PPSIn");

solarwindsinterfaceConfig.HasField("PacketSizeOut");

solarwindsinterfaceConfig.HasField("PacketSizeIn");

solarwindsinterfaceConfig.HasField("UcastPPSOut");

solarwindsinterfaceConfig.HasField("UcastPPSIn");

solarwindsinterfaceConfig.HasField("McastPPSOut");

solarwindsinterfaceConfig.HasField("McastPPSIn");

solarwindsinterfaceConfig.HasField("DiscardsThisHourOut");

solarwindsinterfaceConfig.HasField("DiscardsThisHourIn");

solarwindsinterfaceConfig.HasField("DiscardsTodayOut");

solarwindsinterfaceConfig.HasField("DiscardsTodayIn");

solarwindsinterfaceConfig.HasField("ErrorsThisHourOut");

solarwindsinterfaceConfig.HasField("ErrorsThisHourIn");

solarwindsinterfaceConfig.HasField("ErrorsTodayOut");

solarwindsinterfaceConfig.HasField("ErrorsTodayIn");

solarwindsinterfaceConfig.HasField("MaxInBPSToday");

solarwindsinterfaceConfig.HasField("MaxOutBPSToday");

solarwindsinterfaceConfig.HasField("MaxInBPSTime");

solarwindsinterfaceConfig.HasField("MaxOutBPSTime");

solarwindsinterfaceConfig.HasField("LastSync");

solarwindsinterfaceConfig.HasField("Alias");

solarwindsinterfaceConfig.HasField("MAC");

solarwindsinterfaceConfig.HasField("ValidFor").ToColumn("ValidFor");

MappingConfiguration<SolarWindsNode> solarwindsnodeConfig = new MappingConfiguration<SolarWindsNode>();

solarwindsnodeConfig.FieldNamingRules.CaseMode = CaseChangeModes.CamelCase;

solarwindsnodeConfig.MapType().ToTable("SolarWindsNode");

solarwindsnodeConfig.HasPrimitiveField("ID").IsIdentity(KeyGenerator.HighLow);

solarwindsnodeConfig.HasField("SWNodeID");

solarwindsnodeConfig.HasField("SysName");

solarwindsnodeConfig.HasField("Description");

solarwindsnodeConfig.HasField("Caption");

solarwindsnodeConfig.HasField("NodeDescription");

solarwindsnodeConfig.HasField("IPAddress");

solarwindsnodeConfig.HasField("Contact");

solarwindsnodeConfig.HasField("SWLastUpdatedDate");

solarwindsnodeConfig.HasAssociation<SolarWindsInterface>(x => x.Interfaces).ToColumn("__SolarWindsNodeId");

solarwindsnodeConfig.HasField("validFor").ToColumn("validFor");

MappingConfiguration<TimePeriod> timeperiodConfig = new MappingConfiguration<TimePeriod>();

timeperiodConfig.FieldNamingRules.CaseMode = CaseChangeModes.CamelCase;

timeperiodConfig.MapType().ToTable("TimePeriod");

//timeperiodConfig.HasProperty(x => x.isActive);

timeperiodConfig.FieldNamingRules.AddPrefix = "_";

timeperiodConfig.HasField("StartDateTime");

timeperiodConfig.HasField("EndDateTime");

configurations.Add(configsettingsConfig);

configurations.Add(swerrorConfig);

configurations.Add(trafficConfig);

configurations.Add(solarwindsinterfaceConfig);

configurations.Add(solarwindsnodeConfig);

configurations.Add(timeperiodConfig);

///''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''

return configurations;

}