3

カレンダーアプリケーションは、予定ドメインを次のように表します。

予定

  • ID(PK)
  • StartDateTime
  • EndDateTime
  • ..。

AppointmentRole

  • AppointmentID(FK)
  • PersonOrGroupID(FK)/ *この質問の範囲外で、個人/グループに参加します* /
  • 役割
  • ..。

Appointmentは、AppointmentRolesと1対多の関係があります。各AppointmentRoleは、特定の役割(ドロップオフ、ピックアップ、出席など)の個人またはグループを表します。

この関係には2つの目的があります。

  1. アクセス制御リストを定義します-認証されたプリンシパルは、アクセス制御リストが関連する個人またはグループと一致する場合にのみ予定を表示できます
  2. 誰がその予定に出席し、どのような役割を果たしているかを文書化します。

アポイントメントに関連するメモ/コメントを追跡するための3番目のテーブルもあります。それは、アポイントメントとの1対多の関係の多くの側面にあります。

AppointmentNote

  • AppointmentID(FK)
  • ..。

予定のカレンダーを表示するために、現在、次のようなものを使用しています...

List<IAppointment> GetAppointments(IAccess acl, DateTime start, DateTime end, ...
{
  // Retrieve distinct appointments that are visible to the acl

  var visible = (from appt in dc.Appointments
                 where !(appt.StartDateTime >= end || appt.EndDateTime <= start)
                 join role in
                   (from r in dc.Roles
                    where acl.ToIds().Contains(r.PersonOrGroupID)
                    select new { r.AppointmentID })
                 on appt.ID equals role.AppointmentID
                 select new
                 {
                   ...
                 }).Distinct();

  ...

表示されるLinq式は、指定されたアクセス制御リストで表示できる個別の予定を選択します。

以下では、アポイントメントとアポイントメントノートに関係するすべての人々とグループをピックアップするために、目に見える役割メモに参加/参加します。

  ...

  // Join/into to get all appointment roles and notes

  var q = from appt in visible
          orderby appt.StartDateTime, ...
          join r in dc.Roles
          on appt.ID equals r.AppointmentID
          into roles
          join note in dc.AppointmentNotes
          on appt.ID equals note.AppointmentID
          into notes
          select new { Appointment = appt, Roles = roles, Notes = notes };

最後に、Linq-To-Sqlが1つの非常に最適化されたクエリを生成することを期待してクエリを列挙します(後で説明するような運はありません)...

  // Marshal the anonymous type into an IAppointment
  // IAppointment has a Roles and Notes collection

  var result = new List<IAppointment>();
  foreach (var record in q)
  {
    IAppointment a = new Appointment();
    a.StartDateTime = record.StartDateTime;
    ...
    a.Roles = Marshal(record.Roles);
    a.Notes = Marshal(record.Notes);

    result.Add(a);
  }

Linq-to-Sqlによって生成されたクエリは非常におしゃべりです。表示されている予定を判別するための単一のクエリを生成します。ただし、各反復で3つのクエリが生成されます。1つは予定フィールドを取得し、2つ目は役割を取得し、3つ目はメモを取得します。where句は、常に表示される予定IDです。

そのため、GetAppointmentsをリファクタリングしており、SOコミュニティの専門知識から利益を得ることができると考えています。

すべてをT-SQLストアドプロシージャに移動して、より詳細に制御できるようにすることを期待しています。この問題にどのように取り組むかについてのあなたの考えを共有できますか?データモデルの変更、T-SQLおよびLinqからSQLへの変更はすべて公正なゲームです。インデックスについてもアドバイスをお願いします。MS-SqlServer2008と.NET4.0を使用しています。

4

3 に答える 3

3

私はすべての悪の根源はここから始まると言うでしょう:

where acl.ToIds().Contains(r.PersonOrGroupID) 

これacl.ToIds().Contains(...)はサーバー側では解決できない式であるため、visibleクエリはクライアント側で(非常に非効率的に)解決する必要があります。さらに悪いことに、結果はクライアントに保持する必要があります。表示されている予定(予定フィールド、役割、メモ)ごとに、個別のクエリをサーバーに送信する必要があります。自分のやり方があれば、ACLリストをテーブル値パラメーターとして受け入れ、サーバー側ですべての結合/フィルタリングを実行するストアドプロシージャを作成します。

私はこのスキーマから始めます:

create table Appointments (
    AppointmentID int not null identity(1,1),
    Start DateTime not null,
    [End] DateTime not null,
    Location varchar(100),
    constraint PKAppointments
        primary key nonclustered (AppointmentID));

create table AppointmentRoles (
    AppointmentID int not null,
    PersonOrGroupID int not null,
    Role int not null,
    constraint PKAppointmentRoles
        primary key (PersonOrGroupID, AppointmentID), 
    constraint FKAppointmentRolesAppointmentID
        foreign key (AppointmentID)
        references Appointments(AppointmentID));

create table AppointmentNotes (
    AppointmentID int not null,
    NoteId int not null,
    Note varchar(max),

    constraint PKAppointmentNotes
        primary key (AppointmentID, NoteId),
    constraint FKAppointmentNotesAppointmentID
        foreign key (AppointmentID)
        references Appointments(AppointmentID));
go

create clustered index cdxAppointmentStart on Appointments (Start, [End]);
go

そして、次のように任意のACLの予定を取得します。

create type AccessControlList as table 
    (PersonOrGroupID int not null);
go

create procedure usp_getAppointmentsForACL
 @acl AccessControlList readonly,
 @start datetime,
 @end datetime
as
begin
    set nocount on;
    select a.AppointmentID
        , a.Location
        , r.Role
        , n.NoteID
        , n.Note
    from @acl l 
    join AppointmentRoles r on l.PersonOrGroupID = r.PersonOrGroupID
    join Appointments a on r.AppointmentID = a.AppointmentID
    join AppointmentNotes n on n.AppointmentID = a.AppointMentID
    where a.Start >= @start
    and a.[End] <= @end;    
end
go

100万の予定でこれを試してみましょう。まず、テーブルにデータを入力します(約4〜5分かかります)。

set nocount on;
declare @i int = 0;
begin transaction;
while @i < 1000000
begin
    declare @start datetime, @end datetime;
    set @start = dateadd(hour, rand()*10000-5000, getdate());
    set @end = dateadd(hour, rand()*100, @start)
    insert into Appointments (Start, [End], Location)
    values (@start, @end, replicate('X', rand()*100));

    declare @appointmentID int = scope_identity();
    declare @atendees int = rand() * 10.00 + 1.00;
    while @atendees > 0
    begin
        insert into AppointmentRoles (AppointmentID, PersonOrGroupID, Role)
        values (@appointmentID, @atendees*100 + rand()*100, rand()*10);
        set @atendees -= 1;
    end

    declare @notes int = rand()*3.00;
    while @notes > 0
    begin
        insert into AppointmentNotes (AppointmentID, NoteID, Note)
        values (@appointmentID, @notes, replicate ('Y', rand()*1000));
        set @notes -= 1;
    end

    set @i += 1;
    if @i % 10000 = 0
    begin
        commit;
        raiserror (N'Added %i appointments...', 0, 1, @i);
        begin transaction;
    end
end
commit;
go

それでは、今日の数人の予定を見てみましょう。

set statistics time on;
set statistics io on;

declare @acl AccessControlList;
insert into @acl (PersonOrGroupID) values (102),(111),(131);
exec usp_getAppointmentsForACL @acl, '20100730', '20100731';

Table 'AppointmentNotes'. Scan count 8, logical reads 39, physical reads 0, read-ahead reads 0, lob logical reads 0, lob physical reads 0, lob read-ahead reads 0.
Table 'Worktable'. Scan count 0, logical reads 0, physical reads 0, read-ahead reads 0, lob logical reads 0, lob physical reads 0, lob read-ahead reads 0.
Table 'Appointments'. Scan count 1, logical reads 9829, physical reads 0, read-ahead reads 0, lob logical reads 0, lob physical reads 0, lob read-ahead reads 0.
Table 'AppointmentRoles'. Scan count 3, logical reads 96, physical reads 0, read-ahead reads 0, lob logical reads 0, lob physical reads 0, lob read-ahead reads 0.
Table '#25869641'. Scan count 1, logical reads 1, physical reads 0, read-ahead reads 0, lob logical reads 0, lob physical reads 0, lob read-ahead reads 0.

 SQL Server Execution Times:
   CPU time = 63 ms,  elapsed time = 1294 ms.

 SQL Server Execution Times:
   CPU time = 63 ms,  elapsed time = 1294 ms.

1.2秒(コールドキャッシュでは、ウォームキャッシュでは224ミリ秒になります)。うーん、それはあまり良くありません。問題は、予定表でヒットした9829ページです。これを改善するために、両方のフィルタリング基準(aclとdate)を同時に使用したいと思います。おそらくインデックス付きのビューですか?

create view vwAppointmentAndRoles 
with schemabinding
as
select r.PersonOrGroupID, a.AppointmentID, a.Start, a.[End]
from dbo.AppointmentRoles r
join dbo.Appointments a on r.AppointmentID = a.AppointmentID;
go

create unique clustered index cdxVwAppointmentAndRoles on vwAppointmentAndRoles (PersonOrGroupID, Start, [End]);
go

alter procedure usp_getAppointmentsForACL
 @acl AccessControlList readonly,
 @start datetime,
 @end datetime
as
begin
    set nocount on;
    select ar.AppointmentID
        , a.Location
        , r.Role
        , n.NoteID
        , n.Note
    from @acl l 
    join vwAppointmentAndRoles ar with (noexpand) on l.PersonOrGroupID = ar.PersonOrGroupID
    join AppointmentNotes n on n.AppointmentID = ar.AppointMentID
    join Appointments a on ar.AppointmentID = a.AppointmentID
    join AppointmentRoles r 
        on ar.AppointmentID = r.AppointmentID
        and ar.PersonOrGroupID = r.PersonOrGroupID
    where ar.Start >= @start
     and ar.Start <= @end
    and ar.[End] <= @end;   
end
go

Appointmentsのクラスター化されたインデックスをおそらくより有用なAppointmentIDに変更することもできます。

drop index cdxAppointmentStart on Appointments;
create clustered index cdxAppointmentAppointmentID on Appointments (AppointmentID);
go

これにより、77msの同じ日付範囲の同じ@aclリスト内の予定が返されます(ウォームキャッシュ上)。

もちろん、実際に使用するスキーマは、考慮されていない多くの要因によって異なります。しかし、これにより、適切なパフォーマンスを得るために今取るべき適切なアクションについてのアイデアが得られたことを願っています。テーブル値パラメーターをクライアント実行コンテキストに追加してプロシージャに渡すこと、およびLINQ統合は、読者の演習として残されています。

于 2010-08-01T21:28:17.247 に答える
2

私が正しく理解し、のコレクションとのAppointmentコレクションを持っている場合。これが当てはまる場合(そしてこれをデザイナで正しくモデル化した場合)、これらとプロパティがクラスにあります。クエリのプロジェクション()を変更してそれ自体を選択すると、LINQtoSQLが以下のコレクションを取得できるようになります。その場合、次のようにクエリを作成する必要があります。RolesNotesRolesNotesAppointmentselectqAppointment

var q =
    from appt in visible
    ...
    select appt;

LoadOptionsこの後、のプロパティを使用してDataContext、次のようにサブコレクションをプリフェッチできます。

using (var db = new AppointmentContext())
{
    db.LoadOptions.LoadWith<Appointment>(a => a.Roles);

    // Do the rest here
}

LoadWithただし、ここでの1つの問題は、が2つではなく1つのサブコレクションをロードするように制限されていると思うことです。

これは、2つのクエリで書き出すことで解決できます。最初のクエリは、予定を取得し、それを使用LoadWithしてすべてを取得することRolesでした。DataContext次に、(newで)2番目のクエリを使用し、を使用LoadWithしてすべてをフェッチしますNotes)。

幸運を。

于 2010-08-01T20:04:09.117 に答える
1
where !(appt.StartDateTime >= end || appt.EndDateTime <= start)

これは完全に良いAND基準である可能性があります。

where appt.StartDateTime < end && start < appt.EndDateTime

acl.ToIds().

これをクエリから引き出します。データベースに操作を実行するように依頼しても意味がありません。

List<int> POGIDs = acl.ToIds();

join role in

ロールをフィルターとして使用したい。参加する代わりに、後で区別する必要はありません。


DataLoadOptionsの有無にかかわらず、これを試してください。DataLoadOptionsがなくてもクエリが適切な場合は、関連する行をロードする別の(より手動の)方法があります。

DataLoadOptions myOptions = new DataLoadOptions();
myOptions.LoadWith<Appointment>(appt => appt.Roles);
myOptions.LoadWith<Appointment>(appt => appt.Notes);
dc.LoadOptions = myOptions;


List<int> POGIDs = acl.ToIds();

IQueryable<Roles> roleQuery = dc.Roles
  .Where(r => POGIDs.Contains(r.PersonOrGroupId));

IQueryable<Appointment> visible =
  dc.Appointments
    .Where(appt => appt.StartDateTime < end && start < appt.EndDateTime)
    .Where(appt => appt.Roles.Any(r => roleQuery.Contains(r));

IQueryable<Appointment> q =
  visible.OrderBy(appt => appt.StartDateTime);

List<Appointment> rows = q.ToList();

関連データをフェッチする「より手動の」方法は次のとおりです。注:この手法は、apptIdまたはPOGIDに最大2100intを超える場合に機能しなくなります。それを回避する方法もあります...

List<int> POGIDs = acl.ToIds();

List<Role> visibleRoles = dc.Roles
  .Where(r => POGIDs.Contains(r.PersonOrGroupId)
  .ToList()

List<int> apptIds = visibleRoles.Select(r => r.AppointmentId).ToList();

List<Appointment> appointments = dc.Appointments
  .Where(appt => appt.StartDateTime < end && start < appt.EndDate)
  .Where(appt => apptIds.Contains(appt.Id))
  .OrderBy(appt => appt.StartDateTime)
  .ToList();

ILookup<int, Roles> appointmentRoles = dc.Roles
  .Where(r => apptIds.Contains(r.AppointmentId))
  .ToLookup(r => r.AppointmentId);

ILookup<int, Notes> appointmentNotes = dc.AppointmentNotes
  .Where(n => apptIds.Contains(n.AppointmentId));
  .ToLookup(n => n.AppointmentId);

foreach(Appointment record in appointments)
{
  int key = record.AppointmentId;
  List<Roles> theRoles = appointmentRoles[key].ToList();
  List<Notes> theNotes = appointmentNotes[key].ToList();
}

このスタイルは、インデックスが必要な場所を強調します。

Roles.PersonOrGroupId
Appointments.AppointmentId (should be PK already)
Roles.AppointmentId
Notes.AppointmentId
于 2010-08-02T10:23:32.147 に答える