Support set expressions

https://docs.oasis-open.org/amqp/filtex/v1.0/csd01/filtex-v1.0-csd01.html#_Toc67929291

Author: ansd

deps/rabbit/src/rabbit_amqp_filter_sql.erl

@@ -159,9 +159,9 @@ eval0({unary_minus, Expr}, Msg) ->
     end;
 
 %% Special operators
-eval0({'in', Expr, ValueList}, Msg) ->
+eval0({'in', Expr, ExprList}, Msg) ->
     Value = eval0(Expr, Msg),
-    is_in(Value, ValueList);
+    is_in(Value, ExprList, Msg);
 
 eval0({'is_null', Expr}, Msg) ->
     eval0(Expr, Msg) =:= undefined;
@@ -218,12 +218,13 @@ arithmetic('%', Left, Right) when is_integer(Left) andalso is_integer(Right) and
 arithmetic(_, _, _) ->
     undefined.
 
-is_in(undefined, _) ->
+is_in(undefined, _, _) ->
     %% "If identifier of an IN or NOT IN operation is NULL,
     %% the value of the operation is unknown."
     undefined;
-is_in(Value, List) ->
-    lists:member(Value, List).
+is_in(Value, ExprList, Msg) ->
+    IsEqual = fun(Expr) -> eval0(Expr, Msg) == Value end,
+    lists:any(IsEqual, ExprList).
 
 like(Subject, {exact, Pattern}) ->
     Subject =:= Pattern;

deps/rabbit/src/rabbit_amqp_sql_ast.erl

@@ -23,6 +23,9 @@ search(Pred, Node) ->
             case Node of
                 {Op, Arg} when is_atom(Op) ->
                     search(Pred, Arg);
+                {in, Arg, List} ->
+                    search(Pred, Arg) orelse
+                    lists:any(fun(N) -> search(Pred, N) end, List);
                 {Op, Arg1, Arg2} when is_atom(Op) ->
                     search(Pred, Arg1) orelse
                     search(Pred, Arg2);
@@ -49,6 +52,8 @@ map_1(Other, _Fun) ->
 
 map_2({Op, Arg1}, Fun) ->
     {Op, map_1(Arg1, Fun)};
+map_2({in, Arg1, List}, Fun) ->
+    {in, map_1(Arg1, Fun), lists:map(fun(N) -> map_1(N, Fun) end, List)};
 map_2({Op, Arg1, Arg2}, Fun) ->
     {Op, map_1(Arg1, Fun), map_1(Arg2, Fun)};
 map_2({Op, Arg1, Arg2, Arg3}, Fun) ->
@@ -79,8 +84,11 @@ has_binary_identifier_test() ->
     false = has_binary_identifier("properties.group-id LIKE 'group_%' ESCAPE '!'"),
     true = has_binary_identifier("user_tag LIKE 'group_%' ESCAPE '!'"),
 
-    false = has_binary_identifier("properties.group-id IN ('g1', 'g2', 'g3')"),
     true = has_binary_identifier("user_category IN ('g1', 'g2', 'g3')"),
+    true = has_binary_identifier("p.group-id IN ('g1', user_key, 'g3')"),
+    true = has_binary_identifier("p.group-id IN ('g1', 'g2', a.user_key)"),
+    false = has_binary_identifier("p.group-id IN (p.reply-to-group-id, 'g2', 'g3')"),
+    false = has_binary_identifier("properties.group-id IN ('g1', 'g2', 'g3')"),
 
     false = has_binary_identifier(
               "(properties.group-sequence + 1) * 2 <= 100 AND " ++