diff --git a/Hadoop/ZKLT.Hadoop/TableService.cs b/Hadoop/ZKLT.Hadoop/TableService.cs index 6bc4552..dc7c077 100644 --- a/Hadoop/ZKLT.Hadoop/TableService.cs +++ b/Hadoop/ZKLT.Hadoop/TableService.cs @@ -99,6 +99,10 @@ namespace ZKLT.Hadoop _wherestr.AppendLine(@$"AND `{_item.Name}` {_Itemv[k]} @{_guid}"); param.Add(_guid, $@"%{((JValue)_Colv[k]!).Value!}%"); break; + case HDP_WhereType.IN: + _wherestr.AppendLine(@$"AND `{_item.Name}` {_Itemv[k]} @{_guid}"); + param.Add(_guid, _Colv[k]!); + break; case HDP_WhereType.QUERYIN: var _Command = JsonConvert.DeserializeObject(_Colv[k].ToString())!; var _Query = QueryString(_Command.SourceId!, _Command.TableId!, _Command.Where, _Command.Data, _Command.Order, _Command.Col, param); @@ -110,18 +114,10 @@ namespace ZKLT.Hadoop case HDP_WhereType.LESS: case HDP_WhereType.MORETHEN: case HDP_WhereType.LESSTHEN: - case HDP_WhereType.IN: case HDP_WhereType.BETWEEN: default: _wherestr.AppendLine(@$"AND `{_item.Name}` {_Itemv[k]} @{_guid}"); - if (_Colv[k]!.Type == JTokenType.Object || _data[_item.Name]!.Type == JTokenType.Array) - { - param.Add(_guid, _Colv[k]!); - } - else - { - param.Add(_guid, ((JValue)_Colv[k]!).Value!); - } + param.Add(_guid, ((JValue)_Colv[k]!).Value!); break; } }