-1

请在这里忍耐一下，我已经工作了几个小时，感觉自己开始感到疲倦，犯错误，看不到我应该看到的东西。如果这是一个愚蠢的问题，我很抱歉。我有一个动态对象循环。这些动态对象可以是不同的形状，并且最终将被插入到与动态对象的属性的列名匹配的数据库表中。因此，如果对象具有“Title=Mr”，则数据库中将有一个名为“Title”的数据库列。

我有下面的循环，我试图以某种方式将我的动态对象转换为列名数组和值数组，然后以某种方式在我的 Insert 语句中使用 SqlKata 到 SQL Server 中使用它们（我愿意接受普通的旧 ADO.NET）。

但是，它严重损坏了，我认为压力让我看不到像这样转动动态对象的更简单的解决方案：

{
    "TRS_KEY": 712134,
    "TRS_PTR": 16974,
    "TailFlags": 0,
    "RRP": 49.95,
    "PriceType": 1,
    "PromoID": 194814003
}

进入这样的插入语句（假设我在其他地方准备好了表变量）

INSERT INTO <TABLE> (TRS_KEY,TRS_PTR,TailFlags,RRP,PriceType,PromoId) VALUES(712134,16974... and so on

我到了下面，但它完全搞砸了。我显然离这儿很远。

            foreach (dynamic d in r.Data)
            {
                try
                {
                    context.Logger.LogLine($"Original dynamic object serialised to JSON -> {JsonConvert.SerializeObject(d)}");

                    JObject o = JObject.Parse(JsonConvert.SerializeObject(d));
                    var result = o.Descendants()
                                .OfType<JProperty>()
                                .Select(p => new KeyValuePair<string, object>(p.Path,
                                p.Value.Type == JTokenType.Array || p.Value.Type == JTokenType.Object
                                ? null : p.Value));

                    var columns = result.Select(pairs => result.Select(pair => pair.Key).ToArray().ToString());
                    context.Logger.LogLine($"COLUMNS {JsonConvert.SerializeObject(columns)}");
                    var values = result.Select(pairs => result.Select(pair => pair.Value).ToArray());
                    context.Logger.LogLine($"VALUES TO GO INTO INSERTS {JsonConvert.SerializeObject(values)}");

                    var queryResult = db.Query(r.TableRef).Insert(columns, values);
                    db.Logger = compiled => {
                        context.Logger.Log($"{compiled.ToString()}");
                    };

                }
                catch (Exception ex)
                {
                    context.Logger.LogLine($"{ex.ToString()}");
                }
            }

以下哪些产品一团糟：/

在此处输入图像描述

我通常不会诉诸 SO 的“情感”方面，但如果现在有人可以提供帮助并保留判断力，我将不胜感激。我只有这个周末才能启动并运行这个概念，我想我开始觉得我无法摆脱自己的头脑来简单而干净地解决这个问题。

编辑 - 尝试了下面的答案，但现在遇到了这个问题：

            foreach (dynamic d in r.Data)
            {
                //context.Logger.LogLine($"{d.GetType()}");
                try
                {
                    context.Logger.LogLine($"{r.TableRef} {JsonConvert.SerializeObject(d)}");

                    JObject o = d;
                    var result = o.Descendants()
                                .OfType<JProperty>()
                                .Select(p => new KeyValuePair<string, object>(p.Path,
                                p.Value.Type == JTokenType.Array || p.Value.Type == JTokenType.Object
                                ? null : p.Value));

                    IEnumerable<string> columns = result.Select(p => p.Key);
                    IEnumerable<object> values = result.Select(p => p.Value);


                    var queryResult = db.Query(r.TableRef).Insert(columns, values);

错误：（插入（列，值）中的值下方的红色波浪）

Severity    Code    Description Project File    Line    Suppression State
Error   CS1503  Argument 3: cannot convert from 'System.Collections.Generic.IEnumerable<object>' to 'System.Collections.Generic.IEnumerable<System.Collections.Generic.IEnumerable<object>>'    S2CProcessDataStateMachine  C:\Users\jmatson\source\repos\S2CProcessDataStateMachine\S2CProcessDataStateMachine\StepFunctionTasks.cs    113 Active

编辑：

变成

                    JObject o = d;
                    var result = o.Descendants()
                                .OfType<JProperty>()
                                .Select(p => new KeyValuePair<string, object>(p.Path,
                                p.Value.Type == JTokenType.Array || p.Value.Type == JTokenType.Object
                                ? null : p.Value));

                    IEnumerable<string> columns = result.Select(p => p.Key);
                    IEnumerable<object> values = result.Select(p => p.Value);

                    // Add custom columns
                    IEnumerable<string> colAdded = columns.Add("STORE_ID").Add("last_modified");

                    IEnumerable<object> valAdded = values.Add(state.StoreId).Add(DateTime.Now);


                    var queryResult = db.Query(r.TableRef).AsInsert(colAdded, valAdded );
                    queryResult.Get();

在尝试 SQL 插入之前，这不会导致错误。正如您在上面看到的，我在插入之前添加了几个额外的列和值。所有列都很好地显示在插入语句中，但请注意只有我手动添加的两个值出现？剩下的都是空的？:(

插入 [TLog010000ItemSale] ([TRS_KEY], [TRS_PTR], [PLUID], [Ext11], [Subtract], [Cancel], [Negative], [FuelItemCancel], [StaffDiscAllow], [PriceOveride], [OnSale], [WSPriceOverride]、[ManPrice]、[ManPriceAllw]、[NoManWgnt]、[WgtItem]、[DecItem]、[Gallons]、[ChainPrv]、[NonMerch]、[StoreCpn]、[VendorCpn]、[DiscAlw]、[Scan ], [ReadSrv], [NextInfo], [ReplUnknown], [GSTExclFollow], [PriceGrid], [DepID], [MSU], [RetnID], [TaxF], [QTY], [Price], [Amount], [ExclPrice], [ExclAmount], [CaseQty], [TailFlags], [NoStockDeduct], [NoLoyaltyPoints], [STORE_ID], [last_modified]) 值 (, , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , , 'A854', '2019-08-03 12:11:10')

4

1 回答 1

1

鉴于这result是IEnumerable<KeyValuePair<string,object>>linq 类型，以获取列和值的列表是一个简单的 linq Select。您的 Key 中可能有空值，KeyValuePair因此请先删除它们：

result = result.Where(x => x.Key != null);      
IEnumerable<string> columns = result.Select(p => p.Key);
IEnumerable<object> values = result.Select(p => p.Value);

在这种情况下，使用var更多的是阻碍而不是帮助。如果columnsandvalues已被声明为预期的类型，编译器将立即显示它是否与 linq 查询产生的任何内容相匹配。

SqlKata 函数Insert用于多次插入，因此需要一组插入值列表：

var queryResult = db.Query(r.TableRef).Insert(columns, new[]{values});
于 2019-08-03T09:45:36.213 回答