mirror of
https://gitee.com/milvus-io/milvus.git
synced 2024-12-02 20:09:57 +08:00
115 lines
3.1 KiB
Go
115 lines
3.1 KiB
Go
package proxy
|
|
|
|
import (
|
|
"github.com/cockroachdb/errors"
|
|
|
|
"github.com/milvus-io/milvus/internal/proto/planpb"
|
|
)
|
|
|
|
func ParseExprFromPlan(plan *planpb.PlanNode) (*planpb.Expr, error) {
|
|
node := plan.GetNode()
|
|
|
|
if node == nil {
|
|
return nil, errors.New("can't get expr from empty plan node")
|
|
}
|
|
|
|
var expr *planpb.Expr
|
|
switch node := node.(type) {
|
|
case *planpb.PlanNode_VectorAnns:
|
|
expr = node.VectorAnns.GetPredicates()
|
|
case *planpb.PlanNode_Query:
|
|
expr = node.Query.GetPredicates()
|
|
default:
|
|
return nil, errors.New("unsupported plan node type")
|
|
}
|
|
|
|
return expr, nil
|
|
}
|
|
|
|
func ParsePartitionKeysFromBinaryExpr(expr *planpb.BinaryExpr) ([]*planpb.GenericValue, bool) {
|
|
leftRes, leftInRange := ParsePartitionKeysFromExpr(expr.Left)
|
|
RightRes, rightInRange := ParsePartitionKeysFromExpr(expr.Right)
|
|
|
|
if expr.Op == planpb.BinaryExpr_LogicalAnd {
|
|
// case: partition_key_field in [7, 8] && partition_key > 8
|
|
if len(leftRes)+len(RightRes) > 0 {
|
|
leftRes = append(leftRes, RightRes...)
|
|
return leftRes, false
|
|
}
|
|
|
|
// case: other_field > 10 && partition_key_field > 8
|
|
return nil, leftInRange || rightInRange
|
|
}
|
|
|
|
if expr.Op == planpb.BinaryExpr_LogicalOr {
|
|
// case: partition_key_field in [7, 8] or partition_key > 8
|
|
if leftInRange || rightInRange {
|
|
return nil, true
|
|
}
|
|
|
|
// case: partition_key_field in [7, 8] or other_field > 10
|
|
leftRes = append(leftRes, RightRes...)
|
|
return leftRes, false
|
|
}
|
|
|
|
return nil, false
|
|
}
|
|
|
|
func ParsePartitionKeysFromUnaryExpr(expr *planpb.UnaryExpr) ([]*planpb.GenericValue, bool) {
|
|
res, partitionInRange := ParsePartitionKeysFromExpr(expr.GetChild())
|
|
if expr.Op == planpb.UnaryExpr_Not {
|
|
// case: partition_key_field not in [7, 8]
|
|
if len(res) != 0 {
|
|
return nil, true
|
|
}
|
|
|
|
// case: other_field not in [10]
|
|
return nil, partitionInRange
|
|
}
|
|
|
|
// UnaryOp only includes "Not" for now
|
|
return res, partitionInRange
|
|
}
|
|
|
|
func ParsePartitionKeysFromTermExpr(expr *planpb.TermExpr) ([]*planpb.GenericValue, bool) {
|
|
if expr.GetColumnInfo().GetIsPartitionKey() {
|
|
return expr.GetValues(), false
|
|
}
|
|
|
|
return nil, false
|
|
}
|
|
|
|
func ParsePartitionKeysFromUnaryRangeExpr(expr *planpb.UnaryRangeExpr) ([]*planpb.GenericValue, bool) {
|
|
if expr.GetColumnInfo().GetIsPartitionKey() && expr.GetOp() == planpb.OpType_Equal {
|
|
return []*planpb.GenericValue{expr.Value}, false
|
|
}
|
|
|
|
return nil, true
|
|
}
|
|
|
|
func ParsePartitionKeysFromExpr(expr *planpb.Expr) ([]*planpb.GenericValue, bool) {
|
|
var res []*planpb.GenericValue
|
|
partitionKeyInRange := false
|
|
switch expr := expr.GetExpr().(type) {
|
|
case *planpb.Expr_BinaryExpr:
|
|
res, partitionKeyInRange = ParsePartitionKeysFromBinaryExpr(expr.BinaryExpr)
|
|
case *planpb.Expr_UnaryExpr:
|
|
res, partitionKeyInRange = ParsePartitionKeysFromUnaryExpr(expr.UnaryExpr)
|
|
case *planpb.Expr_TermExpr:
|
|
res, partitionKeyInRange = ParsePartitionKeysFromTermExpr(expr.TermExpr)
|
|
case *planpb.Expr_UnaryRangeExpr:
|
|
res, partitionKeyInRange = ParsePartitionKeysFromUnaryRangeExpr(expr.UnaryRangeExpr)
|
|
}
|
|
|
|
return res, partitionKeyInRange
|
|
}
|
|
|
|
func ParsePartitionKeys(expr *planpb.Expr) []*planpb.GenericValue {
|
|
res, partitionKeyInRange := ParsePartitionKeysFromExpr(expr)
|
|
if partitionKeyInRange {
|
|
res = nil
|
|
}
|
|
|
|
return res
|
|
}
|