import org.dbunit.dataset.filter.ITableFilterSimple;\r
import org.dbunit.dataset.xml.FlatDtdDataSet;\r
import org.dbunit.dataset.xml.FlatXmlDataSet;\r
+import org.dbunit.dataset.xml.FlatXmlWriter;\r
import org.dbunit.dataset.xml.XmlDataSetWriter;\r
import org.dbunit.ext.h2.H2DataTypeFactory;\r
import org.dbunit.operation.DatabaseOperation;\r
connection = getConnection();\r
IDataSet actualDataSet = connection.createDataSet(tableNames);\r
FlatXmlDataSet.write(actualDataSet, out);\r
+\r
+ \r
+ } catch (Exception e) {\r
+ logger.error(e);\r
+ } finally {\r
+ try {\r
+ connection.close();\r
+ } catch (SQLException sqle) {\r
+ logger.error(sqle);\r
+ }\r
+ }\r
+ }\r
+\r
+ /**\r
+ * Prints the named tables to an output stream, using dbunit's\r
+ * {@link org.dbunit.dataset.xml.FlatXmlWriter}.\r
+ *\r
+ * @see {@link #printDataSet(OutputStream)}\r
+ * @param out\r
+ * @param filter\r
+ */\r
+ public void printDataSet(OutputStream out, ITableFilterSimple filter) {\r
+ if (filter == null){\r
+ filter = new ExcludeTableFilter();\r
+ }\r
+ \r
+ IDatabaseConnection connection = null;\r
+\r
+ try {\r
+ connection = getConnection();\r
+// FlatXmlDataSet.write(actualDataSet, out);\r
+\r
+ IDataSet dataSet = new DatabaseDataSet(connection, false, filter);\r
+\r
+ FlatXmlWriter writer = new FlatXmlWriter(out);\r
+ writer.write(dataSet);\r
+ \r
} catch (Exception e) {\r
logger.error(e);\r
} finally {\r
}\r
}\r
\r
+ \r
/**\r
* Prints a dtd to an output stream, using dbunit's\r
* {@link org.dbunit.dataset.xml.FlatDtdDataSet}.\r