Function getAffectedRowsFromOceanBaseQueryPlan

backend/plugin/db/mysql/stats.go:99–131

(planString string)

}

func getAffectedRowsFromOceanBaseQueryPlan(planString string) (int64, error) {
	var planValue map[string]json.RawMessage
	if err := json.Unmarshal([]byte(planString), &planValue); err != nil {
		return 0, errors.Wrapf(err, "failed to parse query plan from string: %+v", planString)
	}
	if len(planValue) == 0 {
		return 0, nil
	}
	queryPlan := oceanBaseQueryPlan{}
	if err := queryPlan.Unmarshal(planValue); err != nil {
		return 0, errors.Wrapf(err, "failed to parse query plan from map: %+v", planValue)
	}
	if queryPlan.Operator != "" {
		return queryPlan.EstRows, nil
	}
	count := int64(-1)
	for k, v := range planValue {
		if !strings.HasPrefix(k, "CHILD_") {
			continue
		}
		child := oceanBaseQueryPlan{}
		if err := child.Unmarshal(v); err != nil {
			return 0, errors.Wrapf(err, "failed to parse field '%s', value: %+v", k, v)
		}
		if child.Operator != "" && child.EstRows > count {
			count = child.EstRows
		}
	}
	if count >= 0 {
		return count, nil
	}
	return 0, nil
}

// oceanBaseQueryPlan represents the query plan of OceanBase.
type oceanBaseQueryPlan struct {