Интерфейс CachedRowSet

public interface CachedRowSet extends RowSet, Joinable

Интерфейс, который должны реализовывать все стандартные реализации CachedRowSet.

Эталонная реализация интерфейса CachedRowSet, предоставляемая корпорацией Oracle, является стандартной реализацией. Разработчики могут использовать эту реализацию без изменений, расширять её или создавать собственные реализации этого интерфейса.

Объект CachedRowSet — это контейнер строк данных, кэшируемых в памяти, что позволяет работать с ним, не поддерживая постоянное подключение к источнику данных. Кроме того, это компонент JavaBeans, поддерживающий прокрутку, обновление и сериализацию. Объект CachedRowSet обычно содержит строки из результирующего набора, но также может содержать строки из любого файла с табличным форматом, например электронной таблицы. Эталонная реализация поддерживает получение данных только из объекта ResultSet, однако разработчики могут расширить реализации SyncProvider, чтобы обеспечить доступ к другим табличным источникам данных.

Приложение может изменять данные в объекте CachedRowSet, а затем эти изменения могут быть переданы обратно в источник данных.

Объект CachedRowSet — это отключённый набор строк, то есть он использует подключение к источнику данных лишь в течение короткого времени. Он подключается к источнику данных при чтении данных для заполнения строк, а затем снова — при передаче изменений в базовый источник данных. В остальное время объект CachedRowSet отключён, в том числе и при изменении его данных. Благодаря отключению объект RowSet становится значительно легче и его гораздо проще передавать другому компоненту. Например, отключённый объект RowSet можно сериализовать и передать по сети тонкому клиенту, например персональному цифровому помощнику (PDA).

1.0 Создание объекта CachedRowSet

Следующая строка кода использует конструктор по умолчанию для CachedRowSet, предоставляемый эталонной реализацией (RI), чтобы создать объект CachedRowSet со значениями по умолчанию.

    CachedRowSetImpl crs = new CachedRowSetImpl();

У этого нового объекта CachedRowSet будут заданы свойства по умолчанию объекта BaseRowSet, а также объект RIOptimisticProvider в качестве поставщика синхронизации. RIOptimisticProvider — одна из двух реализаций SyncProvider, включённых в RI; это поставщик по умолчанию, который предоставит синглтон SyncFactory, если поставщик синхронизации не указан.

Объект SyncProvider предоставляет объекту CachedRowSet средство чтения (объект RowSetReader) для чтения данных из источника данных и заполнения ими объекта. Средство чтения можно реализовать для чтения данных из объекта ResultSet или из файла с табличным форматом. Объект SyncProvider также предоставляет средство записи (объект RowSetWriter) для синхронизации изменений данных объекта CachedRowSet, внесённых во время его отключения, с данными в базовом источнике данных.

Средство записи можно реализовать так, чтобы оно с разной степенью тщательности проверяло наличие конфликтов и предотвращало их. (Конфликт возникает, если значение в источнике данных изменилось после того, как набор строк был заполнен этим значением.) Реализация RIOptimisticProvider предполагает, что конфликтов будет мало или не будет вовсе, поэтому блокировки не устанавливаются. Она обновляет источник данных значениями из объекта CachedRowSet только при отсутствии конфликтов. Другие средства записи можно реализовать так, чтобы они всегда записывали изменённые данные в источник данных. Этого можно добиться либо отказавшись от проверки конфликтов, либо, на противоположном конце спектра, установив блокировки, достаточные для предотвращения изменения данных в источнике данных. Возможны и другие реализации средств записи, занимающие промежуточное положение.

Объект CachedRowSet может использовать любую реализацию SyncProvider, зарегистрированную в синглтоне SyncFactory. Приложение может узнать, какие реализации SyncProvider зарегистрированы, выполнив следующую строку кода.

     java.util.Enumeration providers = SyncFactory.getRegisteredProviders();

Объект CachedRowSet может указать используемый объект SyncProvider двумя способами.

• Передать имя реализации конструктору
  Следующая строка кода создаёт объект CachedRowSet crs2, инициализированный значениями по умолчанию, за исключением того, что его объектом SyncProvider будет указанный объект.

           CachedRowSetImpl crs2 = new CachedRowSetImpl(
                                  "com.fred.providers.HighAvailabilityProvider");
      

• Задать SyncProvider с помощью метода CachedRowSet setSyncProvider
  Следующая строка кода сбрасывает объект SyncProvider для crs — объекта CachedRowSet, созданного конструктором по умолчанию.

            crs.setSyncProvider("com.fred.providers.HighAvailabilityProvider");
       

Подробнее см. комментарии к SyncFactory и SyncProvider.

2.0 Получение данных из объекта CachedRowSet

Данные из объекта CachedRowSet извлекаются с помощью методов получения, унаследованных от интерфейса ResultSet. В следующих примерах, где crs — это объект CachedRowSet, показано, как перебирать строки и получать значения столбцов в каждой строке. В первом примере используется вариант методов получения, принимающий номер столбца; во втором — вариант, принимающий имя столбца. Номера столбцов обычно используются, когда команда объекта RowSet имеет вид SELECT * FROM TABLENAME; имена столбцов чаще всего используются, когда в команде столбцы указаны по именам.

   while (crs.next()) {
       String name = crs.getString(1);
       int id = crs.getInt(2);
       Clob comment = crs.getClob(3);
       short dept = crs.getShort(4);
       System.out.println(name + "  " + id + "  " + comment + "  " + dept);
   }

   while (crs.next()) {
       String name = crs.getString("NAME");
       int id = crs.getInt("ID");
       Clob comment = crs.getClob("COM");
       short dept = crs.getShort("DEPT");
       System.out.println(name + "  " + id + "  " + comment + "  " + dept);
   }

2.1 Получение RowSetMetaData

Приложение может получить сведения о столбцах объекта CachedRowSet, вызвав методы ResultSetMetaData и RowSetMetaData объекта RowSetMetaData. Следующий фрагмент кода, в котором crs — это объект CachedRowSet, иллюстрирует этот процесс. Первая строка создаёт объект RowSetMetaData со сведениями о столбцах в crs. Метод getMetaData, унаследованный от интерфейса ResultSet, возвращает объект ResultSetMetaData, который приводится к типу объекта RowSetMetaData перед присваиванием переменной rsmd. Во второй строке определяется количество столбцов в jrs, а в третьей — тип JDBC значений, хранящихся во втором столбце jrs.

    RowSetMetaData rsmd = (RowSetMetaData)crs.getMetaData();
    int count = rsmd.getColumnCount();
    int type = rsmd.getColumnType(2);

Интерфейс RowSetMetaData отличается от интерфейса ResultSetMetaData двумя особенностями.

• Он включает методы setter: Объект RowSet использует эти методы внутри себя при заполнении данными из другого объекта ResultSet.
• Он содержит меньше методов getter: Некоторые методы ResultSetMetaData неприменимы к объекту RowSet. Например, методы, возвращающие сведения о том, доступна ли запись в столбец или доступен ли он только для чтения, неприменимы, поскольку все столбцы объекта RowSet доступны для записи или только для чтения в зависимости от того, поддерживает ли набор строк обновление.

ПРИМЕЧАНИЕ: Чтобы возвращать объект RowSetMetaData, реализации должны переопределить метод getMetaData(), определённый в java.sql.ResultSet, и возвращать объект RowSetMetaData.

3.0 Обновление объекта CachedRowSet

Обновление объекта CachedRowSet похоже на обновление объекта ResultSet, но, поскольку набор строк не подключён к источнику данных во время обновления, для применения изменений в базовом источнике данных требуется дополнительный шаг. После вызова метода updateRow или insertRow объект CachedRowSet должен также вызвать метод acceptChanges, чтобы записать обновления в источник данных. В следующем примере, где курсор находится на строке объекта CachedRowSet crs, показан код для обновления значений двух столбцов в текущей строке и обновления базового источника данных объекта RowSet.

    crs.updateShort(3, 58);
    crs.updateInt(4, 150000);
    crs.updateRow();
    crs.acceptChanges();

В следующем примере показано, как перейти к строке вставки, создать новую строку в строке вставки, вставить её в набор строк, а затем вызвать метод acceptChanges, чтобы добавить новую строку в базовый источник данных. Обратите внимание: как и методы получения, методы обновления могут принимать индекс столбца или его имя для указания столбца, над которым выполняется действие.

    crs.moveToInsertRow();
    crs.updateString("Name", "Shakespeare");
    crs.updateInt("ID", 10098347);
    crs.updateShort("Age", 58);
    crs.updateInt("Sal", 150000);
    crs.insertRow();
    crs.moveToCurrentRow();
    crs.acceptChanges();

ПРИМЕЧАНИЕ: Место, в которое метод insertRow() вставляет содержимое строки вставки объекта CachedRowSet, определяется реализацией. Эталонная реализация интерфейса CachedRowSet вставляет новую строку сразу после текущей, однако её можно реализовать так, чтобы новые строки вставлялись в любое другое место.

Ещё один важный момент в этих примерах — использование метода acceptChanges. Именно этот метод передаёт изменения объекта CachedRowSet обратно в базовый источник данных, вызывая внутри себя средство записи объекта RowSet для внесения изменений в источник данных. Для этого средству записи приходится устанавливать соединение с источником данных. В двух предыдущих фрагментах кода метод acceptChanges вызывается сразу после вызова updateRow или insertRow. Однако при изменении нескольких строк эффективнее вызвать acceptChanges после всех вызовов updateRow и insertRow. Если вызвать acceptChanges только один раз, потребуется установить лишь одно соединение.

4.0 Обновление базового источника данных

При выполнении метода acceptChanges средство записи объекта CachedRowSet — объект RowSetWriterImpl — незаметно для пользователя вызывается для записи изменений, внесённых в набор строк, в базовый источник данных. Средство записи реализуется так, чтобы устанавливать соединение с источником данных и записывать в него обновления.

Средство записи предоставляется реализацией интерфейса SyncProvider, как описано в разделе 1 «Создание объекта CachedRowSet». В поставщике эталонной реализации по умолчанию, RIOptimisticProvider, средство записи реализовано с использованием механизма оптимистичного управления параллелизмом. Это означает, что пока набор строк отключён от базы данных, блокировки в базовой базе данных не поддерживаются; вместо этого перед записью данных в источник проверяется наличие конфликтов. При наличии конфликтов данные в источник не записываются.

Механизм чтения и записи, предоставляемый классом SyncProvider, является подключаемым, что позволяет настраивать получение и обновление данных. Если требуется другой механизм управления параллелизмом, можно подключить другую реализацию SyncProvider с помощью метода setSyncProvider.

Для использования процедуры оптимистичного управления параллелизмом объект RIOptimisticProvider хранит как текущее, так и исходное значение (значение, которое было непосредственно перед текущим). Обратите внимание: если данные объекта RowSet не изменялись, его текущие и исходные значения совпадают и оба соответствуют значениям, которыми объект RowSet был заполнен изначально. Однако после изменения любого значения в объекте RowSet текущие и исходные значения различаются, хотя на этом этапе исходными значениями по-прежнему остаются первоначальные значения. При последующих изменениях данных объекта RowSet исходные и текущие значения также будут различаться, но исходными значениями станут те, которые ранее были текущими.

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

5.0 Регистрация и уведомление слушателей

Поскольку все наборы строк являются компонентами JavaBeans, они участвуют в модели событий JavaBeans и наследуют от класса BaseRowSet методы регистрации слушателей и уведомления их об изменениях. Слушатель объекта CachedRowSet — это компонент, которому нужно получать уведомления об изменениях в наборе строк. Например, если объект CachedRowSet содержит результаты запроса, отображаемые, скажем, в таблице и на гистограмме, их можно зарегистрировать как слушателей набора строк, чтобы они могли обновляться при изменении данных. Чтобы стать слушателями, классы таблицы и гистограммы должны реализовать интерфейс RowSetListener. Затем их можно добавить в список слушателей объекта CachedRowSet, как показано в следующих строках кода.

   crs.addRowSetListener(table);
   crs.addRowSetListener(barGraph);

Каждый метод CachedRowSet, перемещающий курсор или изменяющий данные, также уведомляет зарегистрированных слушателей об изменениях, поэтому table и barGraph получат уведомление при изменении crs.

6.0 Передача данных тонким клиентам

Одна из основных причин использовать объект CachedRowSet — передача данных между различными компонентами приложения. Поскольку объект CachedRowSet поддерживает сериализацию, его можно использовать, например, для отправки результата запроса, выполненного компонентом Enterprise JavaBeans на сервере, по сети клиенту, работающему в веб-браузере.

В отключённом состоянии объект CachedRowSet может быть значительно легче объекта ResultSet с теми же данными. Поэтому он особенно подходит для отправки данных тонкому клиенту, например PDA, где использование драйвера JDBC нецелесообразно из-за ограничений ресурсов или соображений безопасности. Таким образом, объект CachedRowSet позволяет «получать строки», не реализуя весь API JDBC.

7.0 Прокрутка и обновление

Ещё одно важное применение объектов CachedRowSet — обеспечение прокрутки и обновления для объектов ResultSet, которые сами по себе не поддерживают эти возможности. Иными словами, объект CachedRowSet можно использовать для расширения возможностей драйвера с поддержкой технологии JDBC (далее — «драйвер JDBC»), если СУБД не обеспечивает полноценную поддержку прокрутки и обновления. Чтобы обеспечить прокрутку и обновление для непрокручиваемого набора ResultSet, доступного только для чтения, программисту достаточно создать объект CachedRowSet и заполнить его данными этого объекта ResultSet. Это показано в следующем фрагменте кода, где stmt — объект Statement.

   ResultSet rs = stmt.executeQuery("SELECT * FROM EMPLOYEES");
   CachedRowSetImpl crs = new CachedRowSetImpl();
   crs.populate(rs);

Теперь объект crs содержит данные из таблицы EMPLOYEES, как и объект rs. Разница в том, что курсор объекта crs можно перемещать вперёд, назад или к определённой строке, даже если курсор объекта rs можно перемещать только вперёд. Кроме того, объект crs поддерживает обновление, даже если объект rs его не поддерживает, поскольку по умолчанию объект CachedRowSet поддерживает и прокрутку, и обновление.

Итак, объект CachedRowSet можно представить как отключённый набор строк, кэшируемый вне источника данных. Будучи компактным и поддерживая сериализацию, его можно без труда передать по сети; он хорошо подходит для отправки данных тонкому клиенту. Однако у объекта CachedRowSet есть ограничение: его размер ограничен объёмом данных, который он может одновременно хранить в памяти.

8.0 Универсальный доступ к данным

Ещё одно преимущество класса CachedRowSet заключается в том, что он позволяет получать и хранить данные из источников, отличных от реляционной базы данных. Средство чтения набора строк можно реализовать для чтения данных из любого табличного источника и заполнения ими набора строк, включая электронные таблицы и плоские файлы. Поскольку объект CachedRowSet и его метаданные можно создать с нуля, компонент, выполняющий роль фабрики наборов строк, может использовать эту возможность для создания набора строк с данными из источников, не использующих SQL. Тем не менее предполагается, что чаще всего объекты CachedRowSet будут содержать данные, полученные из базы данных SQL с помощью API JDBC.

9.0 Настройка свойств

Все наборы строк хранят набор свойств, которые обычно задаются с помощью инструмента. Количество и типы свойств набора строк зависят от его назначения и способа получения данных. Например, наборы строк, получающие данные из объекта ResultSet, должны задавать свойства, необходимые для подключения к базе данных. Если набор строк использует для подключения механизм DriverManager, ему необходимо задать свойство URL JDBC, указывающее соответствующий драйвер, а также свойства с именем пользователя и паролем. Если же для подключения набор строк использует объект DataSource, что является предпочтительным способом, задавать свойство URL JDBC не нужно. Вместо этого необходимо задать свойства с логическим именем источника данных, именем пользователя и паролем.

ПРИМЕЧАНИЕ: Чтобы использовать объект DataSource для подключения, объект DataSource должен быть зарегистрирован в службе именования, использующей API Java Naming and Directory Interface (JNDI). Обычно эту регистрацию выполняет системный администратор.

Чтобы заполнить набор строк данными из базы данных, необходимо задать свойство команды. Это свойство представляет собой запрос — объект PreparedStatement, который позволяет использовать в запросе заполнители параметров, задаваемые во время выполнения, а не на этапе проектирования. Для задания значений этих параметров-заполнителей набор строк предоставляет методы установки значений для каждого типа данных, подобные методам установки, предусмотренным интерфейсом PreparedStatement.

В следующем фрагменте кода показано, как можно задать свойство команды объекта CachedRowSet crs. Обратите внимание: если для задания свойств используется инструмент, он будет применять именно этот код.

   crs.setCommand("SELECT FIRST_NAME, LAST_NAME, ADDRESS FROM CUSTOMERS " +
                  "WHERE CREDIT_LIMIT > ? AND REGION = ?");
 

Значения, которые будут использоваться для задания параметров-заполнителей команды, содержатся в поле params объекта RowSet, которое является объектом Vector. Класс CachedRowSet предоставляет набор методов установки для задания элементов поля params. В следующем фрагменте кода показано, как задать два параметра запроса из предыдущего примера.

   crs.setInt(1, 5000);
   crs.setString(2, "West");

Теперь поле params содержит два элемента, каждый из которых представляет собой массив из двух элементов. Первый элемент — номер параметра, второй — задаваемое значение. В данном случае первый элемент params — это 1, 5000, а второй — 2, "West". Когда приложение вызывает метод execute, тот, в свою очередь, вызывает средство чтения этого объекта RowSet, которое затем вызывает свой метод readData. В рамках своей реализации readData получает значения из params и использует их для задания параметров-заполнителей команды. В следующем фрагменте кода показано, как средство чтения выполняет эту операцию после получения объекта Connection con.

   PreparedStatement pstmt = con.prepareStatement(crs.getCommand());
   reader.decodeParams();
   // decodeParams figures out which setter methods to use and does something
   // like the following:
   //    for (i = 0; i < params.length; i++) {
   //        pstmt.setObject(i + 1, params[i]);
   //    }

На этом этапе команда для crs представляет собой запрос "SELECT FIRST_NAME, LAST_NAME, ADDRESS FROM CUSTOMERS WHERE CREDIT_LIMIT > 5000 AND REGION = "West". После того как метод readData выполнит эту команду следующей строкой кода, он получит данные из rs, которыми заполнит crs.

    ResultSet rs = pstmt.executeQuery();

Предыдущие фрагменты кода дают представление о том, что происходит за кулисами; в приложении они не встречаются, поскольку приложение не вызывает такие методы, как readData и decodeParams. Напротив, в следующем фрагменте кода показано, что может делать приложение. Оно задаёт команду набора строк, задаёт параметры команды и выполняет её. Просто вызвав метод execute, объект crs заполняет себя запрошенными данными из таблицы CUSTOMERS.

   crs.setCommand("SELECT FIRST_NAME, LAST_NAME, ADDRESS FROM CUSTOMERS" +
                  "WHERE CREDIT_LIMIT > ? AND REGION = ?");
   crs.setInt(1, 5000);
   crs.setString(2, "West");
   crs.execute();

10.0 Постраничная выборка данных

Поскольку объект CachedRowSet хранит данные в памяти, объём данных, который он может одновременно содержать, определяется доступным объёмом памяти. Чтобы обойти это ограничение, объект CachedRowSet может получать данные из объекта ResultSet порциями, называемыми страницами. Чтобы воспользоваться этим механизмом, приложение задаёт количество строк на странице с помощью метода setPageSize. Иными словами, если размер страницы равен пяти, за один раз из источника данных будет извлекаться порция из пяти строк. Приложение также может дополнительно задать максимальное количество строк, извлекаемых за один раз. Если максимальное количество строк равно нулю или не задано, количество строк, извлекаемых за один раз, не ограничено.

После задания свойств объект CachedRowSet необходимо заполнить данными с помощью метода populate или execute. В следующих строках кода показано использование метода populate. Обратите внимание: эта версия метода принимает два параметра — дескриптор ResultSet и номер строки объекта ResultSet, с которой следует начать извлечение строк.

    CachedRowSet crs = new CachedRowSetImpl();
    crs.setMaxRows(20);
    crs.setPageSize(4);
    crs.populate(rsHandle, 10);

После выполнения этого кода объект crs будет заполнен четырьмя строками из rsHandle, начиная с десятой строки.

В следующем фрагменте кода показано заполнение объекта CachedRowSet с помощью метода execute, который может принимать или не принимать объект Connection в качестве параметра. В этом примере методу execute передаётся объект Connection conHandle.

Обратите внимание на два отличия следующего фрагмента кода от предыдущего. Во-первых, метод setMaxRows не вызывается, поэтому максимальное количество строк для crs не задаётся. (Помните, что crs всё равно ограничен объёмом данных, который может хранить в памяти.) Во-вторых, методу execute нельзя передать номер строки объекта ResultSet, с которой следует начать извлечение строк. Этот метод всегда начинает с первой строки.

    CachedRowSet crs = new CachedRowSetImpl();
    crs.setPageSize(5);
    crs.execute(conHandle);

После выполнения этого кода объект crs будет содержать пять строк данных из объекта ResultSet, полученного в результате выполнения команды для crs. Средство записи объекта crs использует conHandle для подключения к источнику данных и выполнения команды для crs. Затем приложение может работать с данными в crs так же, как с данными любого другого объекта CachedRowSet.

Чтобы получить следующую страницу (порцию данных), приложение вызывает метод nextPage. Этот метод создаёт новый объект CachedRowSet и заполняет его следующей страницей данных. Например, предположим, что команда объекта CachedRowSet возвращает объект ResultSet rs с 1000 строками данных. Если размер страницы задан равным 100, первый вызов метода nextPage создаст объект CachedRowSet, содержащий первые 100 строк из rs. После того как приложение выполнит необходимые операции с данными этих первых 100 строк, оно может снова вызвать метод nextPage, чтобы создать другой объект CachedRowSet со следующими 100 строками из rs. Данные первого объекта CachedRowSet больше не будут храниться в памяти, поскольку их заменят данные второго объекта CachedRowSet. После десятого вызова метода nextPage десятый объект CachedRowSet будет содержать последние 100 строк данных из rs, хранящиеся в памяти. В каждый момент времени в памяти хранятся данные только одного объекта CachedRowSet.

Метод nextPage возвращает true, пока текущая страница не является последней, и false, когда страниц больше нет. Поэтому его можно использовать в цикле while для получения всех страниц, как показано в следующих строках кода.

    CachedRowSet crs = CachedRowSetImpl();
    crs.setPageSize(100);
    crs.execute(conHandle);

    while(crs.nextPage()) {
        while(crs.next()) {
            . . . // operate on chunks (of 100 rows each) in crs,
                  // row by row
        }
    }

После выполнения этого фрагмента кода приложение просмотрит все 1000 строк, но одновременно в памяти будет находиться не более 100 строк.

Интерфейс CachedRowSet также определяет метод previousPage. Подобно тому как метод nextPage аналогичен методу ResultSet интерфейса next, метод previousPage аналогичен методу ResultSet интерфейса previous. Как и метод nextPage, метод previousPage создаёт объект CachedRowSet, содержащий количество строк, равное заданному размеру страницы. Например, метод previousPage можно использовать в цикле while в конце предыдущего фрагмента кода, чтобы перемещаться по страницам от последней к первой. Метод previousPage также похож на nextPage тем, что его можно использовать в цикле while, однако он возвращает true, пока перед текущей страницей есть ещё одна, и false, когда впереди больше нет страниц.

Если установить курсор после последней строки каждой страницы, как показано в следующем фрагменте кода, метод previous будет перемещать курсор от последней строки к первой на каждой странице. Можно также установить курсор перед первой строкой каждой страницы, а затем использовать метод next в цикле while, чтобы перемещаться по каждой странице от первой строки к последней.

Следующий фрагмент кода предполагает продолжение предыдущего: курсор десятого объекта CachedRowSet находится на последней строке. Код перемещает курсор за последнюю строку, чтобы первый вызов метода previous вернул его на последнюю строку. Пройдя все строки последней страницы (объекта CachedRowSet crs), код входит в цикл while, чтобы перейти к девятой странице, пройти строки в обратном порядке, перейти к восьмой странице, снова пройти строки в обратном порядке и так далее, до первой строки первой страницы.

    crs.afterLast();
    while(crs.previous())  {
        . . . // navigate through the rows, last to first
    {
    while(crs.previousPage())  {
        crs.afterLast();
        while(crs.previous())  {
            . . . // go from the last row to the first row of each page
        }
    }