对IN单独处理

pull/4/head
洪华兵 2 weeks ago
parent fd7598fa7d
commit 6746d063d4

@ -99,6 +99,10 @@ namespace ZKLT.Hadoop
_wherestr.AppendLine(@$"AND `{_item.Name}` {_Itemv[k]} @{_guid}"); _wherestr.AppendLine(@$"AND `{_item.Name}` {_Itemv[k]} @{_guid}");
param.Add(_guid, $@"%{((JValue)_Colv[k]!).Value!}%"); param.Add(_guid, $@"%{((JValue)_Colv[k]!).Value!}%");
break; break;
case HDP_WhereType.IN:
_wherestr.AppendLine(@$"AND `{_item.Name}` {_Itemv[k]} @{_guid}");
param.Add(_guid, _Colv[k]!);
break;
case HDP_WhereType.QUERYIN: case HDP_WhereType.QUERYIN:
var _Command = JsonConvert.DeserializeObject<HDP_Command>(_Colv[k].ToString())!; var _Command = JsonConvert.DeserializeObject<HDP_Command>(_Colv[k].ToString())!;
var _Query = QueryString(_Command.SourceId!, _Command.TableId!, _Command.Where, _Command.Data, _Command.Order, _Command.Col, param); 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.LESS:
case HDP_WhereType.MORETHEN: case HDP_WhereType.MORETHEN:
case HDP_WhereType.LESSTHEN: case HDP_WhereType.LESSTHEN:
case HDP_WhereType.IN:
case HDP_WhereType.BETWEEN: case HDP_WhereType.BETWEEN:
default: default:
_wherestr.AppendLine(@$"AND `{_item.Name}` {_Itemv[k]} @{_guid}"); _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; break;
} }
} }

Loading…
Cancel
Save