JavaでのJDBCRowSetインターフェースの概要
1. 概要
この記事では、JDBCを確認しています RowSet インターフェース
オラクルは、 RowSet:を最も頻繁に使用するために、5つのRowSetインターフェースを定義しています。
- JdbcRowSet
- CachedRowSet
- WebRowSet
- JoinRowSet
- FilteredRowSet
このチュートリアルでは、これらのRowSetインターフェイスの使用方法を確認します。
2. JdbcRowSet
JdbcRowSet から始めましょう– ConnectionオブジェクトをJdbcRowSetImplに渡すことで、単純に作成します。
JdbcRowSet jdbcRS = new JdbcRowSetImpl(conn);
jdbcRS.setType(ResultSet.TYPE_SCROLL_INSENSITIVE);
String sql = "SELECT * FROM customers";
jdbcRS.setCommand(sql);
jdbcRS.execute();
jdbcRS.addRowSetListener(new ExampleListener());
while (jdbcRS.next()) {
// each call to next, generates a cursorMoved event
System.out.println("id = " + jdbcRS.getString(1));
System.out.println("name = " + jdbcRS.getString(2));
}
上記の例では、メソッド setCommand を使用してSQLステートメントを定義し、メソッド execute を実行するまで、jdbcRsにはデータが含まれていませんでした。
また、イベント処理を実行するために、RowSetListenerをJdbcRowSet。に追加した方法にも注目してください。
JdbcRowSet は、他の4つの RowSet 実装とは異なります。これは、が常にデータベースに接続されているため、ResultSetに最も類似しているためです。 ] 物体。
3. CachedRowSet
CachedRowSet オブジェクトは、データソースに接続しなくても動作できるため、一意です。 これを「切断されたRowSetオブジェクト」と呼びます。
CachedRowSet は、データベースに格納されているデータではなく、独自のデータを操作できるようにデータをメモリにキャッシュするため、この名前が付けられています。
CachedRowSet インターフェイスは切断されたすべてのRowSetオブジェクトのスーパーインターフェイスであるため、以下で確認するコードは WebRowSe t、JoinRowSetにも適用できます。 ]、または FilteredRowSe tも同様です:
CachedRowSet crs = new CachedRowSetImpl();
crs.setUsername(username);
crs.setPassword(password);
crs.setUrl(url);
crs.setCommand(sql);
crs.execute();
crs.addRowSetListener(new ExampleListener());
while (crs.next()) {
if (crs.getInt("id") == 1) {
System.out.println("CRS found customer1 and will remove the record.");
crs.deleteRow();
break;
}
}
4. WebRowSet
次に、WebRowSetを見てみましょう。
これは、 CachedRowSet オブジェクトの機能を提供することに加えて、自身をXMLドキュメント tに書き込むことができ、そのXMLドキュメントを読み取ってそれ自体を WebRowSet :
WebRowSet wrs = new WebRowSetImpl();
wrs.setUsername(username);
wrs.setPassword(password);
wrs.setUrl(url);
wrs.setCommand(sql);
wrs.execute();
FileOutputStream ostream = new FileOutputStream("customers.xml");
wrs.writeXml(ostream);
writeXml メソッドを使用して、WebRowSetオブジェクトの現在の状態をXMLドキュメントに書き込みます。
writeXmlメソッドにOutputStreamオブジェクトを渡すことにより、文字ではなくバイトで書き込みます。これは、すべての形式のデータを処理するのに非常に役立ちます。
5. JoinRowSet
JoinRowSet を使用すると、 RowSet オブジェクトがメモリ内にある場合に、それらの間にSQL JOINを作成できます。 これは、1つ以上の接続を作成する必要があるオーバーヘッドを節約できるため重要です。
CachedRowSetImpl customers = new CachedRowSetImpl();
// configuration of settings for CachedRowSet
CachedRowSetImpl associates = new CachedRowSetImpl();
// configuration of settings for this CachedRowSet
JoinRowSet jrs = new JoinRowSetImpl();
jrs.addRowSet(customers,ID);
jrs.addRowSet(associates,ID);
JoinRowSetオブジェクトに追加された各RowSetオブジェクトには、SQL JOIN の基になる一致列が必要なため、「id」を指定します。 addRowSetメソッドの。
列名を使用する代わりに、列番号を使用することもできます。
6. FilteredRowSet
最後に、 FilteredRowSet を使用すると、 RowSet オブジェクトに表示される行の数を減らして、関連するデータのみを処理できるようにします。私たちがしていること。
Predicate インターフェースの実装を使用して、データを「フィルタリング」する方法を決定します。
public class FilterExample implements Predicate {
private Pattern pattern;
public FilterExample(String regexQuery) {
if (regexQuery != null && !regexQuery.isEmpty()) {
pattern = Pattern.compile(regexQuery);
}
}
public boolean evaluate(RowSet rs) {
try {
if (!rs.isAfterLast()) {
String name = rs.getString("name");
System.out.println(String.format(
"Searching for pattern '%s' in %s", pattern.toString(),
name));
Matcher matcher = pattern.matcher(name);
return matcher.matches();
} else
return false;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
// methods for handling errors
}
次に、そのフィルターをFilteredRowSetオブジェクトに適用します。
RowSetFactory rsf = RowSetProvider.newFactory();
FilteredRowSet frs = rsf.createFilteredRowSet();
frs.setCommand("select * from customers");
frs.execute(conn);
frs.setFilter(new FilterExample("^[A-C].*"));
ResultSetMetaData rsmd = frs.getMetaData();
int columncount = rsmd.getColumnCount();
while (frs.next()) {
for (int i = 1; i <= columncount; i++) {
System.out.println(
rsmd.getColumnLabel(i)
+ " = "
+ frs.getObject(i) + " ");
}
}
7. 結論
このクイックチュートリアルでは、JDKで使用可能なRowSetインターフェースの5つの標準実装について説明しました。
各実装の構成について説明し、それらの違いについて説明しました。
指摘したように、 RowSet 実装の1つだけが、接続された RowSet オブジェクト、つまりJdbcRowSetです。 他の4つは切断されたRowSetオブジェクトです。
そして、いつものように、この記事の完全なコードはGithubのにあります。