Интерфейс SyncResolver

public interface SyncResolver extends RowSet

Определяет фреймворк, который позволяет приложениям использовать древовидную структуру решений для определения действий при возникновении конфликта синхронизации. Хотя приложениям не обязательно вручную разрешать конфликты синхронизации, этот фреймворк предоставляет средства для делегирования этой задачи при возникновении конфликтов.

Обратите внимание, что конфликт возникает, когда исходные значения объекта RowSet для строки не совпадают со значениями в источнике данных, что указывает на то, что строка в источнике данных была изменена после последней синхронизации. Также обратите внимание, что исходные значения объекта RowSet — это значения, которые у него были непосредственно перед последней синхронизацией, и они не обязательно являются его начальными значениями.

Описание объекта SyncResolver

Объект SyncResolver — это специализированный объект RowSet, реализующий интерфейс SyncResolver. Он может работать как подключенный объект RowSet (реализация интерфейса JdbcRowSet) или как подключенный объект RowSet (реализация интерфейса CachedRowSet или одного из его подинтерфейсов). Сведения о подинтерфейсах см. в описании пакета javax.sql.rowset. Реализация по умолчанию для SyncResolver реализует интерфейс CachedRowSet, но другие реализации могут выбрать реализацию интерфейса JdbcRowSet для удовлетворения конкретных потребностей.

После того, как приложение попыталось синхронизировать объект RowSet с источником данных (вызвав метод CachedRowSet acceptChanges) и было обнаружено одно или несколько конфликтов, объект SyncProvider набора строк создает экземпляр SyncResolver. Этот новый объект SyncResolver имеет такое же количество строк и столбцов, что и объект RowSet, который пытался выполнить синхронизацию. Объект SyncResolver содержит значения из источника данных, вызвавшие конфликт(ы), а также null для всех остальных значений. Кроме того, он содержит информацию о каждом конфликте.

Получение и использование объекта SyncResolver

Когда метод acceptChanges обнаруживает конфликты, объект SyncProvider создает объект SyncProviderException и устанавливает его со значением нового объекта SyncResolver. Метод acceptChanges будет выбрасывать это исключение, которое приложение может перехватить и использовать для получения содержащегося в нем объекта SyncResolver. Следующий фрагмент кода использует метод SyncProviderException getSyncResolver для получения объекта SyncResolver resolver.

  catch (SyncProviderException spe) {
         SyncResolver resolver = spe.getSyncResolver();
     ...
     }

 }
 

Имея resolver, приложение может использовать его для получения информации о конфликте или конфликтах. Объект SyncResolver, такой как resolver, отслеживает конфликты для каждой строки с конфликтом. Он также блокирует таблицу или таблицы, затронутые командой набора строк, чтобы предотвратить возникновение новых конфликтов во время разрешения текущих.

Следующие виды информации можно получить из объекта SyncResolver:

Какая операция выполнялась при возникновении конфликта

Интерфейс SyncProvider определяет четыре константы, описывающие возможные состояния. Три константы описывают тип операции (обновление, удаление или вставка), которую объект RowSet пытался выполнить при обнаружении конфликта, а четвёртая указывает отсутствие конфликта. Эти константы являются возможными значениями возврата, когда объект SyncResolver вызывает метод getStatus.

     int operation = resolver.getStatus(); 
 

Значение в источнике данных, вызвавшее конфликт

Конфликт возникает, когда значение, которое изменил объект RowSet и пытается записать в источник данных, также было изменено в источнике данных после последней синхронизации. Приложение может вызвать метод SyncResolver getConflictValue для получения значения в источнике данных, являющегося причиной конфликта, поскольку значения в объекте SyncResolver — это значения конфликта из источника данных.

     java.lang.Object conflictValue = resolver.getConflictValue(2);
 

Обратите внимание, что столбец в resolver можно указать по номеру столбца, как это сделано в предыдущей строке кода, или по имени столбца.

Имея информацию, полученную из методов getStatus и getConflictValue, приложение может определить, какое значение следует сохранить в источнике данных. Затем приложение вызывает метод SyncResolver setResolvedValue, который устанавливает значение, подлежащее сохранению, в объекте RowSet и также в источнике данных.

     resolver.setResolvedValue("DEPT", 8390426);
 

В предыдущей строке кода имя столбца обозначает столбец в объекте RowSet, который нужно установить указанным значением. Номер столбца также можно использовать для обозначения столбца.

Приложение вызывает метод setResolvedValue после разрешения всех конфликтов в текущей строке конфликта и повторяет этот процесс для каждой строки конфликта в объекте SyncResolver.

Навигация по объекту SyncResolver

Поскольку объект SyncResolver является объектом RowSet, приложение может использовать все методы RowSet для перемещения курсора для навигации по объекту SyncResolver. Например, приложение может использовать метод RowSet next, чтобы перейти к каждой строке, а затем вызвать метод SyncResolver getStatus, чтобы определить, содержит ли строка конфликт. В строке с одним или несколькими конфликтами приложение может проитерировать по столбцам, чтобы найти любые значения, отличные от null, которые будут являться значениями из источника данных, находящимися в конфликте.

Для упрощения навигации по объекту SyncResolver, особенно когда есть большое количество строк без конфликтов, интерфейс SyncResolver определяет методы nextConflict и previousConflict, которые перемещаются только в строки, содержащие по крайней мере одно значение конфликта. Затем приложение может вызвать метод SyncResolver getConflictValue, передав ему номер столбца, чтобы получить само значение конфликта. Фрагмент кода в следующем разделе приводит пример.

Пример кода

Следующий фрагмент кода демонстрирует, как отключенный объект RowSet crs может попытаться синхронизироваться с базовым источником данных, а затем разрешить конфликты. В блоке try crs вызывает метод acceptChanges, передавая ему объект Connection con. Если конфликтов нет, изменения в crs просто записываются в источник данных. Однако если конфликт есть, метод acceptChanges выбрасывает объект SyncProviderException, и срабатывает блок catch. В этом примере, иллюстрирующем один из многих способов использования объекта SyncResolver, метод SyncResolver nextConflict используется в цикле while. Цикл завершится, когда nextConflict вернёт false, что произойдёт, когда в объекте SyncResolver resolver больше нет строк конфликтов. В этом конкретном фрагменте кода resolver ищет строки с конфликтами обновлений (строки со статусом SyncResolver.UPDATE_ROW_CONFLICT), и остальная часть этого фрагмента кода выполняется только для строк, где конфликты возникли, потому что crs пытался выполнить обновление.

После того, как курсор для resolver переместился на следующую строку конфликта с конфликтом обновления, метод getRow указывает номер текущей строки, и курсор для объекта CachedRowSet crs перемещается в сопоставимую строку в crs. Итерируя по столбцам этой строки как в resolver, так и в crs, можно получить и сравнить значения конфликтов, чтобы решить, какое из них следует сохранить. В этом фрагменте кода значение в crs устанавливается как разрешённое значение, что означает, что оно будет использоваться для перезаписи значения конфликта в источнике данных.

 
     try {

         crs.acceptChanges(con);

     } catch (SyncProviderException spe) {

         SyncResolver resolver = spe.getSyncResolver();

         Object crsValue;  // value in the RowSet object
         Object resolverValue:  // value in the SyncResolver object
         Object resolvedValue:  // value to be persisted

         while(resolver.nextConflict())  {
             if(resolver.getStatus() == SyncResolver.UPDATE_ROW_CONFLICT)  {
                 int row = resolver.getRow();
                 crs.absolute(row);

                 int colCount = crs.getMetaData().getColumnCount();
                 for(int j = 1; j <= colCount; j++) {
                     if (resolver.getConflictValue(j) != null)  {
                         crsValue = crs.getObject(j);
                         resolverValue = resolver.getConflictValue(j);
                         . . .
                         // compare crsValue and resolverValue to determine
                         // which should be the resolved value (the value to persist)
                         resolvedValue = crsValue;

                         resolver.setResolvedValue(j, resolvedValue);
                      }
                  }
              }
          }
      }