使用 Derby 引擎开发 DB2 Everyplace XML 同步应用程序

核心提示： 清单 8. 打开数据库连接publicvoidopenDBConnection(){try{Class.forName("org.apache.derby.jdbc.EmbeddedDriver").newInstance();StringBufferstrBuff=newS

清单 8. 打开数据库连接
public　void　openDBConnection()　
　{　
　　try{　
　　　　Class.forName("org.apache.derby.jdbc.EmbeddedDriver").newInstance();　　　　
　　　　StringBuffer　strBuff　=　new　StringBuffer();　
　　　　strBuff.append(new　String("jdbc:derby:"));　
　　　　strBuff.append(strPath);　
　　　　strBuff.append(new　String("\\syncDb"));　
　　　　strURL　=　strBuff.toString();　　
　　　　conn=　DriverManager.getConnection(strURL);　　　
　　　　}catch(Exception　e){　
　　　　　　e.printStackTrace();　
　　　　　　}　
　　}

查询 XML 数据

类 JXSync 提供了方法 queryXDataFromDB 用来查询 XML 数据。 queryXDataFromDB 首先创建一个语句实例，随后执行 SQL 语句 select idx, xmlserialize(xcol as char(128)) from xtable 来执行查询。查询结果通过遍历结果集逐条显示。这里 xmlserialize 是一个 SQL/XML 操作符，用来转换 XML 类型为字符串类型。 Derby 依赖于 Apache JAXP 来实现 xmlserialize 操作符。清单 9 列出了查询 XML 数据的实现代码。

清单 9. 查询 XML 数据
public　void　queryXDataFromDB()　
　　{　
　　　　try{　　
　　　　　　Statement　stmt=conn.createStatement();　
　　　　　　String　sql="select　idx,　xmlserialize(xcol　as　char(128))　from　xtable";　　
　　　　　　ResultSet　rs=stmt.executeQuery(sql);　　　
　　　　　　while(rs.next()){　　
　　　　　　　　int　idx　=　rs.getInt(1);　
　　　　　　　　String　strProduct　=　rs.getString(2);　　　
　　　　　　　　System.out.println("idx:"　+　idx　+　"xcol:"　+　strProduct);　
　　　　　　}//　end　while　　　
　　　　　　rs.close();　　
　　　　　　stmt.close();　　　
　　　　　　}catch(Exception　e){　
　　　　　　　　e.printStackTrace();　
　　　　}　
　　}