Function checkCompatibleTypes

server/connection_data.go:228–236

checkCompatibleTypes checks if multiple types for which a parameter are used are compatible.

(ctx *sql.Context, existingOid, newOid uint32, newName string)

// checkCompatibleTypes checks if multiple types for which a parameter are used are compatible.
func checkCompatibleTypes(ctx *sql.Context, existingOid, newOid uint32, newName string) error {
	var err error
	existing := pgtypes.GetTypeByID(id.Type(id.Cache().ToInternal(existingOid)))
	newType := pgtypes.GetTypeByID(id.Type(id.Cache().ToInternal(newOid)))
	if _, _, err = framework.FindCommonType(ctx, []*pgtypes.DoltgresType{existing, newType}); err != nil {
		err = errors.Errorf("parameter %s is used for incompatible types: %s and %s", newName, existing.String(), newType.String())
	}
	return err
}