From b086f57f56bf0eb9dab9cf321a0f69aaaae84347 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew.branson@cern.ch>
Date: Wed, 30 May 2012 08:37:45 +0200
Subject: Initial Maven Conversion

---
 .../com/c2kernel/persistency/outcome/Outcome.java  | 177 +++++++++++++++++++++
 1 file changed, 177 insertions(+)
 create mode 100644 src/main/java/com/c2kernel/persistency/outcome/Outcome.java

(limited to 'src/main/java/com/c2kernel/persistency/outcome/Outcome.java')

diff --git a/src/main/java/com/c2kernel/persistency/outcome/Outcome.java b/src/main/java/com/c2kernel/persistency/outcome/Outcome.java
new file mode 100644
index 0000000..d321f69
--- /dev/null
+++ b/src/main/java/com/c2kernel/persistency/outcome/Outcome.java
@@ -0,0 +1,177 @@
+package com.c2kernel.persistency.outcome;
+import java.io.StringReader;
+import java.io.StringWriter;
+import java.util.StringTokenizer;
+
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+
+import org.apache.xml.serialize.Method;
+import org.apache.xml.serialize.OutputFormat;
+import org.apache.xml.serialize.XMLSerializer;
+import org.w3c.dom.Document;
+import org.w3c.dom.NodeList;
+import org.w3c.dom.Text;
+import org.xml.sax.InputSource;
+
+import com.c2kernel.common.PersistencyException;
+import com.c2kernel.entity.C2KLocalObject;
+import com.c2kernel.persistency.ClusterStorage;
+import com.c2kernel.utils.Logger;
+
+public class Outcome implements C2KLocalObject {
+    int mID = -1;
+    String mData;
+    String mSchemaType;
+    int mSchemaVersion;
+    Document dom;
+    static DocumentBuilder parser;
+
+    static {
+        DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
+        dbf.setValidating(false);
+        dbf.setNamespaceAware(false);
+        try {
+            parser = dbf.newDocumentBuilder();
+        } catch (ParserConfigurationException e) {
+            Logger.error(e);
+        }
+    }
+
+    //id is the eventID
+    public Outcome(int id, String data, String schemaType, int schemaVersion) {
+        mID = id;
+        mData = data;
+        mSchemaType = schemaType;
+        mSchemaVersion = schemaVersion;
+    }
+
+    public Outcome(String path, String data) throws PersistencyException {
+    // derive all the meta data from the path
+        StringTokenizer tok = new StringTokenizer(path,"/");
+        if (tok.countTokens() != 3 && !(tok.nextToken().equals("Outcome")))
+            throw new PersistencyException("Outcome() - Outcome path must have three components: "+path, null);
+        mSchemaType = tok.nextToken();
+        String verstring = tok.nextToken();
+        String objId = tok.nextToken();
+        try {
+            mSchemaVersion = Integer.parseInt(verstring);
+        } catch (NumberFormatException ex) {
+            throw new PersistencyException("Outcome() - Outcome version was an invalid number: "+verstring, null);
+        }
+        try {
+            mID = Integer.parseInt(objId);
+        } catch (NumberFormatException ex) {
+            mID = -1;
+        }
+        mData = data;
+    }
+
+    public void setID(int ID) {
+        mID = ID;
+    }
+
+    public int getID() {
+        return mID;
+    }
+
+    @Override
+	public void setName(String name) {
+    	try {
+    		mID = Integer.parseInt(name);
+    	} catch (NumberFormatException e) {
+    		Logger.error("Invalid id set on Outcome:"+name);
+    	}
+    }
+
+    @Override
+	public String getName() {
+        return String.valueOf(mID);
+    }
+
+    public void setData(String data) {
+        mData = data;
+        dom = null;
+    }
+
+    public void setData(Document data) {
+        mData = serialize(data, false);
+        dom = data;
+    }
+
+    public String getData() {
+        return mData;
+    }
+
+    public void setSchemaType(String schemaType) {
+        mSchemaType = schemaType;
+    }
+
+    public String getSchemaType() {
+        return mSchemaType;
+    }
+
+    public void setSchemaURL(int schemaVersion) {
+        mSchemaVersion = schemaVersion;
+    }
+
+    public int getSchemaVersion() {
+        return mSchemaVersion;
+    }
+
+    public void setSchemaVersion(int schVer) {
+        mSchemaVersion = schVer;
+    }
+
+	@Override
+	public String getClusterType() {
+		return ClusterStorage.OUTCOME;
+	}
+
+    // special script API methods
+
+    /**
+     * Parses the outcome into a DOM tree
+     * @return a DOM Document
+     */
+    public Document getDOM() {
+    	if (dom == null)
+        try {
+            synchronized (parser) {
+                dom = parser.parse(new InputSource(new StringReader(mData)));
+            }
+        } catch (Exception e) {
+            Logger.error(e);
+            return null;
+        }
+    	return dom;
+    }
+    
+    public String getField(String name) {
+    	 NodeList elements = getDOM().getDocumentElement().getElementsByTagName(name);
+    	 if (elements.getLength() == 1 && elements.item(0).hasChildNodes() && elements.item(0).getFirstChild() instanceof Text)
+    		 return ((Text)elements.item(0).getFirstChild()).getData();
+    	 else
+    		 return null;
+    }
+
+    static public String serialize(Document doc, boolean prettyPrint)
+    {
+        String serializedDoc = null;
+        OutputFormat format = new OutputFormat(Method.XML, null, prettyPrint);
+        StringWriter stringOut = new StringWriter();
+        XMLSerializer serial = new XMLSerializer(stringOut, format);
+        try
+        {
+            serial.asDOMSerializer();
+            serial.serialize(doc);
+        }
+        catch (java.io.IOException ex)
+        {
+            Logger.error(ex.toString());
+        }
+        serializedDoc = stringOut.toString();
+        return serializedDoc;
+    }
+}
-- 
cgit v1.2.3