Migrated source code from Simantics SVN

[simantics/platform.git] / bundles / org.simantics.history / examples / org / simantics / history / examples / HistoryExample2.java

diff --git a/bundles/org.simantics.history/examples/org/simantics/history/examples/HistoryExample2.java b/bundles/org.simantics.history/examples/org/simantics/history/examples/HistoryExample2.java
new file mode 100644 (file)
index 0000000..4f64dc3
--- /dev/null
+++ b/bundles/org.simantics.history/examples/org/simantics/history/examples/HistoryExample2.java
@@ -0,0 +1,130 @@
+/*******************************************************************************\r
+ * Copyright (c) 2007, 2011 Association for Decentralized Information Management in\r
+ * Industry THTH ry.\r
+ * All rights reserved. This program and the accompanying materials\r
+ * are made available under the terms of the Eclipse Public License v1.0\r
+ * which accompanies this distribution, and is available at\r
+ * http://www.eclipse.org/legal/epl-v10.html\r
+ *\r
+ * Contributors:\r
+ *     VTT Technical Research Centre of Finland - initial API and implementation\r
+ *******************************************************************************/\r
+package org.simantics.history.examples;\r
+\r
+import java.io.File;\r
+\r
+import org.simantics.databoard.Bindings;\r
+import org.simantics.databoard.Datatypes;\r
+import org.simantics.databoard.accessor.StreamAccessor;\r
+import org.simantics.databoard.binding.Binding;\r
+import org.simantics.databoard.type.Datatype;\r
+import org.simantics.databoard.type.RecordType;\r
+import org.simantics.databoard.util.Bean;\r
+import org.simantics.history.Collector;\r
+import org.simantics.history.History;\r
+import org.simantics.history.HistoryManager;\r
+import org.simantics.history.ItemManager;\r
+import org.simantics.history.impl.CollectorImpl;\r
+import org.simantics.history.util.subscription.SubscriptionItem;\r
+import org.simantics.history.util.subscription.SamplingFormat;\r
+import org.simantics.utils.FileUtils;\r
+\r
+public class HistoryExample2 {\r
+               \r
+       public static void main(String[] args) throws Exception {\r
+               \r
+               //// Create sampling formats            \r
+               // Simple format captures all samples, no min/max/avg/median \r
+               SamplingFormat simpleFormat, intervalFormat;\r
+               simpleFormat = new SamplingFormat();\r
+               RecordType format = (RecordType) (simpleFormat.format = new RecordType());\r
+               format.addComponent("time", Datatypes.DOUBLE);\r
+               format.addComponent("value", Datatypes.DOUBLE );\r
+               format.addComponent("quality", Datatypes.BYTE );\r
+               simpleFormat.interval = Double.NaN;\r
+               simpleFormat.deadband = Double.NaN;\r
+               simpleFormat.formatId = "Simple";\r
+               \r
+               // Interval format captures samples with 0.5s interval. It also calculates min/max/avg/median \r
+               intervalFormat = new SamplingFormat();\r
+               format = (RecordType) (intervalFormat.format = new RecordType());\r
+               format.addComponent("time", Datatypes.DOUBLE);\r
+               format.addComponent("endTime", Datatypes.DOUBLE);\r
+               format.addComponent("value", Datatypes.DOUBLE );\r
+               format.addComponent("lastValue", Datatypes.DOUBLE);             \r
+               format.addComponent("min", Datatypes.DOUBLE);\r
+               format.addComponent("max", Datatypes.DOUBLE);\r
+               format.addComponent("avg", Datatypes.DOUBLE);\r
+               format.addComponent("median", Datatypes.DOUBLE);\r
+               format.addComponent("quality", Datatypes.BYTE );\r
+               format.addComponent("count", Datatypes.INTEGER);\r
+               intervalFormat.interval = Double.NaN;\r
+               intervalFormat.deadband = Double.NaN;\r
+               intervalFormat.interval = 0.5;\r
+               intervalFormat.formatId = "Interval";\r
+               \r
+               //// Create item descriptions\r
+               SubscriptionItem[] items = SubscriptionItem.createItems("Variable", "MySubscription", simpleFormat, intervalFormat);\r
+\r
+               // Manage items\r
+               ItemManager im = new ItemManager( items );\r
+               im.search("groupId", "MySubscription");\r
+               \r
+               //// Open file history & initialize subscription \r
+               File workarea = FileUtils.createTmpDir();\r
+               HistoryManager historian = History.openFileHistory( workarea );\r
+               historian.create( items );\r
+                               \r
+               //// Record data\r
+               Collector collector = new CollectorImpl( historian );\r
+               collector.addItems( items );\r
+               try {\r
+                       double NaN = Double.NaN;\r
+                       double[] data = { 5.0, 5.0, 5.0, 5.0, 6.0, 6.0, 6.0, 7.0, 8.0, 9.0, NaN,10.0, NaN, NaN, NaN };\r
+\r
+                       for (int i=0; i<data.length; i++) \r
+                       {\r
+                               collector.beginStep(Bindings.DOUBLE, i * 0.1);\r
+                               collector.setValue("Variable", Bindings.DOUBLE, data[i]);\r
+                               collector.endStep();\r
+                       }\r
+                       \r
+               } finally {\r
+                       collector.close();\r
+               }\r
+               \r
+               // Open accessor to the data, read & print data.\r
+               System.out.println("IntervalFormat = "+intervalFormat.toString());\r
+               StreamAccessor sa = historian.openStream( items[1].id, "r" );\r
+               try {                   \r
+                       sa.reset();\r
+                       Datatype sampleType = sa.type().componentType;\r
+                       Binding beanBinding = Bindings.getBeanBinding( sampleType );\r
+                       Bean sample = (Bean) beanBinding.createDefault();\r
+                       for (int i=0; i<sa.size(); i++) {\r
+                               sa.get(i, beanBinding, sample);\r
+                               System.out.println( sample );\r
+                       }\r
+               } finally {\r
+                       sa.close();\r
+               }\r
+                               \r
+               // The data can also be read using generic binding\r
+               System.out.println("\nSimpleFormat = "+simpleFormat.toString());\r
+               sa = historian.openStream(items[0].id, "r");\r
+               try {                   \r
+                       sa.reset();\r
+                       Binding b = Bindings.getBinding( simpleFormat.format );\r
+                       Object sample = b.createDefault();\r
+                       for (int i=0; i<sa.size(); i++) {\r
+                               sa.get(i, b, sample);\r
+                               System.out.println( b.toString(sample) );\r
+                       }\r
+               } finally {\r
+                       sa.close();\r
+               }\r
+               \r
+               \r
+       }\r
+\r
+}\r