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