[jbpm-commits] JBoss JBPM SVN: r5070 - in jbpm4/trunk/modules/test-db: src/test/java and 1 other directories.

Author: heiko.braun(a)jboss.com Date: 2009-06-22 06:35:34 -0400 (Mon, 22 Jun 2009) New Revision: 5070 Added: jbpm4/trunk/modules/test-db/src/test/java/reporting/ jbpm4/trunk/modules/test-db/src/test/java/reporting/DOMUtils.java jbpm4/trunk/modules/test-db/src/test/java/reporting/SQLStmtTest.java Modified: jbpm4/trunk/modules/test-db/pom.xml Log: Add reporting SQL statement tests Modified: jbpm4/trunk/modules/test-db/pom.xml =================================================================== --- jbpm4/trunk/modules/test-db/pom.xml 2009-06-19 17:26:38 UTC (rev 5069) +++ jbpm4/trunk/modules/test-db/pom.xml 2009-06-22 10:35:34 UTC (rev 5070) @@ -53,6 +53,12 @@ <scope>test</scope> </dependency> + <dependency> + <groupId>org.jbpm.jbpm4</groupId> + <artifactId>jbpm-console-reports</artifactId> + <scope>test</scope> + </dependency> + </dependencies> <build> @@ -102,16 +108,16 @@ <configuration> <tasks> <copy file="../../qa/jdbc/${database}.properties" - tofile="target/jdbc.properties" /> + tofile="target/test-classes/jdbc.properties" /> <copy file="${user.home}/.jbpm4/jdbc/${database}.properties" - tofile="target/jdbc.properties" + tofile="target/test-classes/jdbc.properties" overwrite="true" failonerror="true "/> <copy file="../../modules/distro/src/main/files/db/hibernate.cfg/${database}.hibernate.cfg.xml" tofile="target/test-classes/jbpm.hibernate.cfg.xml" overwrite="true"> <filterset> - <filtersfile file="target/jdbc.properties" /> + <filtersfile file="target/test-classes/jdbc.properties" /> </filterset> </copy> <replace file="target/test-classes/jbpm.hibernate.cfg.xml"> Added: jbpm4/trunk/modules/test-db/src/test/java/reporting/DOMUtils.java =================================================================== --- jbpm4/trunk/modules/test-db/src/test/java/reporting/DOMUtils.java (rev 0) +++ jbpm4/trunk/modules/test-db/src/test/java/reporting/DOMUtils.java 2009-06-22 10:35:34 UTC (rev 5070) @@ -0,0 +1,706 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file in the + * distribution for a full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package reporting; + +import org.w3c.dom.*; +import org.xml.sax.EntityResolver; +import org.xml.sax.InputSource; +import org.xml.sax.SAXException; + +import javax.xml.namespace.QName; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import javax.xml.parsers.ParserConfigurationException; +import javax.xml.transform.*; +import javax.xml.transform.dom.DOMSource; +import javax.xml.transform.sax.SAXSource; +import javax.xml.transform.stream.StreamResult; +import javax.xml.transform.stream.StreamSource; +import java.io.*; +import java.util.*; + +/** + * DOM2 utilites + * + * @author Thomas.Diesler(a)jboss.org + * @author alessio.soldano(a)jboss.com + */ +public final class DOMUtils +{ + + // All elements created by the same thread are created by the same builder and belong to the same doc + private static ThreadLocal<Document> documentThreadLocal = new ThreadLocal<Document>(); + private static ThreadLocal<DocumentBuilder> builderThreadLocal = new ThreadLocal<DocumentBuilder>() + { + protected DocumentBuilder initialValue() + { + try + { + DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); + factory.setValidating(false); + factory.setNamespaceAware(true); + DocumentBuilder builder = factory.newDocumentBuilder(); + setEntityResolver(builder); + return builder; + } + catch (ParserConfigurationException e) + { + throw new RuntimeException("Failed to create DocumentBuilder", e); + } + } + + private void setEntityResolver(DocumentBuilder builder) + { + String[] resolvers = new String[] { "org.jboss.ws.core.utils.JBossWSEntityResolver", "org.jboss.util.xml.JBossEntityResolver" }; + + EntityResolver entityResolver = null; + ClassLoader loader = Thread.currentThread().getContextClassLoader(); + for (String resolver : resolvers) + { + try + { + Class<?> resolverClass = loader.loadClass(resolver); + entityResolver = (EntityResolver)resolverClass.newInstance(); + } + catch (Exception ex) + { + // + } + } + + if (entityResolver != null) + builder.setEntityResolver(entityResolver); + } + }; + + public static void clearThreadLocals() + { + documentThreadLocal.remove(); + builderThreadLocal.remove(); + } + + // Hide the constructor + private DOMUtils() + { + } + + /** Initialize the DocumentBuilder + */ + public static DocumentBuilder getDocumentBuilder() + { + return builderThreadLocal.get(); + } + + /** Parse the given XML string and return the root Element + */ + public static Element parse(String xmlString) throws IOException + { + try + { + return parse(new ByteArrayInputStream(xmlString.getBytes("UTF-8"))); + } + catch (IOException e) + { + throw e; + } + } + + /** Parse the given XML stream and return the root Element + */ + public static Element parse(InputStream xmlStream) throws IOException + { + try + { + return getDocumentBuilder().parse(xmlStream).getDocumentElement(); + } + catch (SAXException se) + { + throw new IOException(se.toString()); + } + finally + { + xmlStream.close(); + } + } + + /** Parse the given input source and return the root Element + */ + public static Element parse(InputSource source) throws IOException + { + try + { + return getDocumentBuilder().parse(source).getDocumentElement(); + } + catch (SAXException se) + { + throw new IOException(se.toString()); + } + finally + { + InputStream is = source.getByteStream(); + if (is != null) + { + is.close(); + } + Reader r = source.getCharacterStream(); + if (r != null) + { + r.close(); + } + } + } + + /** Create an Element for a given name + */ + public static Element createElement(String localPart) + { + Document doc = getOwnerDocument(); + return doc.createElement(localPart); + } + + /** Create an Element for a given name and prefix + */ + public static Element createElement(String localPart, String prefix) + { + Document doc = getOwnerDocument(); + return doc.createElement(prefix + ":" + localPart); + } + + /** Create an Element for a given name, prefix and uri + */ + public static Element createElement(String localPart, String prefix, String uri) + { + Document doc = getOwnerDocument(); + if (prefix == null || prefix.length() == 0) + { + return doc.createElementNS(uri, localPart); + } + else + { + return doc.createElementNS(uri, prefix + ":" + localPart); + } + } + + /** Create an Element for a given QName + */ + public static Element createElement(QName qname) + { + return createElement(qname.getLocalPart(), qname.getPrefix(), qname.getNamespaceURI()); + } + + /** Create a org.w3c.dom.Text node + */ + public static Text createTextNode(String value) + { + Document doc = getOwnerDocument(); + return doc.createTextNode(value); + } + + /** Get the qname of the given node. + */ + public static QName getElementQName(Element el) + { + String qualifiedName = el.getNodeName(); + return resolveQName(el, qualifiedName); + } + + /** Transform the given qualified name into a QName + */ + public static QName resolveQName(Element el, String qualifiedName) + { + QName qname; + String prefix = ""; + String namespaceURI = ""; + String localPart = qualifiedName; + + int colIndex = qualifiedName.indexOf(":"); + if (colIndex > 0) + { + prefix = qualifiedName.substring(0, colIndex); + localPart = qualifiedName.substring(colIndex + 1); + + if ("xmlns".equals(prefix)) + { + namespaceURI = "URI:XML_PREDEFINED_NAMESPACE"; + } + else + { + Element nsElement = el; + while (namespaceURI.equals("") && nsElement != null) + { + namespaceURI = nsElement.getAttribute("xmlns:" + prefix); + if (namespaceURI.equals("")) + nsElement = getParentElement(nsElement); + } + } + + if (namespaceURI.equals("")) + throw new IllegalArgumentException("Cannot find namespace uri for: " + qualifiedName); + } + else + { + Element nsElement = el; + while (namespaceURI.equals("") && nsElement != null) + { + namespaceURI = nsElement.getAttribute("xmlns"); + if (namespaceURI.equals("")) + nsElement = getParentElement(nsElement); + } + } + + qname = new QName(namespaceURI, localPart, prefix); + return qname; + } + + /** Get the value from the given attribute + * + * @return null if the attribute value is empty or the attribute is not present + */ + public static String getAttributeValue(Element el, String attrName) + { + return getAttributeValue(el, new QName(attrName)); + } + + /** Get the value from the given attribute + * + * @return null if the attribute value is empty or the attribute is not present + */ + public static String getAttributeValue(Element el, QName attrName) + { + String attr = null; + if ("".equals(attrName.getNamespaceURI())) + attr = el.getAttribute(attrName.getLocalPart()); + else attr = el.getAttributeNS(attrName.getNamespaceURI(), attrName.getLocalPart()); + + if ("".equals(attr)) + attr = null; + + return attr; + } + + /** Get the qname value from the given attribute + */ + public static QName getAttributeValueAsQName(Element el, String attrName) + { + return getAttributeValueAsQName(el, new QName(attrName)); + + } + + /** Get the qname value from the given attribute + */ + public static QName getAttributeValueAsQName(Element el, QName attrName) + { + QName qname = null; + + String qualifiedName = getAttributeValue(el, attrName); + if (qualifiedName != null) + { + qname = resolveQName(el, qualifiedName); + } + + return qname; + } + + /** Get the boolean value from the given attribute + */ + public static boolean getAttributeValueAsBoolean(Element el, String attrName) + { + return getAttributeValueAsBoolean(el, new QName(attrName)); + } + + /** Get the boolean value from the given attribute + */ + public static boolean getAttributeValueAsBoolean(Element el, QName attrName) + { + String attrVal = getAttributeValue(el, attrName); + boolean ret = "true".equalsIgnoreCase(attrVal) || "1".equalsIgnoreCase(attrVal); + return ret; + } + + /** Get the integer value from the given attribute + */ + public static Integer getAttributeValueAsInteger(Element el, String attrName) + { + return getAttributeValueAsInteger(el, new QName(attrName)); + } + + /** Get the integer value from the given attribute + */ + public static Integer getAttributeValueAsInteger(Element el, QName attrName) + { + String attrVal = getAttributeValue(el, attrName); + return (attrVal != null ? new Integer(attrVal) : null); + } + + /** Get the attributes as Map<QName, String> + */ + public static Map getAttributes(Element el) + { + Map attmap = new HashMap(); + NamedNodeMap attribs = el.getAttributes(); + for (int i = 0; i < attribs.getLength(); i++) + { + Attr attr = (Attr)attribs.item(i); + String name = attr.getName(); + QName qname = resolveQName(el, name); + String value = attr.getNodeValue(); + attmap.put(qname, value); + } + return attmap; + } + + /** Copy attributes between elements + */ + public static void copyAttributes(Element destElement, Element srcElement) + { + NamedNodeMap attribs = srcElement.getAttributes(); + for (int i = 0; i < attribs.getLength(); i++) + { + Attr attr = (Attr)attribs.item(i); + String uri = attr.getNamespaceURI(); + String qname = attr.getName(); + String value = attr.getNodeValue(); + + // Prevent DOMException: NAMESPACE_ERR: An attempt is made to create or + // change an object in a way which is incorrect with regard to namespaces. + if (uri == null && qname.startsWith("xmlns")) + { + // + } + else + { + destElement.setAttributeNS(uri, qname, value); + } + } + } + + /** True if the node has text child elements only + */ + public static boolean hasTextChildNodesOnly(Node node) + { + NodeList nodeList = node.getChildNodes(); + if (nodeList.getLength() == 0) + return false; + + for (int i = 0; i < nodeList.getLength(); i++) + { + Node acksToChildNode = nodeList.item(i); + if (acksToChildNode.getNodeType() != Node.TEXT_NODE) + return false; + } + + return true; + } + + /** True if the node has child elements + */ + public static boolean hasChildElements(Node node) + { + NodeList nlist = node.getChildNodes(); + for (int i = 0; i < nlist.getLength(); i++) + { + Node child = nlist.item(i); + if (child.getNodeType() == Node.ELEMENT_NODE) + return true; + } + return false; + } + + /** Gets child elements + */ + public static Iterator<Element> getChildElements(Node node) + { + List<Element> list = new LinkedList<Element>(); + NodeList nlist = node.getChildNodes(); + for (int i = 0; i < nlist.getLength(); i++) + { + Node child = nlist.item(i); + if (child.getNodeType() == Node.ELEMENT_NODE) + list.add((Element)child); + } + return list.iterator(); + } + + /** Get the concatenated text content, or null. + */ + public static String getTextContent(Node node) + { + boolean hasTextContent = false; + StringBuffer buffer = new StringBuffer(); + NodeList nlist = node.getChildNodes(); + for (int i = 0; i < nlist.getLength(); i++) + { + Node child = nlist.item(i); + if (child.getNodeType() == Node.TEXT_NODE) + { + buffer.append(child.getNodeValue()); + hasTextContent = true; + } + } + return (hasTextContent ? buffer.toString() : null); + } + + /** Gets the first child element + */ + public static Element getFirstChildElement(Node node) + { + return getFirstChildElement(node, false); + } + + /** Gets the first child element + */ + public static Element getFirstChildElement(Node node, boolean recursive) + { + return getFirstChildElementIntern(node, null, recursive); + } + + /** Gets the first child element for a given local name without namespace + */ + public static Element getFirstChildElement(Node node, String nodeName) + { + return getFirstChildElement(node, nodeName, false); + } + + /** Gets the first child element for a given local name without namespace + */ + public static Element getFirstChildElement(Node node, String nodeName, boolean recursive) + { + return getFirstChildElementIntern(node, new QName(nodeName), recursive); + } + + /** Gets the first child element for a given qname + */ + public static Element getFirstChildElement(Node node, QName nodeName) + { + return getFirstChildElement(node, nodeName, false); + } + + /** Gets the first child element for a given qname + */ + public static Element getFirstChildElement(Node node, QName nodeName, boolean recursive) + { + return getFirstChildElementIntern(node, nodeName, recursive); + } + + private static Element getFirstChildElementIntern(Node node, QName nodeName, boolean recursive) + { + Element childElement = null; + Iterator it = getChildElementsIntern(node, nodeName, recursive); + if (it.hasNext()) + { + childElement = (Element)it.next(); + } + return childElement; + } + + /** Gets the child elements for a given local name without namespace + */ + public static Iterator getChildElements(Node node, String nodeName) + { + return getChildElements(node, nodeName, false); + } + + /** Gets the child elements for a given local name without namespace + */ + public static Iterator getChildElements(Node node, String nodeName, boolean recursive) + { + return getChildElementsIntern(node, new QName(nodeName), recursive); + } + + /** Gets the child element for a given qname + */ + public static Iterator getChildElements(Node node, QName nodeName) + { + return getChildElements(node, nodeName, false); + } + + /** Gets the child element for a given qname + */ + public static Iterator getChildElements(Node node, QName nodeName, boolean recursive) + { + return getChildElementsIntern(node, nodeName, recursive); + } + + public static List<Element> getChildElementsAsList(Node node, String nodeName) + { + return getChildElementsAsList(node, nodeName, false); + } + + public static List<Element> getChildElementsAsList(Node node, String nodeName, boolean recursive) + { + return getChildElementsAsListIntern(node, new QName(nodeName), recursive); + } + + public static List<Element> getChildElementsAsList(Node node, QName nodeName) + { + return getChildElementsAsList(node, nodeName, false); + } + + public static List<Element> getChildElementsAsList(Node node, QName nodeName, boolean recursive) + { + return getChildElementsAsListIntern(node, nodeName, recursive); + } + + private static List<Element> getChildElementsAsListIntern(Node node, QName nodeName, boolean recursive) + { + List<Element> list = new LinkedList<Element>(); + NodeList nlist = node.getChildNodes(); + for (int i = 0; i < nlist.getLength(); i++) + { + Node child = nlist.item(i); + if (child.getNodeType() == Node.ELEMENT_NODE) + { + search(list, (Element)child, nodeName, recursive); + } + } + return list; + } + + private static void search(List<Element> list, Element baseElement, QName nodeName, boolean recursive) + { + if (nodeName == null) + { + list.add(baseElement); + } + else + { + QName qname; + if (nodeName.getNamespaceURI().length() > 0) + { + qname = new QName(baseElement.getNamespaceURI(), baseElement.getLocalName()); + } + else + { + qname = new QName(baseElement.getLocalName()); + } + if (qname.equals(nodeName)) + { + list.add(baseElement); + } + } + if (recursive) + { + NodeList nlist = baseElement.getChildNodes(); + for (int i = 0; i < nlist.getLength(); i++) + { + Node child = nlist.item(i); + if (child.getNodeType() == Node.ELEMENT_NODE) + { + search(list, (Element)child, nodeName, recursive); + } + } + } + } + + private static Iterator getChildElementsIntern(Node node, QName nodeName, boolean recursive) + { + return getChildElementsAsListIntern(node, nodeName, recursive).iterator(); + } + + /** Gets parent element or null if there is none + */ + public static Element getParentElement(Node node) + { + Node parent = node.getParentNode(); + return (parent instanceof Element ? (Element)parent : null); + } + + /** Get the owner document that is associated with the current thread */ + public static Document getOwnerDocument() + { + Document doc = documentThreadLocal.get(); + if (doc == null) + { + doc = getDocumentBuilder().newDocument(); + documentThreadLocal.set(doc); + } + return doc; + } + + public static Element sourceToElement(Source source) throws IOException + { + Element retElement = null; + + try + { + if (source instanceof StreamSource) + { + StreamSource streamSource = (StreamSource)source; + + InputStream ins = streamSource.getInputStream(); + if (ins != null) + { + retElement = parse(ins); + } + else + { + Reader reader = streamSource.getReader(); + retElement = parse(new InputSource(reader)); + } + } + else if (source instanceof DOMSource) + { + DOMSource domSource = (DOMSource)source; + Node node = domSource.getNode(); + if (node instanceof Element) + { + retElement = (Element)node; + } + else if (node instanceof Document) + { + retElement = ((Document)node).getDocumentElement(); + } + else + { + throw new RuntimeException("Unsupported Node type: " + node.getClass().getName()); + } + } + else if (source instanceof SAXSource) + { + // The fact that JAXBSource derives from SAXSource is an implementation detail. + // Thus in general applications are strongly discouraged from accessing methods defined on SAXSource. + // The XMLReader object obtained by the getXMLReader method shall be used only for parsing the InputSource object returned by the getInputSource method. + + TransformerFactory tf = TransformerFactory.newInstance(); + ByteArrayOutputStream baos = new ByteArrayOutputStream(1024); + Transformer transformer = tf.newTransformer(); + transformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "yes"); + transformer.setOutputProperty(OutputKeys.METHOD, "xml"); + transformer.transform(source, new StreamResult(baos)); + retElement = parse(new ByteArrayInputStream(baos.toByteArray())); + } + else + { + throw new RuntimeException("Source type not implemented: " + source.getClass().getName()); + } + + } + catch (TransformerException ex) + { + IOException ioex = new IOException(); + ioex.initCause(ex); + throw ioex; + } + + return retElement; + } +} \ No newline at end of file Added: jbpm4/trunk/modules/test-db/src/test/java/reporting/SQLStmtTest.java =================================================================== --- jbpm4/trunk/modules/test-db/src/test/java/reporting/SQLStmtTest.java (rev 0) +++ jbpm4/trunk/modules/test-db/src/test/java/reporting/SQLStmtTest.java 2009-06-22 10:35:34 UTC (rev 5070) @@ -0,0 +1,232 @@ +package reporting;/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file in the + * distribution for a full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ + +import junit.framework.TestCase; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; +import org.xml.sax.SAXException; + +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import javax.xml.parsers.ParserConfigurationException; +import java.io.InputStream; +import java.io.IOException; +import java.util.ArrayList; +import java.util.LinkedList; +import java.util.List; +import java.util.Properties; +import java.sql.*; + +/** + * Parse the birt report templates, extract SQL statements and execute against database. + * + * @author Heiko.Braun <heiko.braun(a)jboss.com&gt; + */ +public class SQLStmtTest extends TestCase +{ + private static final String OVERALL_ACTIVITY_RPTDESIGN = "overall_activity.rptdesign"; + + private static final String PROCESS_SUMMARY_RPTDESIGN = "process_summary.rptdesign"; + + private Connection conn; + + static boolean skipTests; + + protected void setUp() throws Exception + { + InputStream in = + Thread.currentThread().getContextClassLoader() + .getResourceAsStream("jbpm.hibernate.cfg.xml"); + + if(null==in) + fail("Failed to read jbpm.hibernate.cfg.xml"); + + Document hibnCfg = parseTemplate(in); + Properties jdbcProps = getConnectionSettings(hibnCfg); + + // create connection + Class.forName(jdbcProps.getProperty("hibernate.connection.driver_class")); + this.conn = DriverManager.getConnection( + jdbcProps.getProperty("hibernate.connection.url"), + jdbcProps.getProperty("hibernate.connection.username"), + jdbcProps.getProperty("hibernate.connection.password") + ); + } + + + protected void tearDown() throws Exception + { + if(this.conn!=null) + { + conn.close(); + } + } + + public void testOverallActivityReport_Statements() throws Exception + { + InputStream in = + Thread.currentThread().getContextClassLoader() + .getResourceAsStream(OVERALL_ACTIVITY_RPTDESIGN); + assertNotNull("Unable to find report:"+OVERALL_ACTIVITY_RPTDESIGN, in); + + Document doc = parseTemplate(in); + + List<Element> queryTextElements = getQueryTextElements(doc); + assertFalse("No query strings found in template", queryTextElements.isEmpty()); + + for(Element query : queryTextElements) + { + executeQuery(query.getTextContent()); + } + } + + public void testProcessSummaryReport_Statements() throws Exception + { + if(skipTests) return; + + InputStream in = + Thread.currentThread().getContextClassLoader() + .getResourceAsStream(PROCESS_SUMMARY_RPTDESIGN); + assertNotNull("Unable to find report:"+PROCESS_SUMMARY_RPTDESIGN, in); + + Document doc = parseTemplate(in); + + List<Element> queryTextElements = getQueryTextElements(doc); + assertFalse("No query strings found in template", queryTextElements.isEmpty()); + + for(Element query : queryTextElements) + { + executeQuery(query.getTextContent()); + } + } + + private void executeQuery(String sql) throws SQLException + { + + System.out.println("Execute:"); + System.out.println(sql); + + PreparedStatement stmt = conn.prepareStatement(sql); + ParameterMetaData metaData = stmt.getParameterMetaData(); + for(int i=1; i<metaData.getParameterCount()+1; i++) + { + stmt.setString(i, "PLACEHOLDER_STRING"); + } + + // run it + ResultSet rs = stmt.executeQuery(); + System.out.println(""); + System.out.println("Result size:" +rs.getFetchSize()); + System.out.println("--"); + } + + private List<Element> getQueryTextElements(Document doc) + { + List<Element> props = new ArrayList<Element>(); + dfsElementSearch(props, doc.getDocumentElement(), + new Filter() + { + public boolean select(Element candidate) + { + return candidate.getNodeName().equals("property") + && DOMUtils.getAttributeValue(candidate, "name").equals("queryText"); + } + }); + return props; + } + + private Properties getConnectionSettings(Document doc) + { + List<Element> props = new ArrayList<Element>(); + dfsElementSearch(props, doc.getDocumentElement(), + new Filter() + { + public boolean select(Element candidate) + { + return candidate.getNodeName().equals("property") + && DOMUtils.getAttributeValue(candidate, "name").startsWith("hibernate.connection"); + } + }); + + Properties connectionSettings = new Properties(); + for(Element el : props) + { + connectionSettings.put( + DOMUtils.getAttributeValue(el, "name"), + el.getTextContent() + ); + } + + return connectionSettings; + } + + + private Document parseTemplate(InputStream in) + throws ParserConfigurationException, SAXException, IOException + { + DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); + factory.setValidating(false); + factory.setNamespaceAware(true); + DocumentBuilder builder = factory.newDocumentBuilder(); + Document doc = builder.parse(in); + return doc; + } + + private static void dfsElementSearch(List<Element> resultBuffer, Element root, Filter filter) + { + if( filter.select(root) ) + { + resultBuffer.add(root); + return; + } + + List<Element> children = getChildElements(root); + for(Element child : children) + { + dfsElementSearch(resultBuffer, child, filter); + } + } + + private static List<Element> getChildElements(Node node) + { + List<Element> list = new LinkedList<Element>(); + NodeList nlist = node.getChildNodes(); + for (int i = 0; i < nlist.getLength(); i++) + { + Node child = nlist.item(i); + if (child.getNodeType() == Node.ELEMENT_NODE) + { + list.add((Element)child); + } + } + return list; + } + + interface Filter + { + boolean select(Element candidate); + } + + +}