|
180
|
1 package alice.jungle.log.example;
|
|
|
2
|
|
|
3 import java.io.File;
|
|
183
|
4 import java.io.FileNotFoundException;
|
|
180
|
5 import java.io.IOException;
|
|
|
6 import java.nio.ByteBuffer;
|
|
|
7 import java.util.Iterator;
|
|
|
8
|
|
|
9 import fj.Ord;
|
|
|
10 import fj.data.List;
|
|
|
11 import fj.data.TreeMap;
|
|
|
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.Jungle;
|
|
|
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree;
|
|
|
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTreeEditor;
|
|
|
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Children;
|
|
|
16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
|
|
|
17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader;
|
|
|
18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath;
|
|
|
19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultTreeEditor;
|
|
|
20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNode;
|
|
|
21 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNodeAttributes;
|
|
|
22 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultJungleTreeEditor;
|
|
|
23 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser;
|
|
|
24 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.InterfaceTraverser;
|
|
|
25 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
|
|
|
26 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
|
|
|
27 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Pair;
|
|
|
28 import jp.ac.u_ryukyu.ie.cr.tatsuki.jungle.query.Query;
|
|
|
29 import junit.framework.TestCase;
|
|
|
30 import alice.jungle.operations.NetworkNodePath;
|
|
|
31 import alice.jungle.persistent.PersistentJournal;
|
|
|
32 import alice.jungle.persistent.PersistentJungle;
|
|
|
33 import alice.jungle.transaction.JungleUpdater;
|
|
|
34 import app.bbs.NetworkBulletinBoard;
|
|
|
35 import app.bbs.NetworkJungleBulletinBoard;
|
|
|
36
|
|
|
37 public class FindMatrixTest extends TestCase {
|
|
|
38
|
|
183
|
39 public static void main(String[] args) throws IOException {
|
|
|
40 PersistentJournal journal = new PersistentJournal();
|
|
|
41 journal.setOutputFile(new File("./log/test.log"));
|
|
|
42 Jungle jungle = new PersistentJungle(journal, "uuid", new DefaultTreeEditor(new DefaultTraverser()));
|
|
180
|
43
|
|
183
|
44 String treeName = treeLoad(jungle);
|
|
|
45
|
|
|
46 JungleTree tree = jungle.getTreeByName(treeName);
|
|
|
47 InterfaceTraverser ifTraverser = tree.getTraverser();
|
|
|
48
|
|
|
49 Iterator<Pair<TreeNode, NodePath>> searchNode = ifTraverser.find(
|
|
184
|
50 (TreeNode node) -> {
|
|
|
51 ByteBuffer attribute = node.getAttributes().get("mes");
|
|
|
52 if(attribute != null){
|
|
|
53 byte[] byteAttribute = attribute.array();
|
|
|
54 String str = new String(byteAttribute);
|
|
|
55 System.out.println(str);
|
|
|
56 return str.equals("株式会社フタコ放送");
|
|
|
57 }
|
|
|
58 return false;
|
|
183
|
59 }
|
|
|
60 );
|
|
184
|
61
|
|
183
|
62 TreeNode node = searchNode.next().left();
|
|
|
63 byte[] nodeAttibute = node.getAttributes().get("mes").array();
|
|
|
64 System.out.println(new String(nodeAttibute));
|
|
|
65 }
|
|
|
66
|
|
|
67 public static String treeLoad(Jungle jungle) throws FileNotFoundException {
|
|
|
68 String treeName = null;
|
|
180
|
69
|
|
183
|
70 for (ChangeList chList : getChangeList()) {
|
|
180
|
71 treeName = chList.getTreeName();
|
|
183
|
72 JungleTree tree = jungle.getTreeByName(treeName);
|
|
|
73 if(tree == null) {
|
|
|
74 tree = jungle.createNewTree(treeName);
|
|
180
|
75 }
|
|
183
|
76 JungleTreeEditor editor2 = tree.getTreeEditor();
|
|
180
|
77 Either<Error, JungleTreeEditor> either2 = JungleUpdater.edit(editor2, chList);
|
|
|
78 assertFalse(either2.isA());
|
|
|
79 editor2 = either2.b();
|
|
|
80 editor2.success();
|
|
|
81 }
|
|
183
|
82 return treeName;
|
|
|
83 }
|
|
|
84
|
|
|
85 public static ChangeListReader getChangeList() throws FileNotFoundException {
|
|
|
86 PersistentJournal journal1 = new PersistentJournal();
|
|
|
87 journal1.setInputFile(new File("./_log_/1410589309338.log"));
|
|
|
88 ChangeListReader reader = journal1.getReader();
|
|
|
89 return reader;
|
|
|
90 }
|
|
180
|
91 }
|
