方法: LINQ to SQL データソースを使用してデータサービスを作成する (WCF Data Services)

[アーティクル]
02/24/2011

WCF Data Services では、エンティティデータはデータサービスとして公開されます。リフレクションプロバイダーでは、IQueryable 実装を返すメンバーを公開するクラスに基づいたデータモデルを定義できます。データソース内のデータに更新を加えるには、これらのクラスも IUpdatable インターフェイスを実装する必要があります。詳細については、「データサービスプロバイダー (WCF Data Services)」を参照してください。このトピックでは、リフレクションプロバイダーを使用して Northwind サンプルデータベースにアクセスする LINQ to SQL クラスを作成する方法と、これらのデータクラスに基づくデータサービスを作成する方法について説明します。

LINQ to SQL クラスをプロジェクトに追加するには

Visual Basic または Visual C# から、[プロジェクト] メニューの [新しい項目の追加] をクリックします。
[LINQ to SQL クラス] テンプレートをクリックします。
名前を「Northwind.dbml」に変更します。
[追加] をクリックします。

Northwind.dbml ファイルがプロジェクトに追加され、オブジェクトリレーショナルデザイナー (O/R デザイナー) が開きます。
サーバーエクスプローラーまたはデータベースエクスプローラーで、Northwind の下にある [テーブル] を展開して、Customers テーブルをオブジェクトリレーショナルデザイナー (O/R デザイナー) にドラッグします。

Customer エンティティクラスが作成され、デザインサーフェイスに表示されます。
Orders テーブル、Order_Details テーブル、および Products テーブルに対して手順 6 を繰り返します。
LINQ to SQL クラスを表す新しい .dbml ファイルを右クリックして、[コードの表示] をクリックします。

DataContext クラス (この場合は NorthwindDataContext) から継承するクラスの部分クラス定義を含む Northwind.cs という新しい分離コードページが作成されます。

Northwind.cs コードファイルの内容を次のコードに置き換えます。このコードでは、DataContext と、および LINQ to SQL によって生成されたデータクラスを拡張して、リフレクションプロバイダーを実装します。

Imports System.ComponentModel
Imports System.Collections
Imports System.Linq
Imports System.Reflection
Imports System.Data.Linq
Imports System.Data.Linq.Mapping
Imports System.Data.Services
Imports System.Data.Services.Common

' Define the key properties for the LINQ to SQL data classes.
<DataServiceKeyAttribute("CustomerID")> _
Partial Public Class Customer
End Class
<DataServiceKeyAttribute("ProductID")> _
Partial Public Class Product
End Class
<DataServiceKeyAttribute("OrderID")> _
Partial Public Class Order
End Class
<DataServiceKeyAttribute("OrderID", "ProductID")> _
Partial Public Class Order_Detail
End Class
#Region "IUpdatable implementation"
' Define the IUpdatable implementation for LINQ to SQL.
Partial Public Class NorthwindDataContext
    Implements IUpdatable
    ' Creates an object in the container.
    Function CreateResource(ByVal containerName As String, ByVal fullTypeName As String) _
        As Object Implements IUpdatable.CreateResource

        Dim t = Type.GetType(fullTypeName, True)
        Dim table = GetTable(t)
        Dim resource = Activator.CreateInstance(t)
        table.InsertOnSubmit(resource)
        Return resource
    End Function
    ' Gets the object referenced by the resource.
    Function GetResource(ByVal query As IQueryable, ByVal fullTypeName As String) As Object _
     Implements IUpdatable.GetResource
        Dim resource = query.Cast(Of Object)().SingleOrDefault()

        ' fullTypeName can be null for deletes
        If fullTypeName IsNot Nothing AndAlso resource.GetType().FullName <> fullTypeName Then
            Throw New ApplicationException("Unexpected type for this resource.")
        End If
        Return resource
    End Function
    ' Resets the value of the object to its default value.
    Function ResetResource(ByVal resource As Object) As Object _
        Implements IUpdatable.ResetResource
        Dim t = resource.GetType()
        Dim table = Mapping.GetTable(t)
        Dim dummyResource = Activator.CreateInstance(t)
        For Each member In table.RowType.DataMembers

            If Not member.IsPrimaryKey AndAlso Not member.IsDeferred AndAlso _
                Not member.IsAssociation AndAlso Not member.IsDbGenerated Then
                Dim defaultValue = member.MemberAccessor.GetBoxedValue(dummyResource)
                member.MemberAccessor.SetBoxedValue(resource, defaultValue)
            End If
            Next
        Return resource
    End Function
    ' Sets the value of the given property on the object.
    Sub SetValue(ByVal targetResource As Object, ByVal propertyName As String, _
                 ByVal propertyValue As Object) Implements IUpdatable.SetValue
        Dim table = Mapping.GetTable(targetResource.GetType())
        Dim member = table.RowType.DataMembers.Single(Function(x) x.Name = propertyName)
        member.MemberAccessor.SetBoxedValue(targetResource, propertyValue)
    End Sub
    ' Gets the value of a property on an object.
    Function GetValue(ByVal targetResource As Object, ByVal propertyName As String) _
    As Object Implements IUpdatable.GetValue
        Dim table = Mapping.GetTable(targetResource.GetType())
        Dim member = _
        table.RowType.DataMembers.Single(Function(x) x.Name = propertyName)
        Return member.MemberAccessor.GetBoxedValue(targetResource)
    End Function
    ' Sets the related object for a reference.
    Sub SetReference(ByVal targetResource As Object, ByVal propertyName As String, _
                     ByVal propertyValue As Object) Implements IUpdatable.SetReference
        CType(Me, IUpdatable).SetValue(targetResource, propertyName, propertyValue)
    End Sub
' Adds the object to the related objects collection.
    Sub AddReferenceToCollection(ByVal targetResource As Object, ByVal propertyName As String, _
                                 ByVal resourceToBeAdded As Object) _
                                 Implements IUpdatable.AddReferenceToCollection
        Dim pi = targetResource.GetType().GetProperty(propertyName)
        If pi Is Nothing Then
            Throw New Exception("Can't find property")
        End If
        Dim collection = CType(pi.GetValue(targetResource, Nothing), IList)
        collection.Add(resourceToBeAdded)
    End Sub
    ' Removes the object from the related objects collection.
    Sub RemoveReferenceFromCollection(ByVal targetResource As Object, ByVal propertyName As String, _
                                      ByVal resourceToBeRemoved As Object) _
                                      Implements IUpdatable.RemoveReferenceFromCollection
        Dim pi = targetResource.GetType().GetProperty(propertyName)
        If pi Is Nothing Then
            Throw New Exception("Can't find property")
        End If
        Dim collection = CType(pi.GetValue(targetResource, Nothing), IList)
        collection.Remove(resourceToBeRemoved)
    End Sub
        ' Deletes the resource.
    Sub DeleteResource(ByVal targetResource As Object) _
    Implements IUpdatable.DeleteResource
        Dim table = GetTable(targetResource.GetType())
        table.DeleteOnSubmit(targetResource)
    End Sub
    ' Saves all the pending changes.
    Sub SaveChanges() Implements IUpdatable.SaveChanges
        SubmitChanges()
    End Sub
    ' Returns the actual instance of the resource represented 
    ' by the resource object.
    Function ResolveResource(ByVal resource As Object) As Object Implements IUpdatable.ResolveResource
        Return resource
    End Function
        ' Reverts all the pending changes.
    Sub ClearChanges() Implements IUpdatable.ClearChanges
        ' Raise an exception as there is no real way to do this with LINQ to SQL.
        ' Comment out the following line if you'd prefer a silent failure
        Throw New NotSupportedException()
    End Sub
End Class
#End Region

using System;
using System.ComponentModel;
using System.Collections;
using System.Linq;
using System.Reflection;
using System.Data.Linq;
using System.Data.Linq.Mapping;
using System.Data.Services;
using System.Data.Services.Common;

namespace NorthwindService
{
    // Define the key properties for the LINQ to SQL data classes.
    [DataServiceKeyAttribute("CustomerID")]
    public partial class Customer { }

    [DataServiceKeyAttribute("ProductID")]
    public partial class Product { }

    [DataServiceKeyAttribute("OrderID")]
    public partial class Order { }

    [DataServiceKeyAttribute("OrderID", "ProductID")]
    public partial class Order_Detail { }

    #region IUpdatable implementation
    // Define the IUpdatable implementation for LINQ to SQL.
    public partial class NorthwindDataContext : IUpdatable
    {
        // Creates an object in the container.
        object IUpdatable.CreateResource(string containerName, string fullTypeName)
        {
            Type t = Type.GetType(fullTypeName, true);
            ITable table = GetTable(t);
            object resource = Activator.CreateInstance(t);
            table.InsertOnSubmit(resource);
            return resource;
        }

        // Gets the object referenced by the resource.
        object IUpdatable.GetResource(IQueryable query, string fullTypeName)
        {
            object resource = query.Cast<object>().SingleOrDefault();

            // fullTypeName can be null for deletes
            if (fullTypeName != null && resource.GetType().FullName != fullTypeName)
                throw new ApplicationException("Unexpected type for this resource.");
            return resource;
        }


        // Resets the value of the object to its default value.
        object IUpdatable.ResetResource(object resource)
        {
            Type t = resource.GetType();
            MetaTable table = Mapping.GetTable(t);
            object dummyResource = Activator.CreateInstance(t);
            foreach (var member in table.RowType.DataMembers)
            {
                if (!member.IsPrimaryKey && !member.IsDeferred &&
                    !member.IsAssociation && !member.IsDbGenerated)
                {
                    object defaultValue = member.MemberAccessor.GetBoxedValue(dummyResource);
                    member.MemberAccessor.SetBoxedValue(ref resource, defaultValue);
                }
            }
            return resource;
        }

        // Sets the value of the given property on the object.
        void IUpdatable.SetValue(object targetResource, string propertyName, object propertyValue)
        {
            MetaTable table = Mapping.GetTable(targetResource.GetType());
            MetaDataMember member = table.RowType.DataMembers.Single(x => x.Name == propertyName);
            member.MemberAccessor.SetBoxedValue(ref targetResource, propertyValue);
        }

        // Gets the value of a property on an object.
        object IUpdatable.GetValue(object targetResource, string propertyName)
        {
            MetaTable table = Mapping.GetTable(targetResource.GetType());
            MetaDataMember member =
                table.RowType.DataMembers.Single(x => x.Name == propertyName);
            return member.MemberAccessor.GetBoxedValue(targetResource);
        }

        // Sets the related object for a reference.
        void IUpdatable.SetReference(
            object targetResource, string propertyName, object propertyValue)
        {
            ((IUpdatable)this).SetValue(targetResource, propertyName, propertyValue);
        }

        // Adds the object to the related objects collection.
        void IUpdatable.AddReferenceToCollection(
            object targetResource, string propertyName, object resourceToBeAdded)
        {
            PropertyInfo pi = targetResource.GetType().GetProperty(propertyName);
            if (pi == null)
                throw new Exception("Can't find property");
            IList collection = (IList)pi.GetValue(targetResource, null);
            collection.Add(resourceToBeAdded);
        }

        // Removes the object from the related objects collection.
        void IUpdatable.RemoveReferenceFromCollection(
            object targetResource, string propertyName, object resourceToBeRemoved)
        {
            PropertyInfo pi = targetResource.GetType().GetProperty(propertyName);
            if (pi == null)
                throw new Exception("Can't find property");
            IList collection = (IList)pi.GetValue(targetResource, null);
            collection.Remove(resourceToBeRemoved);
        }

        // Deletes the resource.
        void IUpdatable.DeleteResource(object targetResource)
        {
            ITable table = GetTable(targetResource.GetType());
            table.DeleteOnSubmit(targetResource);
        }

        // Saves all the pending changes.
        void IUpdatable.SaveChanges()
        {
            SubmitChanges();
        }

        // Returns the actual instance of the resource represented 
        // by the resource object.
        object IUpdatable.ResolveResource(object resource)
        {
            return resource;
        }

        // Reverts all the pending changes.
        void IUpdatable.ClearChanges()
        {
            // Raise an exception as there is no real way to do this with LINQ to SQL.
            // Comment out the following line if you'd prefer a silent failure
            throw new NotSupportedException();
        }
    #endregion
    }
}

LINQ to SQL ベースのデータモデルを使用してデータサービスを作成するには

ソリューションエクスプローラーで、ASP.NET プロジェクトの名前を右クリックし、[新しい項目の追加] をクリックします。
[新しい項目の追加] ダイアログボックスで、[WCF Data Service] を選択します。
サービスの名前を入力して、[OK] をクリックします。

Visual Studio で新しいサービスの XML マークアップおよびコードファイルが作成されます。既定では、コードエディターのウィンドウが開きます。
データサービスのコードで、データサービスを定義するクラスの定義にあるコメント /* TODO: put your data source class name here */ をデータモデルのエンティティコンテナーである型 (この場合は NorthwindDataContext) で置き換えます。

データサービスのコードで、InitializeService 関数のプレースホルダーのコードを次の内容で置き換えます。

config.SetEntitySetAccessRule("Customers", EntitySetRights.ReadMultiple)
config.SetEntitySetAccessRule("Orders", EntitySetRights.AllRead _
                            Or EntitySetRights.WriteMerge)
config.SetEntitySetAccessRule("Order_Details", EntitySetRights.AllRead _
                            Or EntitySetRights.AllWrite)
config.SetEntitySetAccessRule("Products", EntitySetRights.ReadMultiple)

config.SetEntitySetAccessRule("Customers", EntitySetRights.ReadMultiple);
config.SetEntitySetAccessRule("Orders", EntitySetRights.AllRead  
                            | EntitySetRights.WriteMerge);
config.SetEntitySetAccessRule("Order_Details", EntitySetRights.AllRead                             
                            | EntitySetRights.AllWrite);
config.SetEntitySetAccessRule("Products", EntitySetRights.ReadMultiple);

指定した 3 つのエンティティセットのリソースへのクライアントアクセスが承認されます。

Web ブラウザーを使用して Northwind.svc データサービスをテストするには、トピック「Web ブラウザーからサービスへのアクセス (WCF Data Services クイックスタート)」の手順に従います。

参照

処理手順

方法: ADO.NET Entity Framework データソースを使用してデータサービスを作成する (WCF Data Services)
方法: リフレクションプロバイダーを使用してデータサービスを作成する (WCF Data Services)

概念

データサービスプロバイダー (WCF Data Services)

次の方法で共有

方法: LINQ to SQL データソースを使用してデータサービスを作成する (WCF Data Services)

LINQ to SQL クラスをプロジェクトに追加するには

LINQ to SQL ベースのデータモデルを使用してデータサービスを作成するには

参照

処理手順

概念

その他のリソース

次の方法で共有

方法: LINQ to SQL データ ソースを使用してデータ サービスを作成する (WCF Data Services)

LINQ to SQL クラスをプロジェクトに追加するには

LINQ to SQL ベースのデータ モデルを使用してデータ サービスを作成するには

参照

処理手順

概念

その他のリソース

方法: LINQ to SQL データソースを使用してデータサービスを作成する (WCF Data Services)

LINQ to SQL ベースのデータモデルを使用してデータサービスを作成するには