Кто-нибудь здесь работал с Sync Framework и синхронизировал его через конечные точки WCF? Просьба поделиться образцами кода или примерами проектов. Я специально ищу сценарии офлайн, где клиент приходит в Интернет только для получения обновлений с сервера.
Синхронизация баз данных SQL Server 2008 через HTTP с использованием инфраструктуры WCF и Sync
Ответ 1
Я сделал следующее, чтобы заставить Sync Framework работать с WCF с SQL Server 2008
- Включено отслеживание изменений в SQL Server 2008
- Включено отслеживание изменений для таблиц, участвующих в синхронизации
- Добавлена таблица метаданных с именем anchor
- Добавлена таблица для отслеживания идентификаторов клиентов с именем "guid"
- Используется SqlExpressClientSyncProvider, доступный с сайта проекта MSF codeplex в качестве поставщика синхронизации клиентов.
-
Используется SqlSyncAdapterBuilder для создания адаптеров для таблиц, участвующих в синхронизации
foreach (var item in anchorTables) { // Use adapter builder to generate T-SQL for querying change tracking data and CRUD SqlSyncAdapterBuilder builder = new SqlSyncAdapterBuilder(); builder.Connection = new SqlConnection(this.connectionStringFactory.ConnectionString); builder.ChangeTrackingType = ChangeTrackingType.SqlServerChangeTracking; builder.SyncDirection = SyncDirection.Bidirectional; builder.TableName = item.TableName; // Get sync adapters from builder SyncAdapter clientAdapter = builder.ToSyncAdapter(); clientAdapter.TableName = item.TableName; this.clientSyncProvider.SyncAdapters.Add(clientAdapter); }
-
Добавлены команды привязки
SqlCommand anchroCommand = new SqlCommand { CommandText = "SELECT @" + SyncSession.SyncNewReceivedAnchor + " = change_tracking_current_version()" }; anchroCommand.Parameters.Add("@" + SyncSession.SyncNewReceivedAnchor, SqlDbType.BigInt) .Direction = ParameterDirection.Output; this.clientSyncProvider.SelectNewAnchorCommand = anchroCommand;
-
Реализована служба WCF с использованием экземпляра DbServerSyncProvider, функционирующего как поставщик синхронизации сервера. У вас будет генерация адаптеров синхронизации и установка команды привязки, как показано на предыдущем шаге для поставщика сервера.
[ServiceContract] public interface ISyncService { [OperationContract] SyncContext ApplyChanges(SyncGroupMetadata groupMetadata, DataSet dataSet, SyncSession syncSession); [OperationContract] SyncContext GetChanges(SyncGroupMetadata groupMetadata, SyncSession syncSession); [OperationContract] SyncSchema GetSchema(Collection<string> tableNames, SyncSession syncSession); [OperationContract] SyncServerInfo GetServerInfo(SyncSession syncSession); }
-
Создан класс прокси, реализующий ServerSyncProvider для доступа к службе WCF
public class DbServerSyncProviderProxy : ServerSyncProvider { SyncServiceProxy.SyncServiceClient serviceProxy = new SyncServiceProxy.SyncServiceClient(); public override SyncContext ApplyChanges(SyncGroupMetadata groupMetadata, DataSet dataSet, SyncSession syncSession) { return serviceProxy.ApplyChanges(groupMetadata, dataSet, syncSession); } }
- Создал экземпляр SyncAgent и установил RemoteProvider с экземпляром класса proxy, который используется для доступа к службе WCF. LocalProvider устанавливается с экземпляром SqlExpressClientSyncProvider
- Добавлены таблицы и группы синхронизации в конфигурацию SyncAgent
- SyncAgent.Synchronize()