增加NOT IN和BETWEEN的判断

pull/4/head
洪华兵 2 weeks ago
parent a9ba0aafaa
commit 99ceabeb7e

@ -24,8 +24,11 @@ namespace ZKLT.Hadoop.Model
public const string IN = "IN"; public const string IN = "IN";
public const string NOTIN = "NOT IN";
public const string BETWEEN = "BETWEEN"; public const string BETWEEN = "BETWEEN";
public const string QUERYIN = "QUERYIN"; public const string QUERYIN = "QUERYIN";
} }
} }

@ -100,6 +100,7 @@ namespace ZKLT.Hadoop
param.Add(_guid, $@"%{((JValue)_Colv[k]!).Value!}%"); param.Add(_guid, $@"%{((JValue)_Colv[k]!).Value!}%");
break; break;
case HDP_WhereType.IN: case HDP_WhereType.IN:
case HDP_WhereType.NOTIN:
_wherestr.AppendLine(@$"AND `{_item.Name}` {_Itemv[k]} @{_guid}"); _wherestr.AppendLine(@$"AND `{_item.Name}` {_Itemv[k]} @{_guid}");
param.Add(_guid, _Colv[k]!); param.Add(_guid, _Colv[k]!);
break; break;
@ -108,13 +109,17 @@ namespace ZKLT.Hadoop
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);
_wherestr.AppendLine(@$"AND `{_item.Name}` IN ({_Query})"); _wherestr.AppendLine(@$"AND `{_item.Name}` IN ({_Query})");
break; break;
case HDP_WhereType.BETWEEN:
_wherestr.AppendLine(@$"AND `{_item.Name}` BETWEEN @{_guid}1 AND @{_guid}2");
param.Add(_guid + "1", ((JArray)_Colv[k]!)[0].ToString());
param.Add(_guid + "2", ((JArray)_Colv[k]!)[1].ToString());
break;
case HDP_WhereType.EQUAL: case HDP_WhereType.EQUAL:
case HDP_WhereType.NOTEQUAL: case HDP_WhereType.NOTEQUAL:
case HDP_WhereType.MORE: case HDP_WhereType.MORE:
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.BETWEEN:
default: default:
_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!);

Loading…
Cancel
Save