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