MergePublication.AddMergeDynamicSnapshotJob メソッド
パラメーター化された行フィルターを使用する場合に、フィルター選択されたデータ パーティションをサブスクライバー用に生成する、スナップショット エージェント ジョブを追加します。
名前空間: Microsoft.SqlServer.Replication
アセンブリ: Microsoft.SqlServer.Rmo (Microsoft.SqlServer.Rmo.dll)
構文
'宣言
Public Sub AddMergeDynamicSnapshotJob ( _
mergeDynamicSnapshotJob As MergeDynamicSnapshotJob, _
schedule As ReplicationAgentSchedule _
)
'使用
Dim instance As MergePublication
Dim mergeDynamicSnapshotJob As MergeDynamicSnapshotJob
Dim schedule As ReplicationAgentSchedule
instance.AddMergeDynamicSnapshotJob(mergeDynamicSnapshotJob, _
schedule)
public void AddMergeDynamicSnapshotJob(
MergeDynamicSnapshotJob mergeDynamicSnapshotJob,
ReplicationAgentSchedule schedule
)
public:
void AddMergeDynamicSnapshotJob(
MergeDynamicSnapshotJob^ mergeDynamicSnapshotJob,
ReplicationAgentSchedule^ schedule
)
member AddMergeDynamicSnapshotJob :
mergeDynamicSnapshotJob:MergeDynamicSnapshotJob *
schedule:ReplicationAgentSchedule -> unit
public function AddMergeDynamicSnapshotJob(
mergeDynamicSnapshotJob : MergeDynamicSnapshotJob,
schedule : ReplicationAgentSchedule
)
パラメーター
- mergeDynamicSnapshotJob
型: Microsoft.SqlServer.Replication.MergeDynamicSnapshotJob
フィルター処理されたデータ スナップショット ジョブです。
- schedule
型: Microsoft.SqlServer.Replication.ReplicationAgentSchedule
ジョブに関連付けられているスケジュールです。
説明
AddMergeDynamicSnapshotJob を呼び出すと、sp_adddynamicsnapshot_job を実行したのと同じことになります。
AddMergeDynamicSnapshotJob メソッドを呼び出すことができるのは、パブリッシャー側の固定サーバー ロール sysadmin のメンバー、またはパブリケーション データベースの固定データベース ロール db_owner のメンバーだけです。
使用例
// Define the server, database, and publication names
string publisherName = publisherInstance;
string publicationName = "AdvWorksSalesOrdersMerge";
string publicationDbName = "AdventureWorks2012";
string distributorName = publisherInstance;
MergePublication publication;
MergePartition partition;
MergeDynamicSnapshotJob snapshotAgentJob;
ReplicationAgentSchedule schedule;
// Create a connection to the Publisher.
ServerConnection publisherConn = new ServerConnection(publisherName);
// Create a connection to the Distributor to start the Snapshot Agent.
ServerConnection distributorConn = new ServerConnection(distributorName);
try
{
// Connect to the Publisher.
publisherConn.Connect();
// Set the required properties for the publication.
publication = new MergePublication();
publication.ConnectionContext = publisherConn;
publication.Name = publicationName;
publication.DatabaseName = publicationDbName;
// If we can't get the properties for this merge publication,
// then throw an application exception.
if (publication.LoadProperties() || publication.SnapshotAvailable)
{
// Set a weekly schedule for the filtered data snapshot.
schedule = new ReplicationAgentSchedule();
schedule.FrequencyType = ScheduleFrequencyType.Weekly;
schedule.FrequencyRecurrenceFactor = 1;
schedule.FrequencyInterval = Convert.ToInt32(0x001);
// Set the value of Hostname that defines the data partition.
partition = new MergePartition();
partition.DynamicFilterHostName = hostname;
snapshotAgentJob = new MergeDynamicSnapshotJob();
snapshotAgentJob.DynamicFilterHostName = hostname;
// Create the partition for the publication with the defined schedule.
publication.AddMergePartition(partition);
publication.AddMergeDynamicSnapshotJob(snapshotAgentJob, schedule);
}
else
{
throw new ApplicationException(String.Format(
"Settings could not be retrieved for the publication, " +
" or the initial snapshot has not been generated. " +
"Ensure that the publication {0} exists on {1} and " +
"that the Snapshot Agent has run successfully.",
publicationName, publisherName));
}
}
catch (Exception ex)
{
// Do error handling here.
throw new ApplicationException(string.Format(
"The partition for '{0}' in the {1} publication could not be created.",
hostname, publicationName), ex);
}
finally
{
publisherConn.Disconnect();
if (distributorConn.IsOpen) distributorConn.Disconnect();
}
' Define the server, database, and publication names
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publicationDbName As String = "AdventureWorks2012"
Dim distributorName As String = publisherInstance
Dim publication As MergePublication
Dim partition As MergePartition
Dim snapshotAgentJob As MergeDynamicSnapshotJob
Dim schedule As ReplicationAgentSchedule
' Create a connection to the Publisher.
Dim publisherConn As ServerConnection = New ServerConnection(publisherName)
' Create a connection to the Distributor to start the Snapshot Agent.
Dim distributorConn As ServerConnection = New ServerConnection(distributorName)
Try
' Connect to the Publisher.
publisherConn.Connect()
' Set the required properties for the publication.
publication = New MergePublication()
publication.ConnectionContext = publisherConn
publication.Name = publicationName
publication.DatabaseName = publicationDbName
' If we can't get the properties for this merge publication,
' then throw an application exception.
If (publication.LoadProperties() Or publication.SnapshotAvailable) Then
' Set a weekly schedule for the filtered data snapshot.
schedule = New ReplicationAgentSchedule()
schedule.FrequencyType = ScheduleFrequencyType.Weekly
schedule.FrequencyRecurrenceFactor = 1
schedule.FrequencyInterval = Convert.ToInt32("0x001", 16)
' Set the value of Hostname that defines the data partition.
partition = New MergePartition()
partition.DynamicFilterHostName = hostname
snapshotAgentJob = New MergeDynamicSnapshotJob()
snapshotAgentJob.DynamicFilterHostName = hostname
' Create the partition for the publication with the defined schedule.
publication.AddMergePartition(partition)
publication.AddMergeDynamicSnapshotJob(snapshotAgentJob, schedule)
Else
Throw New ApplicationException(String.Format( _
"Settings could not be retrieved for the publication, " + _
" or the initial snapshot has not been generated. " + _
"Ensure that the publication {0} exists on {1} and " + _
"that the Snapshot Agent has run successfully.", _
publicationName, publisherName))
End If
Catch ex As Exception
' Do error handling here.
Throw New ApplicationException(String.Format( _
"The partition for '{0}' in the {1} publication could not be created.", _
hostname, publicationName), ex)
Finally
publisherConn.Disconnect()
If distributorConn.IsOpen Then
distributorConn.Disconnect()
End If
End Try
関連項目
参照
Microsoft.SqlServer.Replication 名前空間
その他の技術情報
パラメーター化されたフィルターを使用してマージ パブリケーションのスナップショットを作成する方法 (RMO プログラミング)
パラメーター化されたフィルターを使用してマージ パブリケーションのパーティションを管理する方法 (RMO プログラミング)