Интерфейс 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);
                      }
                  }
              }
          }
      }