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>