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