Procédure : intercepter des messages de service de données (WCF Data Services)

Avec Services de données WCF , vous pouvez intercepter des messages de demande afin de pouvoir ajouter la logique personnalisée à une opération. Pour intercepter un message, vous utilisez des méthodes attribuées spécialement dans le service de données. Pour plus d'informations, consultez Intercepteurs (WCF Data Services).

L'exemple de cette rubrique utilise l'exemple du service de données Northwind. Ce service est créé lorsque vous complétez le démarrage rapide WCF Data Services.

Pour définir un intercepteur de requête pour le jeu d'entités Orders

1. Dans le projet de service de données Northwind, ouvrez le fichier Northwind.svc.

2. Dans la page de codes de la classe Northwind, ajoutez l'instruction suivante using (Imports en Visual Basic).

   Imports System.Linq.Expressions
   

   using System.Linq.Expressions;
   

3. Dans la classe Northwind, définissez une méthode d'opération de service nommée OnQueryOrders comme suit :

   ' Define a query interceptor for the Orders entity set.
   <QueryInterceptor("Orders")> _
   Public Function OnQueryOrders() As Expression(Of Func(Of Order, Boolean))
   

   // Define a query interceptor for the Orders entity set.
   [QueryInterceptor("Orders")]
   public Expression<Func<Order, bool>> OnQueryOrders()
   

Pour définir un intercepteur de modification pour le jeu d'entités Products

1. Dans le projet de service de données Northwind, ouvrez le fichier Northwind.svc.

2. Dans la classe Northwind, définissez une méthode d'opération de service nommée OnChangeProducts comme suit :

   ' Define a change interceptor for the Products entity set.
   <ChangeInterceptor("Products")> _
   Public Sub OnChangeProducts(ByVal product As Product, _
                               ByVal operations As UpdateOperations)
   

   // Define a change interceptor for the Products entity set.
   [ChangeInterceptor("Products")]
   public void OnChangeProducts(Product product, UpdateOperations operations)
   

Exemple

Cet exemple définit une méthode d'interception de requête pour le jeu d'entités Orders qui retourne une expression lambda. Cette expression contient un délégué qui filtre le Orders demandé en fonction du Customers connexe qui a un nom de contact spécifique. Le nom est déterminé ensuite selon l'utilisateur demandeur. Cet exemple suppose que le service de données est hébergé dans une application Web ASP.NET qui utilise WCF, et que l'authentification est activée. La classe HttpContext est utilisée pour récupérer le principe de la demande actuelle.

' Define a query interceptor for the Orders entity set.
<QueryInterceptor("Orders")> _
Public Function OnQueryOrders() As Expression(Of Func(Of Order, Boolean))
    ' Filter the returned orders to only orders 
    ' that belong to a customer that is the current user.
    Return Function(o) o.Customer.ContactName = _
        HttpContext.Current.User.Identity.Name
End Function

// Define a query interceptor for the Orders entity set.
[QueryInterceptor("Orders")]
public Expression<Func<Order, bool>> OnQueryOrders()
{
    // Filter the returned orders to only orders 
    // that belong to a customer that is the current user.
    return o => o.Customer.ContactName ==
        HttpContext.Current.User.Identity.Name;
}

Cet exemple définit une méthode d'interception de modification pour le jeu d'entités Products. Cette méthode valide l'entrée au service pour une opération Add ou Change et lève une exception si une modification est apportée à un produit de fin de série. Elle bloque également la suppression de produits comme une opération non prise en charge.

' Define a change interceptor for the Products entity set.
<ChangeInterceptor("Products")> _
Public Sub OnChangeProducts(ByVal product As Product, _
                            ByVal operations As UpdateOperations)
    If operations = UpdateOperations.Change Then
        Dim entry As System.Data.Objects.ObjectStateEntry

        If Me.CurrentDataSource.ObjectStateManager _
            .TryGetObjectStateEntry(product, entry) Then

            ' Reject changes to a discontinued Product.
            ' Because the update is already made to the entity by the time the 
            ' change interceptor in invoked, check the original value of the Discontinued
            ' property in the state entry and reject the change if 'true'.
            If CType(entry.OriginalValues("Discontinued"), Boolean) Then
                Throw New DataServiceException(400, String.Format(
                            "A discontinued {0} cannot be modified.", product.ToString()))
            Else
                Throw New DataServiceException(String.Format( _
                    "The requested {0} could not be found in the data source.", product.ToString()))
            End If
        ElseIf (operations = UpdateOperations.Delete) Then
            ' Block the delete and instead set the Discontinued flag.
            Throw New DataServiceException(400, _
                "Products cannot be deleted; instead set the Discontinued flag to 'true'")
        End If
    End If
End Sub

// Define a change interceptor for the Products entity set.
[ChangeInterceptor("Products")]
public void OnChangeProducts(Product product, UpdateOperations operations)
{
    if (operations == UpdateOperations.Change)
    {
        System.Data.Objects.ObjectStateEntry entry;

        if (this.CurrentDataSource.ObjectStateManager
            .TryGetObjectStateEntry(product, out entry))
        {
            // Reject changes to a discontinued Product.
            // Because the update is already made to the entity by the time the 
            // change interceptor in invoked, check the original value of the Discontinued
            // property in the state entry and reject the change if 'true'.
            if ((bool)entry.OriginalValues["Discontinued"])
            {
                throw new DataServiceException(400, string.Format(
                            "A discontinued {0} cannot be modified.", product.ToString()));
            }
        }
        else
        {
            throw new DataServiceException(string.Format(
                "The requested {0} could not be found in the data source.", product.ToString()));
        }
    }
    else if (operations == UpdateOperations.Delete)
    {
        // Block the delete and instead set the Discontinued flag.
        throw new DataServiceException(400, 
            "Products cannot be deleted; instead set the Discontinued flag to 'true'"); 
    }
}

Voir aussi

Tâches

Procédure : définir une opération de service (WCF Data Services)

Autres ressources

Définition de WCF Data Services