Интерфейс 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, в цикле while используется метод SyncResolver nextConflict. Цикл завершится, когда 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);
                      }
                  }
              }
          }
      }

Поля

UPDATE_ROW_CONFLICT

static final int UPDATE_ROW_CONFLICT

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

См. также:

Постоянные значения поля

DELETE_ROW_CONFLICT

static final int DELETE_ROW_CONFLICT

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

См. также:

Постоянные значения поля

INSERT_ROW_CONFLICT

static final int INSERT_ROW_CONFLICT

Указывает, что произошел конфликт во время попытки объекта RowSet вставить строку в источник данных. Это означает, что строка с тем же первичным ключом, что и вставляемая строка, была вставлена в источник данных с момента последней синхронизации.

См. также:

Постоянные значения поля

NO_ROW_CONFLICT

static final int NO_ROW_CONFLICT

Указывает, что не произошло конфликта при попытке объекта RowSet обновить, удалить или вставить строку в источник данных. Значения в объекте SyncResolver будут содержать только значения null, как указание, что никакая информация не относится к разрешению конфликтов в этой строке.

См. также:

Постоянные значения поля

Методы

getStatus

int getStatus()

Возвращает состояние конфликта текущей строки этого объекта SyncResolver, которое указывает операцию, которую объект RowSet пытался выполнить при возникновении конфликта.

Возвращает:

одно из следующих констант: SyncResolver.UPDATE_ROW_CONFLICT, SyncResolver.DELETE_ROW_CONFLICT, SyncResolver.INSERT_ROW_CONFLICT, или SyncResolver.NO_ROW_CONFLICT

getConflictValue

Object getConflictValue(int index)
                 throws SQLException

Возвращает значение в указанном столбце в текущей строке этого объекта SyncResolver, которое является значением в источнике данных, вызвавшим конфликт.

Параметры:

index - целое число, обозначающее столбец в этой строке этого объекта SyncResolver для получения значения, вызвавшего конфликт

Возвращает:

значение указанного столбца в текущей строке этого объекта SyncResolver

Исключения:

SQLException - если произошла ошибка доступа к базе данных

getConflictValue

Object getConflictValue(String columnName)
                 throws SQLException

Возвращает значение в указанном столбце в текущей строке этого объекта SyncResolver, которое является значением в источнике данных, вызвавшим конфликт.

Параметры:

columnName - объект String, обозначающий столбец в этой строке этого объекта SyncResolver для получения значения, вызвавшего конфликт

Возвращает:

значение указанного столбца в текущей строке этого объекта SyncResolver

Исключения:

SQLException - если произошла ошибка доступа к базе данных

setResolvedValue

void setResolvedValue(int index,
                      Object obj)
               throws SQLException

Устанавливает obj в качестве значения в столбце index в текущей строке объекта RowSet, который синхронизируется. obj устанавливается как значение в источнике данных внутри.

Параметры:

index - целое число, определяющее номер столбца, в который установить значение для сохранения

obj - объект, являющийся значением, которое необходимо установить в объекте RowSet и сохранить в источнике данных

Исключения:

SQLException - если произошла ошибка доступа к базе данных

setResolvedValue

void setResolvedValue(String columnName,
                      Object obj)
               throws SQLException

Устанавливает obj в качестве значения в столбце columnName в текущей строке объекта RowSet, который синхронизируется. obj устанавливается как значение в источнике данных внутри.

Параметры:

columnName - объект String, указывающий имя столбца, в который установить значение для сохранения

obj - объект, являющийся значением, которое необходимо установить в объекте RowSet и сохранить в источнике данных

Исключения:

SQLException - если произошла ошибка доступа к базе данных

nextConflict

boolean nextConflict()
              throws SQLException

Возвращает:

true если новая текущая строка допустима; false если больше нет строк

Исключения:

SQLException - если произошла ошибка доступа к базе данных или тип набора результатов TYPE_FORWARD_ONLY

previousConflict

boolean previousConflict()
                  throws SQLException

Возвращает:

true если курсор находится на допустимой строке; false если он вне набора результатов

Исключения:

SQLException - если произошла ошибка доступа к базе данных или тип набора результатов TYPE_FORWARD_ONLY