Интерфейс 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 для проверки наличия конфликта в строке. В строке с одним или несколькими конфликтами приложение может проитерироваться по столбцам, чтобы найти любые не нулевые значения, которые будут значениями из источника данных, находящимися в конфликте.

Для упрощения навигации по объекту 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);
                      }
                  }
              }
          }
      }