public static void main(String[] args) throws Exception {
- Table t1 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 399, -1);
+ Table t1 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 260, -1);
// t1.initTable();
t1.rebuild();
+
String a = "bulb";
IoTString ia = new IoTString(a);
- t1.createNewKey(ia, 399);
+ t1.createNewKey(ia, 260);
t1.update();
-
-
String valueA = "on";
IoTString iValueA = new IoTString(valueA);
-
-
IoTString testValA1 = t1.getCommitted(ia);
- if ((testValA1 != null) && (testValA1.equals(iValueA) == true)) {
- System.out.println("Is True");
- } else {
- System.out.println("Is False or Null");
- }
-
-
-
t1.startTransaction();
t1.addKV(ia, iValueA);
t1.commitTransaction();
-
+
t1.update();
- testValA1 = t1.getCommitted(ia);
-
- if ((testValA1 != null) && (testValA1.equals(iValueA) == true)) {
- System.out.println("Is True");
- } else {
- System.out.println("Is False or Null");
- }
-
}
-}
\ No newline at end of file
+}
--- /dev/null
+import iotcloud.*;
+
+class Controller2 {
+ public static void main(String[] args) throws Exception {
+
+
+ Table t1 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 260, -1);
+ // t1.initTable();
+ t1.rebuild();
+
+ String a = "bulb";
+ IoTString ia = new IoTString(a);
+ t1.createNewKey(ia, 260);
+
+ t1.update();
+
+ String valueB = "off";
+ IoTString iValueB = new IoTString(valueB);
+
+ t1.startTransaction();
+ t1.addKV(ia, iValueB);
+ t1.commitTransaction();
+
+
+ t1.update();
+ }
+
+}
--- /dev/null
+import iotcloud.*;
+import java.util.Set;
+import java.util.HashSet;
+
+class Read {
+ public static void main(String[] args) throws Exception {
+
+
+ Table t1 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 41567, -1);
+ // t1.initTable();
+ t1.rebuild();
+
+ Set<IoTString> keySet = t1.getKeys();
+ int i = 1;
+ for(IoTString key : keySet) {
+ System.out.print(i + "- Key: " + key.toString() + " -> ");
+ IoTString val = t1.getCommitted(key);
+ System.out.println("Value: " + val.toString());
+ i = i + 1;
+ }
+ }
+}
public static void main(String[] args) throws Exception {
- Table t1 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 321, -1);
+ Table t1 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 400, -1);
t1.initTable();
+ String a = "bulb";
+ IoTString ia = new IoTString(a);
- // for ( int i = 0; i < 150; i++) {
-
- // System.out.println(i);
+ t1.createNewKey(ia, 400);
- // String a1 = "bulb" + i;
- // IoTString ia1 = new IoTString(a1);
- // t1.createNewKey(ia1, 321);
- // t1.update();
-
-
- // // t1.update();
- // // t1.startTransaction();
- // // t1.addKV(ia1, ia1);
- // // t1.commitTransaction();
-
- // }
-
-
- String a1 = "bulb1";
- String a2 = "bulb2";
- String a3 = "bulb3";
- IoTString ia1 = new IoTString(a1);
- IoTString ia2 = new IoTString(a2);
- IoTString ia3 = new IoTString(a3);
-
-
-
- String b1 = "wemo1";
- String b2 = "wemo2";
- IoTString ib1 = new IoTString(b1);
- IoTString ib2 = new IoTString(b2);
-
-
- String c1 = "sensor";
- IoTString ic1 = new IoTString(c1);
-
-
- String pingTimerKey = "bulbController";
- IoTString ipingTimerKey = new IoTString(pingTimerKey);
-
-
- String pingTimerKey2 = "wemoController";
- IoTString ipingTimerKey2 = new IoTString(pingTimerKey2);
-
-
- String pingTimerKey3 = "sensorController";
- IoTString ipingTimerKey3 = new IoTString(pingTimerKey3);
-
-
- t1.createNewKey(ia1, 321);
- t1.createNewKey(ia2, 321);
- t1.createNewKey(ia3, 321);
- t1.createNewKey(ipingTimerKey, 321);
-
- t1.createNewKey(ib1, 351);
- t1.createNewKey(ib2, 351);
- t1.createNewKey(ipingTimerKey2, 351);
-
-
- t1.createNewKey(ic1, 361);
- t1.createNewKey(ipingTimerKey3, 361);
+ String valueA = "on";
+ IoTString iValueA = new IoTString(valueA);
+ IoTString testValA1 = t1.getCommitted(ia);
+
+ t1.startTransaction();
+ t1.addKV(ia, iValueA);
+ t1.commitTransaction();
t1.update();
}
-}
\ No newline at end of file
+}