为什么 PropertyDataCollection 对象将多条记录保存到数据库

Question

我有一个实用程序可以读取 MicrosoftBizTalk Server 资源的状态.. 特别是 ReceiveLocation 组件。我的问题是程序正在提交每个项目的多个条目，即返回的数据中的每个项目都乘以 25，这样而不是仅保留 5 行，而是保留的数据是 125。例如，而不是只有 1 行我的第一行返回我有 25.

这是我的程序：

public List<BizTalk> GetBizTalkServicesStatistics()
    {

    
        List<BizTalk> model = new List<BizTalk>();

        try
        {
            //Create the WMI search object.
            ManagementObjectSearcher Searcher = new ManagementObjectSearcher();

            ConnectionOptions options = new ConnectionOptions
            {

                Username = "+username+",
                Password = "+password+",
                Authority = "+domain+"
            };

            
            var server = "+server+";
            // create the scope node so we can set the WMI root node correctly.
            ManagementScope Scope = new ManagementScope("\\" + server + "\root\MicrosoftBizTalkServer", options);
            Searcher.Scope = Scope;

            // Build a Query to enumerate the MSBTS_ReceiveLocation instances if an argument
            // is supplied use it to select only the matching RL.

                //if (args.Length == 0)
                SelectQuery Query = new SelectQuery();               
                Query.QueryString = "SELECT * FROM MSBTS_ReceiveLocation";
                //          else
                //Query.QueryString = "SELECT * FROM MSBTS_ReceiveLocation WHERE Name = '" + args[0] + "'";


            // Set the query for the searcher.
            Searcher.Query = Query;

            // Execute the query and determine if any results were obtained.
            ManagementObjectCollection QueryCol = Searcher.Get();

            // Use a bool to tell if we enter the for loop
            // below because Count property is not supported
            bool ReceiveLocationFound = false;

            // Enumerate all properties.
            foreach (ManagementBaseObject envVar in QueryCol)
            {
                // There is at least one Receive Location
                ReceiveLocationFound = true;

                PropertyDataCollection envVarProperties = envVar.Properties;
               
                foreach (PropertyData envVarProperty in envVarProperties)
                {
                    BizTalk bizTalk = new BizTalk();
                    bizTalk.Name = Convert.ToString(envVar["Name"]);
                    bizTalk.TransportType = Convert.ToString(envVar["AdapterName"]);
                    bizTalk.Uri = Convert.ToString(envVar["InboundTransportURL"]);
                    bizTalk.Status = Convert.ToString(envVar["Name"]);
                    bizTalk.ReceiveHandler = Convert.ToString(envVar["HostName"]);
                    bizTalk.ReceivePort = Convert.ToString(envVar["ReceivePortName"]);
                    bizTalk.RunDate = DateTime.Now;
                    bizTalk.ApplicationId = 24;
                    bizTalk.ServerId = 8;
                    bizTalk.InstanceName = "FBCZOP";                                          
                    model.Add(bizTalk);
                    
                }
            }

            if (!ReceiveLocationFound)
            {
                Console.WriteLine("No receive locations found matching the specified name.");
            }
        }

        catch (Exception excep)
        {
            ExceptionLogger.SendErrorToText(excep);
        }

        return model;
    }

保存功能

public void SaveStatistics(BizTalk entity)
    {
        List<BizTalk> ServerInfo = new List<BizTalk>();
        ServerInfo = GetBizTalkServicesStatistics();
        foreach (var di in ServerInfo)
        {
            entity.RunDate = di.RunDate;
            entity.Name = di.Name;
            entity.Status = di.Status;
            entity.Uri = di.Uri;
            entity.InstanceName = di.InstanceName;
            entity.ReceivePort = di.ReceivePort;
            entity.TransportType= di.TransportType;
            entity.RunDate = DateTime.Now;
            entity.ReceiveHandler = di.ReceiveHandler;                
            entity.ServerId = entity.ServerId;
            entity.ApplicationId = entity.ApplicationId;
            appEntities.BizTalk.Add(entity);
            appEntities.SaveChanges();
        }

    }

当我逐步执行代码变量 envVarProperties 时，在 envVarProperties << ResultsView 下显示记录数为 125： Link 1

而 QueryCol 变量显示计数为 5 :

Link 2

Answer 1

您正在添加同一个实体 25 次并通过引用覆盖其属性。您需要在循环内初始化一个新实体：

foreach (var di in ServerInfo)
        {
            var entity = new BizTalk();
            entity.RunDate = di.RunDate;
            entity.Name = di.Name;
            entity.Status = di.Status;
            entity.Uri = di.Uri;
            entity.InstanceName = di.InstanceName;
            entity.ReceivePort = di.ReceivePort;
            entity.TransportType= di.TransportType;
            entity.RunDate = DateTime.Now;
            entity.ReceiveHandler = di.ReceiveHandler;                
            entity.ServerId = entity.ServerId;
            entity.ApplicationId = entity.ApplicationId;
            appEntities.BizTalk.Add(entity);
            appEn.SaveChanges();
        }
    }

由于您没有显示调用“SaveStatistics”的代码，因此不确定这是否会解决您的全部问题，但至少有一种方法没有达到您的预期。

Answer 2

您似乎在 GetBizTalkServicesStatistics() 方法中重复了额外的时间。

删除以 foreach (PropertyData envVarProperty in envVarProperties). 开头的 foreach 循环这是遍历每个属性对象具有的每个实例（5 个实例）的（所有 25 个属性）... 25 * 5 = 125您正在检索的值。您只想遍历实例并提取所需的属性。这样你最终在你的模型对象中有 5 个对象。

我建议可能是这样的（未经测试，因为我没有 BizTalk）

public List<BizTalk> GetBizTalkServicesStatistics()
        {

            List<BizTalk> model = new List<BizTalk>();

            try
            {
                //Create the WMI search object.
                ConnectionOptions options = new ConnectionOptions
                {
                    Username = "+username+",
                    Password = "+password+",
                    Authority = "+domain+"
                };

                var server = "+server+";

                // create the scope node so we can set the WMI root node correctly.
                ManagementScope Scope = new ManagementScope("\\" + server + "\root\MicrosoftBizTalkServer", options);

                ManagementObjectSearcher Searcher = new ManagementObjectSearcher(Scope, new ObjectQuery("SELECT * FROM MSBTS_ReceiveLocation"));

                // Enumerate all properties.
                foreach (ManagementObject instance in Searcher.Get())
                {
                    {
                        BizTalk bizTalk = new BizTalk();
                        bizTalk.Name = instance.Properties["Name"]?.Value?.ToString();
                        bizTalk.TransportType = instance.Properties["AdapterName"]?.Value?.ToString();
                        bizTalk.Uri = instance.Properties["InboundTransportURL"]?.Value?.ToString();
                        bizTalk.Status = instance.Properties["Name"]?.Value?.ToString();
                        bizTalk.ReceiveHandler = instance.Properties["HostName"]?.Value?.ToString();
                        bizTalk.ReceivePort = instance.Properties["ReceivePortName"]?.Value?.ToString();
                        bizTalk.RunDate = DateTime.Now;
                        bizTalk.ApplicationId = 24;
                        bizTalk.ServerId = 8;
                        bizTalk.InstanceName = "FBCZOP";
                        model.Add(bizTalk);
                    }
                }

                // Determine  
                if (model.Count == 0)
                {
                    Console.WriteLine("No receive locations found matching the specified name.");
                }
            }

            catch (Exception excep)
            {
                ExceptionLogger.SendErrorToText(excep);
            }

            return model;
        }

此外，如果您删除连接选项，这可以进一步简化（除非您是硬编码凭据，强烈建议您不要这么做）。如果您只是使用执行用户的身份，则不需要该数据。

-保罗

为什么 PropertyDataCollection 对象将多条记录保存到数据库

Why is PropertyDataCollection object persisting multiple records to database

c#

collections

wmi

biztalk