javax.sql.rowset.spi

Интерфейсный SyncResolver

Все Суперинтерфейсы:

AutoCloseable, ResultSet, RowSet, Обертка

public interface SyncResolver
extends RowSet

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

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

Описание a SyncResolver Объект

A SyncResolver объект является специализированным RowSet возразите что реализации SyncResolver интерфейс. Это может работать как любой соединенный RowSet объект (реализация JdbcRowSet интерфейс) или соединенный RowSet объект (реализация CachedRowSet взаимодействуйте через интерфейс или один из его подынтерфейсов). Для получения информации о подынтерфейсах см. javax.sql.rowset описание пакета. Ссылочная реализация для SyncResolver реализации CachedRowSet интерфейс, но другие реализации может хотеть реализовывать JdbcRowSet интерфейс, чтобы удовлетворить определенные потребности.

После того, как приложение попыталось синхронизировать a RowSet объект с источником данных (вызывая CachedRowSet метод acceptChanges), и один или более конфликтов были найдены, набор строк SyncProvider объект создает экземпляр SyncResolver. Это новое SyncResolver у объекта есть то же самое число строк и столбцов как RowSet объект, который делал попытку синхронизации. SyncResolver объект содержит значения от источника данных, который вызвал конфликт (ы) и null для всех других значений. Кроме того, это содержит информацию о каждом конфликте.

Получение и Используя a SyncResolver Объект

Когда метод acceptChanges встречается с конфликтами, SyncProvider объект создает a SyncProviderException объект и наборы это с новым SyncResolver объект. Метод acceptChanges выдаст это исключение, которое приложение может тогда поймать и использовать, чтобы получить SyncResolver объект это содержит. Следующий фрагмент кода использует SyncProviderException метод getSyncResolver добраться SyncResolver объектный преобразователь.

     } catch (SyncProviderException spe) {
         SyncResolver resolver = spe.getSyncResolver();
     ...
     }
 

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

Следующие виды информации могут быть получены из a SyncResolver объект:

Какая работа предпринималась, когда конфликт произошел
SyncProvider интерфейс определяет четыре константы, описывающие состояния, которые могут произойти. Три константы описывают тип работы (обновление, удалите, или вставьте), это a RowSet объект пытался выполнить, когда конфликт был обнаружен, и четвертое указывает, что нет никакого конфликта. Эти константы являются возможными возвращаемыми значениями когда a SyncResolver возразите вызывает метод getStatus.

     int operation = resolver.getStatus();
 

Значение в источнике данных, который вызвал конфликт
Конфликт существует когда значение это a RowSet объект изменился и пытается записать в источник данных, был также изменен в источнике данных начиная с последней синхронизации. Приложение может вызвать SyncResolver метод getConflictValue получать значение в источнике данных, который является причиной конфликта потому что значения в a SyncResolver объект является значениями конфликта от источника данных.

     java.lang.Object conflictValue = resolver.getConflictValue(2);
 

Отметьте, что столбец в преобразователе может определяться номером столбца, как делается в предыдущей строке кода, или именем столбца.

С информацией, полученной от методов getStatus и getConflictValue, приложение может сделать определение, относительно которого значение должно быть сохранено в источнике данных. Приложение тогда вызывает SyncResolver метод setResolvedValue, который устанавливает значение, которое будет сохранено в RowSet возразите и также в источнике данных.

     resolver.setResolvedValue("DEPT", 8390426);
 

В предыдущей строке кода имя столбца определяет столбец в RowSet объект, который должен быть установлен с данным значением. Номер столбца может также использоваться, чтобы определять столбец.

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

Навигация a SyncResolver Объект

Поскольку a SyncResolver объект является a RowSet объект, приложение может использовать весь из RowSet методы для того, чтобы переместить курсор, чтобы переместиться по a SyncResolver объект. Например, приложение может использовать RowSet метод next добраться до каждой строки и затем вызвать SyncResolver метод getStatus видеть, содержит ли строка конфликт. Подряд с одним или более конфликтами, приложение может выполнить итерации через столбцы, чтобы найти любые ненулевые значения, которые будут значениями от источника данных, которые находятся в конфликте.

Облегчить перемещаться по a SyncResolver объект, особенно когда есть большие количества строк без конфликтов, SyncResolver интерфейс определяет методы nextConflict и previousConflict, которые перемещаются только в строки, которые содержат по крайней мере одно значение конфликта. Затем приложение может вызвать SyncResolver метод getConflictValue, предоставление этого с номером столбца, чтобы получить конфликт ценят себя. Фрагмент кода в следующем разделе дает пример.

Пример кода

Следующий фрагмент кода демонстрирует как разъединенный RowSet объект crs мог бы попытаться синхронизировать себя с базовым источником данных и затем разрешить конфликты. В try блок, crs вызывает метод acceptChanges, передача этого Connection объектный довод "против". Если нет никаких конфликтов, изменения в crs просто пишутся источнику данных. Однако, если есть конфликт, метод acceptChanges броски a SyncProviderException объект, и catch блок вступает в силу. В этом примере, который иллюстрирует один из многих путей a SyncResolver объект может использоваться, SyncResolver метод nextConflict используется в a while цикл. Цикл закончится когда nextConflict возвраты false, который произойдет, когда не будет больше строк конфликта в SyncResolver объектный преобразователь. В Этом определенном фрагменте кода преобразователь ищет строки, у которых есть конфликты обновления (строки с состоянием SyncResolver.UPDATE_ROW_CONFLICT), и остальная часть этого фрагмента кода выполняется только для строк, где конфликты произошли, потому что crs делал попытку обновления.

После того, как курсор для преобразователя переместился в следующую строку конфликта, у которой есть конфликт обновления, метод getRow указывает на число текущей строки, и курсор для CachedRowSet объект crs перемещается в сопоставимую строку в crs. Выполняя итерации через столбцы той строки и в преобразователе и в 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);
                      }
                  }
              }
          }
      }