1 /*******************************************************************************
\r
2 * Copyright (c) 2007, 2011 Association for Decentralized Information Management in
\r
4 * All rights reserved. This program and the accompanying materials
\r
5 * are made available under the terms of the Eclipse Public License v1.0
\r
6 * which accompanies this distribution, and is available at
\r
7 * http://www.eclipse.org/legal/epl-v10.html
\r
10 * VTT Technical Research Centre of Finland - initial API and implementation
\r
11 *******************************************************************************/
\r
12 package org.simantics.history.examples;
\r
14 import java.io.File;
\r
16 import org.simantics.databoard.Bindings;
\r
17 import org.simantics.databoard.Datatypes;
\r
18 import org.simantics.databoard.accessor.StreamAccessor;
\r
19 import org.simantics.databoard.binding.Binding;
\r
20 import org.simantics.databoard.type.Datatype;
\r
21 import org.simantics.databoard.type.RecordType;
\r
22 import org.simantics.databoard.util.Bean;
\r
23 import org.simantics.history.Collector;
\r
24 import org.simantics.history.History;
\r
25 import org.simantics.history.HistoryManager;
\r
26 import org.simantics.history.ItemManager;
\r
27 import org.simantics.history.impl.CollectorImpl;
\r
28 import org.simantics.history.util.subscription.SubscriptionItem;
\r
29 import org.simantics.history.util.subscription.SamplingFormat;
\r
30 import org.simantics.utils.FileUtils;
\r
32 public class HistoryExample2 {
\r
34 public static void main(String[] args) throws Exception {
\r
36 //// Create sampling formats
\r
37 // Simple format captures all samples, no min/max/avg/median
\r
38 SamplingFormat simpleFormat, intervalFormat;
\r
39 simpleFormat = new SamplingFormat();
\r
40 RecordType format = (RecordType) (simpleFormat.format = new RecordType());
\r
41 format.addComponent("time", Datatypes.DOUBLE);
\r
42 format.addComponent("value", Datatypes.DOUBLE );
\r
43 format.addComponent("quality", Datatypes.BYTE );
\r
44 simpleFormat.interval = Double.NaN;
\r
45 simpleFormat.deadband = Double.NaN;
\r
46 simpleFormat.formatId = "Simple";
\r
48 // Interval format captures samples with 0.5s interval. It also calculates min/max/avg/median
\r
49 intervalFormat = new SamplingFormat();
\r
50 format = (RecordType) (intervalFormat.format = new RecordType());
\r
51 format.addComponent("time", Datatypes.DOUBLE);
\r
52 format.addComponent("endTime", Datatypes.DOUBLE);
\r
53 format.addComponent("value", Datatypes.DOUBLE );
\r
54 format.addComponent("lastValue", Datatypes.DOUBLE);
\r
55 format.addComponent("min", Datatypes.DOUBLE);
\r
56 format.addComponent("max", Datatypes.DOUBLE);
\r
57 format.addComponent("avg", Datatypes.DOUBLE);
\r
58 format.addComponent("median", Datatypes.DOUBLE);
\r
59 format.addComponent("quality", Datatypes.BYTE );
\r
60 format.addComponent("count", Datatypes.INTEGER);
\r
61 intervalFormat.interval = Double.NaN;
\r
62 intervalFormat.deadband = Double.NaN;
\r
63 intervalFormat.interval = 0.5;
\r
64 intervalFormat.formatId = "Interval";
\r
66 //// Create item descriptions
\r
67 SubscriptionItem[] items = SubscriptionItem.createItems("Variable", "MySubscription", simpleFormat, intervalFormat);
\r
70 ItemManager im = new ItemManager( items );
\r
71 im.search("groupId", "MySubscription");
\r
73 //// Open file history & initialize subscription
\r
74 File workarea = FileUtils.createTmpDir();
\r
75 HistoryManager historian = History.openFileHistory( workarea );
\r
76 historian.create( items );
\r
79 Collector collector = new CollectorImpl( historian );
\r
80 collector.addItems( items );
\r
82 double NaN = Double.NaN;
\r
83 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
85 for (int i=0; i<data.length; i++)
\r
87 collector.beginStep(Bindings.DOUBLE, i * 0.1);
\r
88 collector.setValue("Variable", Bindings.DOUBLE, data[i]);
\r
89 collector.endStep();
\r
96 // Open accessor to the data, read & print data.
\r
97 System.out.println("IntervalFormat = "+intervalFormat.toString());
\r
98 StreamAccessor sa = historian.openStream( items[1].id, "r" );
\r
101 Datatype sampleType = sa.type().componentType;
\r
102 Binding beanBinding = Bindings.getBeanBinding( sampleType );
\r
103 Bean sample = (Bean) beanBinding.createDefault();
\r
104 for (int i=0; i<sa.size(); i++) {
\r
105 sa.get(i, beanBinding, sample);
\r
106 System.out.println( sample );
\r
112 // The data can also be read using generic binding
\r
113 System.out.println("\nSimpleFormat = "+simpleFormat.toString());
\r
114 sa = historian.openStream(items[0].id, "r");
\r
117 Binding b = Bindings.getBinding( simpleFormat.format );
\r
118 Object sample = b.createDefault();
\r
119 for (int i=0; i<sa.size(); i++) {
\r
120 sa.get(i, b, sample);
\r
121 System.out.println( b.toString(sample) );
\r