これを行うにはいくつかの方法があり、それをどのように行うかは、個人的な好みと潜在的なパフォーマンスの目標に少し依存します。
- 照会されたすべてのタイプを表す統合クラスを作成します。StatusUpdateEntryとNotificationEntryがある場合は、各プロパティを1つのクラスにマージするだけです。シリアライザーは自動的に正しいプロパティを入力し、他のプロパティはnull(またはデフォルト)のままにします。エンティティに「type」プロパティ(計算またはストレージに設定)も設定すると、そのタイプを簡単にオンに切り替えることができます。私は常にテーブルエンティティからアプリ内の独自のタイプにマッピングすることをお勧めしますので、これも問題なく機能します(クラスはDTOにのみ使用されます)。
例:
[DataServiceKey("PartitionKey", "RowKey")]
public class NoticeStatusUpdateEntry
{
public string PartitionKey { get; set; }
public string RowKey { get; set; }
public string NoticeProperty { get; set; }
public string StatusUpdateProperty { get; set; }
public string Type
{
get
{
return String.IsNullOrEmpty(this.StatusUpdateProperty) ? "Notice" : "StatusUpate";
}
}
}
- シリアル化プロセスをオーバーライドします。これは、ReadingEntityイベントをフックすることで自分で行うことができます。それはあなたに生のXMLを与え、あなたはあなたが望むようにシリアル化することを選ぶことができます。JaiHaridasとPabloCastroは、タイプ(以下に含まれる)がわからないときにエンティティを読み取るためのサンプルコードをいくつか示しました。これを適応させて、知っている特定のタイプを読み取ることができます。
両方のアプローチの欠点は、場合によっては必要以上のデータを取得してしまうことです。これを、あるタイプと別のタイプに対して実際にクエリする量と比較検討する必要があります。テーブルストレージでプロジェクションを使用できるようになったことを覚えておいてください。これにより、ワイヤフォーマットのサイズも小さくなり、エンティティが大きい場合や返されるエンティティが多い場合に、処理速度が大幅に向上します。単一の型のみをクエリする必要がある場合は、おそらくRowKeyまたはPartitionKeyの一部を使用して型を指定します。これにより、一度に1つの型のみをクエリできるようになります(プロパティを使用できますが、これは、クエリの目的ではPKやRKほど効率的ではありません)。
編集:Lucifureが指摘したように、もう1つの優れたオプションは、その周りを設計することです。複数のテーブルを使用したり、並列クエリを実行したりします。もちろん、タイムアウトやエラー処理に関する複雑さとトレードオフする必要がありますが、ニーズによっては、実行可能で、多くの場合、適切なオプションです。
一般的なエンティティの読み取り:
[DataServiceKey("PartitionKey", "RowKey")]
public class GenericEntity
{
public string PartitionKey { get; set; }
public string RowKey { get; set; }
Dictionary<string, object> properties = new Dictionary<string, object>();
internal object this[string key]
{
get
{
return this.properties[key];
}
set
{
this.properties[key] = value;
}
}
public override string ToString()
{
// TODO: append each property
return "";
}
}
void TestGenericTable()
{
var ctx = CustomerDataContext.GetDataServiceContext();
ctx.IgnoreMissingProperties = true;
ctx.ReadingEntity += new EventHandler<ReadingWritingEntityEventArgs>(OnReadingEntity);
var customers = from o in ctx.CreateQuery<GenericTable>(CustomerDataContext.CustomersTableName) select o;
Console.WriteLine("Rows from '{0}'", CustomerDataContext.CustomersTableName);
foreach (GenericEntity entity in customers)
{
Console.WriteLine(entity.ToString());
}
}
// Credit goes to Pablo from ADO.NET Data Service team
public void OnReadingEntity(object sender, ReadingWritingEntityEventArgs args)
{
// TODO: Make these statics
XNamespace AtomNamespace = "http://www.w3.org/2005/Atom";
XNamespace AstoriaDataNamespace = "http://schemas.microsoft.com/ado/2007/08/dataservices";
XNamespace AstoriaMetadataNamespace = "http://schemas.microsoft.com/ado/2007/08/dataservices/metadata";
GenericEntity entity = args.Entity as GenericEntity;
if (entity == null)
{
return;
}
// read each property, type and value in the payload
var properties = args.Entity.GetType().GetProperties();
var q = from p in args.Data.Element(AtomNamespace + "content")
.Element(AstoriaMetadataNamespace + "properties")
.Elements()
where properties.All(pp => pp.Name != p.Name.LocalName)
select new
{
Name = p.Name.LocalName,
IsNull = string.Equals("true", p.Attribute(AstoriaMetadataNamespace + "null") == null ? null : p.Attribute(AstoriaMetadataNamespace + "null").Value, StringComparison.OrdinalIgnoreCase),
TypeName = p.Attribute(AstoriaMetadataNamespace + "type") == null ? null : p.Attribute(AstoriaMetadataNamespace + "type").Value,
p.Value
};
foreach (var dp in q)
{
entity[dp.Name] = GetTypedEdmValue(dp.TypeName, dp.Value, dp.IsNull);
}
}
private static object GetTypedEdmValue(string type, string value, bool isnull)
{
if (isnull) return null;
if (string.IsNullOrEmpty(type)) return value;
switch (type)
{
case "Edm.String": return value;
case "Edm.Byte": return Convert.ChangeType(value, typeof(byte));
case "Edm.SByte": return Convert.ChangeType(value, typeof(sbyte));
case "Edm.Int16": return Convert.ChangeType(value, typeof(short));
case "Edm.Int32": return Convert.ChangeType(value, typeof(int));
case "Edm.Int64": return Convert.ChangeType(value, typeof(long));
case "Edm.Double": return Convert.ChangeType(value, typeof(double));
case "Edm.Single": return Convert.ChangeType(value, typeof(float));
case "Edm.Boolean": return Convert.ChangeType(value, typeof(bool));
case "Edm.Decimal": return Convert.ChangeType(value, typeof(decimal));
case "Edm.DateTime": return XmlConvert.ToDateTime(value, XmlDateTimeSerializationMode.RoundtripKind);
case "Edm.Binary": return Convert.FromBase64String(value);
case "Edm.Guid": return new Guid(value);
default: throw new NotSupportedException("Not supported type " + type);
}
}