util/src/test/java/org/apache/etch/util/core/xml/testJaxp.java

/* $Id$
 *
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements. See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership. The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License. You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied. See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

package org.apache.etch.util.core.xml;

import java.io.StringReader;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;

import org.apache.etch.util.Timer;
import org.w3c.dom.CharacterData;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.xml.sax.InputSource;


/**
 * Description of testJaxp.
 */
public class testJaxp
{
	/**
	 * @param args
	 * @throws Exception
	 */
	public static void main( String[] args )
		throws Exception
	{
		DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
		DocumentBuilder db = dbf.newDocumentBuilder();
		Document d = db.parse( new InputSource( new StringReader( "<x>blah</x>" ) ) );
		System.out.println( "d = "+d );
		dump( d );
		
		dump( parse( db, TEST_MSG ) );
		
		if (false) return;
		
		int m = 5;
		int n = 50000*4;
		for (int j = 0; j < m; j++)
		{
			if (j != 0)
				Thread.sleep( 5000 );
			
			long t0 = Timer.currentTimeMillis();
			for (int i = 0; i < n; i += 4)
			{
				parse( db, TEST_MSG );
				parse( db, TEST_MSG );
				parse( db, TEST_MSG );
				parse( db, TEST_MSG );
			}
			long t1 = Timer.currentTimeMillis();
			
			double t = (t1-t0)/1000.0;
			double r = n / t;
			System.out.println( "took "+t+" for "+n+" iterations ("+r+" per second)" );
		}
	}
	
	private static void dump( Document d )
	{
		dump( "", d.getDocumentElement() );
		
	}

	private static void dump( String prefix, Element e )
	{
		System.out.println( prefix+"start of element name="+e.getTagName() );
		
		NamedNodeMap attrs = e.getAttributes();
		int n = attrs.getLength();
		for (int i = 0; i < n; i++)
		{
			Node a = attrs.item( i );
			System.out.println( prefix+"  attr name '"+a.getNodeName()+"' value '"+a.getNodeValue()+"'" );
		}
		
		NodeList nl = e.getChildNodes();
		n = nl.getLength();
		for (int i = 0; i < n; i++)
		{
			Node sn = nl.item( i );
			if (sn instanceof Element)
				dump( prefix+"  ", (Element) sn );
			else
				dump( prefix+"  ", (CharacterData ) sn );
		}
		
		System.out.println( prefix+"end of element name="+e.getTagName() );
	}

	private static void dump( String prefix, CharacterData data )
	{
		System.out.println( prefix+"data = '"+data+"'" );
	}

	private static Document parse( DocumentBuilder db, String msg ) throws Exception
	{
		return db.parse( new InputSource( new StringReader( msg ) ) );
	}

	private final static String TEST_MSG =
		"<message>" +
			"<messageId>connect</messageId>" +
			"<field name='machineName'>xxx</field>" +
			"<field name='queueName'>xxx</field>" +
			"<field name='heartbeatInterval'>10</field>" +
			"<field name='heartbeatPayload'>mediaResources</field>" +
			"<field name='serverId'>1</field>" +
			"<field name='transactionId'>1</field>" +
		"</message>";
}