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