LINQ et le nouveau modèle de données de SharePoint 2010

using (SPSite TargetSite = new SPSite(TargetSiteUrl))
{
    using (SPWeb TargetWeb = TargetSite.OpenWeb())
    {
        
        SPRelatedFieldCollection RelatedFields = TargetWeb.Lists["Cities"].GetRelatedFields();
        foreach (SPRelatedField RelatedField in RelatedFields)
        {
            Console.WriteLine("Field <{0}>\r\nbound to <{1}>\r\nlookup on <{2}>\r\nbehavior <{3}>\r\nWeb <{4}>",
                RelatedField.FieldId.ToString(),
                TargetWeb.Lists[RelatedField.ListId].Title,
                RelatedField.LookupList,
                RelatedField.RelationshipDeleteBehavior,
                RelatedField.WebId);
        }
    }
}

static void CreateRelationShip()
{
    string NewLookupFieldTitle = "New Field";
    using (SPSite Site = new SPSite("http://win-a8m4b9i5u4w/test"))
    {
        using (SPWeb Web = Site.OpenWeb())
        {
            try
            {

                SPListCollection Lists = Web.Lists;

                Guid SourceListId = Lists.Add("Source List",
                    "",
                    SPListTemplateType.GenericList);

                Console.WriteLine("Source List Created");

                Guid TargetListId = Lists.Add("Target List",
                    "",
                    SPListTemplateType.GenericList);

                Console.WriteLine("Target List Created");

                SPList SourceList = Lists[SourceListId];
                SPList TargetList = Lists[TargetListId];
                SPFieldCollection Fields = TargetList.Fields;
                Fields.AddLookup(NewLookupFieldTitle, SourceList.ID, true);
                Console.WriteLine("Lookup Field Created");
                SPFieldLookup NewLookupField = Fields[NewLookupFieldTitle] as SPFieldLookup;
                NewLookupField.Indexed = true;
                NewLookupField.LookupField = "Title";
                NewLookupField.RelationshipDeleteBehavior = SPRelationshipDeleteBehavior.Restrict;
                NewLookupField.Update();
                Console.WriteLine("Lookup Field Integrity enfored");
                SPListItem NewSourceItem = SourceList.Items.Add();
                NewSourceItem["Title"] = "Source Data";
                NewSourceItem.Update();
                Console.WriteLine("Source List Item Created");
                SPListItem NewTargetItem = TargetList.Items.Add();
                NewTargetItem["Title"] = "Target Data";                        
                NewTargetItem[NewLookupFieldTitle] = new SPFieldLookupValue(1, "Source Data");
                NewTargetItem.Update();
                Console.WriteLine("Source List Item Created");
                TargetList.Update();
                SourceList.Update();
                Console.WriteLine("Trying to delete the referenced source item...");
                NewSourceItem.Delete();
            }
            catch (SPException Ex)
            {
                Console.WriteLine(Ex.Message);
            }

            
        }
    }
}

using (SPSite TargetSite = new SPSite(TargetSiteUrl))
{
    using (SPWeb TargetWeb = TargetSite.OpenWeb())
    {
        
        SPRelatedFieldCollection RelatedFields = TargetWeb.Lists["Cities"].GetRelatedFields();
        SPField TheField = TargetWeb.Lists["Customers"].Fields.GetFieldByInternalName("Title");
        TheField.Indexed = true;
        TheField.AllowDuplicateValues = false;
        TheField.Update();       
        
    }
}

[Microsoft.SharePoint.Linq.ListAttribute(Name="Customers")]
public Microsoft.SharePoint.Linq.EntityList<CustomersItem> Customers 
{
	get
	{
		return this.GetList<CustomersItem>("Customers");
	}
}

[Microsoft.SharePoint.Linq.ContentTypeAttribute(Name="Item", Id="0x01", List="Customers")]
public partial class CustomersItem : Item {
	private System.Nullable<double> _age;
	private Microsoft.SharePoint.Linq.EntityRef<CitiesItem> _city;
	private Microsoft.SharePoint.Linq.EntitySet<OrdersItem> _ordersItem;
	
	#region Extensibility Method Definitions
	partial void OnLoaded();
	partial void OnValidate();
	partial void OnCreated();
	#endregion
	
	public CustomersItem() {
		this._city = new Microsoft.SharePoint.Linq.EntityRef<CitiesItem>();
		this._city.OnSync += new System.EventHandler<Microsoft.SharePoint.Linq.AssociationChangedEventArgs<CitiesItem>>(this.OnCitySync);
		this._city.OnChanged += new System.EventHandler(this.OnCityChanged);
		this._city.OnChanging += new System.EventHandler(this.OnCityChanging);
		this._ordersItem = new Microsoft.SharePoint.Linq.EntitySet<OrdersItem>();
		this._ordersItem.OnSync += new System.EventHandler<Microsoft.SharePoint.Linq.AssociationChangedEventArgs<OrdersItem>>(this.OnOrdersItemSync);
		this._ordersItem.OnChanged += new System.EventHandler(this.OnOrdersItemChanged);
		this._ordersItem.OnChanging += new System.EventHandler(this.OnOrdersItemChanging);
		this.OnCreated();
	}
	[Microsoft.SharePoint.Linq.ColumnAttribute(Name = "Age", Storage = "_age", FieldType = "Number")]
	public System.Nullable<double> Age
	{
		get
		{
			return this._age;
		}
		set
		{
			if ((value != this._age))
			{
				this.OnPropertyChanging("Age", this._age);
				this._age = value;
				this.OnPropertyChanged("Age");
			}
		}
	}
	[Microsoft.SharePoint.Linq.AssociationAttribute(Name="City", Storage="_city", MultivalueType=Microsoft.SharePoint.Linq.AssociationType.Single, List="Cities")]
	public CitiesItem City {
		get {
			return this._city.GetEntity();
		}
		set {
			this._city.SetEntity(value);
		}
	}
	[Microsoft.SharePoint.Linq.AssociationAttribute(Name = "Customer", Storage = "_ordersItem", MultivalueType = Microsoft.SharePoint.Linq.AssociationType.Backward, List = "Orders")]
	public Microsoft.SharePoint.Linq.EntitySet<OrdersItem> OrdersItem
	{
		get
		{
			return this._ordersItem;
		}
		set
		{
			this._ordersItem.Assign(value);
		}
	}
	
	private void OnCityChanging(object sender, System.EventArgs e) {
		this.OnPropertyChanging("City", this._city.Clone());
	}
	
	private void OnCityChanged(object sender, System.EventArgs e) {
		this.OnPropertyChanged("City");
	}
	
	private void OnCitySync(object sender, Microsoft.SharePoint.Linq.AssociationChangedEventArgs<CitiesItem> e) {
		if ((Microsoft.SharePoint.Linq.AssociationChangedState.Added == e.State)) {
			e.Item.CustomersItem.Add(this);
		}
		else {
			e.Item.CustomersItem.Remove(this);
		}
	}
	private void OnOrdersItemChanging(object sender, System.EventArgs e)
	{
		this.OnPropertyChanging("OrdersItem", this._ordersItem.Clone());
	}
	private void OnOrdersItemChanged(object sender, System.EventArgs e)
	{
		this.OnPropertyChanged("OrdersItem");
	}
	private void OnOrdersItemSync(object sender, Microsoft.SharePoint.Linq.AssociationChangedEventArgs<OrdersItem> e)
	{
		if ((Microsoft.SharePoint.Linq.AssociationChangedState.Added == e.State))
		{
			e.Item.Customer = this;
		}
		else
		{
			e.Item.Customer = null;
		}
	}
}

TeamSiteDataContext Ctx = new TeamSiteDataContext("http://urldusite");

TeamSiteDataContext Ctx = new TeamSiteDataContext(SPContext.Current.Web.Url);

IEnumerable<IGrouping<CitiesItem, CustomersItem>> CustomersByCity = Ctx.Customers.Where(c => c.Age < 35).GroupBy(c => c.City);
foreach (var CustomerCity in CustomersByCity)
{
	CitiesItem CityGroup = CustomerCity.Key as CitiesItem;
	Console.WriteLine(string.Format("Number of customers aged < 35 living in {0} is {1}",
	CityGroup.Title, CustomerCity.Count()));
}

IEnumerable<IGrouping<CitiesItem, CustomersItem>> CustomersByCity = Ctx.Customers.Where(c => c.Age < 35).ToList().GroupBy(c => c.City);
foreach (var CustomerCity in CustomersByCity)
{
	CitiesItem CityGroup = CustomerCity.Key as CitiesItem;
	Console.WriteLine(string.Format("Number of customers aged < 35 living in {0} is {1}",
	CityGroup.Title, CustomerCity.Count()));
}

EntityList<CustomersItem> Customers = Ctx.GetList<CustomersItem>("Customers");
EntityList<CitiesItem> Cities = Ctx.GetList<CitiesItem>("Cities");
EntityList<OrdersItem> Orders = Ctx.GetList<OrdersItem>("Orders");

var QueryResults = from Customer in Customers
                   join City in Cities on Customer.City.Id equals City.Id
                   join OrderItem in Orders on Customer.Id equals OrderItem.Customer.Id
                   select new { CityName = City.Title, City.Country, Customer.Title, OrderTitle = OrderItem.Title };

List<CustomersItem> Customers = Ctx.GetList<CustomersItem>("Customers").Where(c=>c.City!=null).ToList();
List<CitiesItem> Cities = Ctx.GetList<CitiesItem>("Cities").ToList();
List<OrdersItem> Orders = Ctx.GetList<OrdersItem>("Orders").Where(o => o.Customer != null).ToList();

var QueryResults = from Customer in Customers
                   join City in Cities on Customer.City.Id equals City.Id
                   join OrderItem in Orders on Customer.Id equals OrderItem.Customer.Id
                   select new { CityName = City.Title, City.Country, Customer.Title, OrderTitle = OrderItem.Title };

EntityList<CustomersItem> Customers = Ctx.GetList<CustomersItem>("Customers");
var CustomerItems = from Customer in Customers
                    where Customer.Id == CustomerId
                    select Customer;

foreach (var CustomerItem in CustomerItems)
{
    CustomerItem.Age = Age;
}
System.Threading.Thread.Sleep(SleepTime);
try
{
    Ctx.SubmitChanges(ConflictMode.FailOnFirstConflict);
}
catch (ChangeConflictException)
{
    
    foreach (ObjectChangeConflict UpdatedListItem in Ctx.ChangeConflicts)
    {
        foreach (MemberChangeConflict UpdatedField in UpdatedListItem.MemberConflicts)
        {
            MessageBox.Show(string.Format(
                "Conflict detected on <{0}>, Original value <{1}>, Database Value <{2}> Trying to set <{3}>",
                UpdatedField.Member.Name,
                UpdatedField.OriginalValue,
                UpdatedField.DatabaseValue,
                UpdatedField.CurrentValue));

        }
    }


}

try
            {
                Ctx.SubmitChanges(ConflictMode.ContinueOnConflict);
            }
            catch (ChangeConflictException)
            {
                MessageBox.Show ("Detected change conflict exception, forcing changes");
                Ctx.ChangeConflicts.ResolveAll(RefreshMode.KeepChanges);
                Ctx.SubmitChanges();
            }

try
{
    Ctx.SubmitChanges(ConflictMode.ContinueOnConflict);
}
catch (ChangeConflictException)
{
    foreach (ObjectChangeConflict UpdatedListItem in Ctx.ChangeConflicts)
    {
        CustomersItem CurrentObj = UpdatedListItem.Object as CustomersItem;
        MessageBox.Show(string.Format("Detected conflict for customer <{0}>",
            CurrentObj.Id));

        foreach (MemberChangeConflict UpdatedField in UpdatedListItem.MemberConflicts)
        {
            MessageBox.Show(string.Format(
                "Conflict detected on <{0}>, Original value <{1}>, Database Value <{2}> Trying to set <{3}>",
                UpdatedField.Member.Name,
                UpdatedField.OriginalValue,
                UpdatedField.DatabaseValue,
                UpdatedField.CurrentValue));

            if (CurrentObj.Id == 1 &&
                UpdatedField.Member.Name == "Age") // in this case it's always age but it's just to show an example
            {
                MessageBox.Show("Forcing changes for customer <1>");
                UpdatedField.Resolve(RefreshMode.KeepCurrentValues);
            }
            else
            {
                MessageBox.Show(string.Format("Cancelling changes for customer <{0}>",
                    CurrentObj.Id));

                UpdatedField.Resolve(RefreshMode.OverwriteCurrentValues);
            }
        }
    }
    Ctx.SubmitChanges();
}