| 1 | #include "duckdb/planner/expression/list.hpp" |
| 2 | #include "duckdb/optimizer/rule/comparison_simplification.hpp" |
| 3 | |
| 4 | #include "duckdb/execution/expression_executor.hpp" |
| 5 | #include "duckdb/planner/expression/bound_constant_expression.hpp" |
| 6 | |
| 7 | namespace duckdb { |
| 8 | |
| 9 | ComparisonSimplificationRule::ComparisonSimplificationRule(ExpressionRewriter &rewriter) : Rule(rewriter) { |
| 10 | // match on a ComparisonExpression that has a ConstantExpression as a check |
| 11 | auto op = make_uniq<ComparisonExpressionMatcher>(); |
| 12 | op->matchers.push_back(x: make_uniq<FoldableConstantMatcher>()); |
| 13 | op->policy = SetMatcher::Policy::SOME; |
| 14 | root = std::move(op); |
| 15 | } |
| 16 | |
| 17 | unique_ptr<Expression> ComparisonSimplificationRule::Apply(LogicalOperator &op, vector<reference<Expression>> &bindings, |
| 18 | bool &changes_made, bool is_root) { |
| 19 | auto &expr = bindings[0].get().Cast<BoundComparisonExpression>(); |
| 20 | auto &constant_expr = bindings[1].get(); |
| 21 | bool column_ref_left = expr.left.get() != &constant_expr; |
| 22 | auto column_ref_expr = !column_ref_left ? expr.right.get() : expr.left.get(); |
| 23 | // the constant_expr is a scalar expression that we have to fold |
| 24 | // use an ExpressionExecutor to execute the expression |
| 25 | D_ASSERT(constant_expr.IsFoldable()); |
| 26 | Value constant_value; |
| 27 | if (!ExpressionExecutor::TryEvaluateScalar(context&: GetContext(), expr: constant_expr, result&: constant_value)) { |
| 28 | return nullptr; |
| 29 | } |
| 30 | if (constant_value.IsNull() && !(expr.type == ExpressionType::COMPARE_NOT_DISTINCT_FROM || |
| 31 | expr.type == ExpressionType::COMPARE_DISTINCT_FROM)) { |
| 32 | // comparison with constant NULL, return NULL |
| 33 | return make_uniq<BoundConstantExpression>(args: Value(LogicalType::BOOLEAN)); |
| 34 | } |
| 35 | if (column_ref_expr->expression_class == ExpressionClass::BOUND_CAST) { |
| 36 | //! Here we check if we can apply the expression on the constant side |
| 37 | //! We can do this if the cast itself is invertible and casting the constant is |
| 38 | //! invertible in practice. |
| 39 | auto &cast_expression = column_ref_expr->Cast<BoundCastExpression>(); |
| 40 | auto target_type = cast_expression.source_type(); |
| 41 | if (!BoundCastExpression::CastIsInvertible(source_type: target_type, target_type: cast_expression.return_type)) { |
| 42 | return nullptr; |
| 43 | } |
| 44 | |
| 45 | // Can we cast the constant at all? |
| 46 | string error_message; |
| 47 | Value cast_constant; |
| 48 | auto new_constant = constant_value.DefaultTryCastAs(target_type, new_value&: cast_constant, error_message: &error_message, strict: true); |
| 49 | if (!new_constant) { |
| 50 | return nullptr; |
| 51 | } |
| 52 | |
| 53 | // Is the constant cast invertible? |
| 54 | if (!cast_constant.IsNull() && |
| 55 | !BoundCastExpression::CastIsInvertible(source_type: cast_expression.return_type, target_type)) { |
| 56 | // Is it actually invertible? |
| 57 | Value uncast_constant; |
| 58 | if (!cast_constant.DefaultTryCastAs(target_type: constant_value.type(), new_value&: uncast_constant, error_message: &error_message, strict: true) || |
| 59 | uncast_constant != constant_value) { |
| 60 | return nullptr; |
| 61 | } |
| 62 | } |
| 63 | |
| 64 | //! We can cast, now we change our column_ref_expression from an operator cast to a column reference |
| 65 | auto child_expression = std::move(cast_expression.child); |
| 66 | auto new_constant_expr = make_uniq<BoundConstantExpression>(args&: cast_constant); |
| 67 | if (column_ref_left) { |
| 68 | expr.left = std::move(child_expression); |
| 69 | expr.right = std::move(new_constant_expr); |
| 70 | } else { |
| 71 | expr.left = std::move(new_constant_expr); |
| 72 | expr.right = std::move(child_expression); |
| 73 | } |
| 74 | } |
| 75 | return nullptr; |
| 76 | } |
| 77 | |
| 78 | } // namespace duckdb |
| 79 | |