Method callTimestampOperation

cel2sql.go:191–251

(fun string, lhs *exprpb.Expr, rhs *exprpb.Expr)

}

func (con *converter) callTimestampOperation(fun string, lhs *exprpb.Expr, rhs *exprpb.Expr) error {
	lhsParen := isComplexOperatorWithRespectTo(fun, lhs)
	rhsParen := isComplexOperatorWithRespectTo(fun, rhs)
	lhsType := con.getType(lhs)
	rhsType := con.getType(rhs)

	var timestampType *exprpb.Type
	var timestamp, duration *exprpb.Expr
	var timestampParen, durationParen bool
	switch {
	case isTimestampRelatedType(lhsType):
		timestampType = lhsType
		timestamp, duration = lhs, rhs
		timestampParen, durationParen = lhsParen, rhsParen
	case isTimestampRelatedType(rhsType):
		timestampType = rhsType
		timestamp, duration = rhs, lhs
		timestampParen, durationParen = rhsParen, lhsParen
	default:
		panic("lhs or rhs must be timestamp related type")
	}

	var sqlFun string
	switch fun {
	case operators.Add:
		switch {
		case isTimeType(timestampType):
			sqlFun = "TIME_ADD"
		case isDateType(timestampType):
			sqlFun = "DATE_ADD"
		case isDateTimeType(timestampType):
			sqlFun = "DATETIME_ADD"
		default:
			sqlFun = "TIMESTAMP_ADD"
		}
	case operators.Subtract:
		switch {
		case isTimeType(timestampType):
			sqlFun = "TIME_SUB"
		case isDateType(timestampType):
			sqlFun = "DATE_SUB"
		case isDateTimeType(timestampType):
			sqlFun = "DATETIME_SUB"
		default:
			sqlFun = "TIMESTAMP_SUB"
		}
	default:
		return fmt.Errorf("unsupported operation (%s)", fun)
	}
	con.str.WriteString(sqlFun)
	con.str.WriteString("(")
	if err := con.visitMaybeNested(timestamp, timestampParen); err != nil {
		return err
	}
	con.str.WriteString(", ")
	if err := con.visitMaybeNested(duration, durationParen); err != nil {
		return err
	}