2014年02月11日
川俣晶の縁側ソフトウェア技術雑記 total 6684 count

Azureのストレージにバッジ追加削除するクラス

Written By: 川俣 晶連絡先

「別にどうってことはないが、YamatoDriveに追加したクラスだ」

「なんで追加したの?」

「大量のレコードを一括追加すると遅くて叶わないから」

「1個ずつ追加して結果として大量に溜まった時には気にならなかった処理時間ってことだね」

「うむ。ローカルデータを一括追加するような処理を作成していて気になった問題だ」

「それで、バッチで登録すると早くなる?」

「なるなる。1個ずつより100個ずつ」

「なんで100個なの?」

「APIの制約が100個だから」

public class StorageTableBatchUpdate<T> : IDisposable where T : ITableEntity, new()

{

    private CloudTable tbl;

    private TableBatchOperation tbo = new TableBatchOperation();

    private const int limit = 100;

    public TableQuery<T> Query

    {

        get { return tbl.CreateQuery<T>(); }

    }

    public void AddObject(T targetToAdd)

    {

        exec(TableOperation.InsertOrReplace(targetToAdd));

    }

    public void UpdateObject(T targetToUpdate)

    {

        exec(TableOperation.Replace(targetToUpdate));

    }

    public void DeleteObject(T found)

    {

        exec(TableOperation.Delete(found));

    }

    public StorageTableBatchUpdate(StorageTable<T> table)

    {

        tbl = Util.CTC.GetTableReference(table.TableName);

    }

    private void exec(TableOperation op)

    {

        tbo.Add(op);

        if (tbo.Count() >= limit) exec();

    }

    private void exec()

    {

        tbl.ExecuteBatch(tbo);

        tbo.Clear();

    }

    public void Dispose()

    {

        if (tbo.Count() > 0) exec();

    }

}