Java by API/javax.sql.rowset/WebRowSet

WebRowSet: writeXml(ResultSet rs, Writer writer)

   <source lang="java">
 

/*

* Copyright (c) Ian F. Darwin, http://www.darwinsys.ru/, 1996-2002.
* All rights reserved. Software written by Ian F. Darwin and others.
* $Id: LICENSE,v 1.8 2004/02/09 03:33:38 ian Exp $
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
*    notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
*    notice, this list of conditions and the following disclaimer in the
*    documentation and/or other materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS""
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
* TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
* PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS
* BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
* 
* Java, the Duke mascot, and all variants of Sun"s Java "steaming coffee
* cup" logo are trademarks of Sun Microsystems. Sun"s, and James Gosling"s,
* pioneering role in inventing and promulgating (and standardizing) the Java 
* language and environment is gratefully acknowledged.
* 
* The pioneering role of Dennis Ritchie and Bjarne Stroustrup, of AT&T, for
* inventing predecessor languages C and C++ is also gratefully acknowledged.
*/

import java.io.IOException; import java.io.PrintWriter; import java.sql.ResultSet; import java.sql.SQLException; import javax.sql.rowset.WebRowSet; /**

* This guy"s primary raison d"etre is to generate an XML output file for use in
* JUnit testing of the ResultsDecoratorSQL!
* 
* @version $Id: ResultsDecoratorXML.java,v 1.1 2004/03/26 02:39:33 ian Exp $
*/

public class Main extends ResultsDecorator {

 WebRowSet results;
 Main(ResultsDecoratorPrinter out) {
   super(out);
   try {
     // The name is com.sun.rowset.WebRowSetImpl in rowset.jar,
     // but sun.rowset.jar in J2SDK1.5. Go figure.
     Class c = Class.forName("com.sun.rowset.WebRowSetImpl");
     results = (WebRowSet) c.newInstance();
   } catch (Exception ex) {
     throw new IllegalArgumentException(
         "can"t load WebRowSetImpl, check CLASSPATH");
   }
 }
 public void write(ResultSet rs) throws SQLException {
   results.writeXml(rs, parent.getPrintWriter());
 }
 void write(int rowCount) throws IOException {
   println("RowCount: " + rowCount);
 }
 /*
  * (non-Javadoc)
  * 
  * @see ResultsDecorator#getName()
  */
 String getName() {
   return "XML";
 }

} /**

* Base class for a series of ResultSet printers.
* 
* @version $Id: ResultsDecorator.java,v 1.2 2004/03/26 02:39:33 ian Exp $
*/

abstract class ResultsDecorator {

 ResultsDecoratorPrinter parent;
 ResultsDecorator(ResultsDecoratorPrinter wr) {
   this.parent = wr;
 }
 /** Print the name of this Decorator"s output format */
 abstract String getName();
 /** Print the contents of a ResultSet */
 abstract void write(ResultSet rs) throws IOException, SQLException;
 /** Print the results of an operation as a Count */
 abstract void write(int rowCount) throws IOException;
 void println(String line) throws IOException {
   parent.println(line);
 }
 void println() throws IOException {
   parent.println();
 }
 void print(String lineSeg) throws IOException {
   parent.print(lineSeg);
 }

} /**

* Callback so that ResultsDecorator can call invoker to handle redirections
* etc.
* 
* @version $Id: ResultsDecoratorPrinter.java,v 1.1 2004/03/26 02:39:33 ian Exp $
*/

interface ResultsDecoratorPrinter {

 void print(String line) throws IOException;
 void println(String line) throws IOException;
 void println() throws IOException;
 PrintWriter getPrintWriter();

}

 </source>
   
  
 
  

WebRowSet: writeXml(Writer writer)

   <source lang="java">
 

import java.io.File; import java.io.FileWriter; import java.io.StringWriter; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; import javax.sql.rowset.WebRowSet; import com.sun.rowset.WebRowSetImpl; public class Main {

 public static void main(String[] args) throws Exception {
   Connection conn = getHSQLConnection();
   System.out.println("Got Connection.");
   Statement st = conn.createStatement();
   st.executeUpdate("create table survey (id int,name varchar);");
   st.executeUpdate("insert into survey (id,name ) values (1,"nameValue")");
   st.executeUpdate("insert into survey (id,name ) values (2,"anotherValue")");    
   
   Statement stmt = conn.createStatement();
   String sqlQuery = "SELECT * FROM survey WHERE id="1"";
   WebRowSet webRS = new WebRowSetImpl();
   webRS.setCommand(sqlQuery);
   webRS.execute(conn);
   File file = new File("1.xml");
   FileWriter fw = new FileWriter(file);
   System.out.println("Writing db data to file " + file.getAbsolutePath());
   webRS.writeXml(fw);
   StringWriter sw = new StringWriter();
   webRS.writeXml(sw);
   System.out.println(sw.toString());
   fw.flush();
   fw.close();
   stmt.close();
   conn.close();
 }
 private static Connection getHSQLConnection() throws Exception {
   Class.forName("org.hsqldb.jdbcDriver");
   System.out.println("Driver Loaded.");
   String url = "jdbc:hsqldb:data/tutorial";
   return DriverManager.getConnection(url, "sa", "");
 }
 public static Connection getMySqlConnection() throws Exception {
   String driver = "org.gjt.mm.mysql.Driver";
   String url = "jdbc:mysql://localhost/demo2s";
   String username = "oost";
   String password = "oost";
   Class.forName(driver);
   Connection conn = DriverManager.getConnection(url, username, password);
   return conn;
 }
 public static Connection getOracleConnection() throws Exception {
   String driver = "oracle.jdbc.driver.OracleDriver";
   String url = "jdbc:oracle:thin:@localhost:1521:databaseName";
   String username = "userName";
   String password = "password";
   Class.forName(driver); // load Oracle driver
   Connection conn = DriverManager.getConnection(url, username, password);
   return conn;
 }

}

 </source>