diff options
| author | yzhou <yzhou@krr-linux.cs.ox.ac.uk> | 2015-04-30 17:36:35 +0100 |
|---|---|---|
| committer | yzhou <yzhou@krr-linux.cs.ox.ac.uk> | 2015-04-30 17:36:35 +0100 |
| commit | 0d8f240c9c0a64f2285324e5a517161e45c698fc (patch) | |
| tree | f4b4f7078e3be02011b9812cd8791c657a135993 /test/uk/ac/ox/cs/data/Fragment.java | |
| parent | 68ae342b2a4923bc7b3f378c6a489f2355d85279 (diff) | |
| download | ACQuA-0d8f240c9c0a64f2285324e5a517161e45c698fc.tar.gz ACQuA-0d8f240c9c0a64f2285324e5a517161e45c698fc.zip | |
downgrade owl api and reorganised src files
Diffstat (limited to 'test/uk/ac/ox/cs/data/Fragment.java')
| -rw-r--r-- | test/uk/ac/ox/cs/data/Fragment.java | 129 |
1 files changed, 0 insertions, 129 deletions
diff --git a/test/uk/ac/ox/cs/data/Fragment.java b/test/uk/ac/ox/cs/data/Fragment.java deleted file mode 100644 index 1038a33..0000000 --- a/test/uk/ac/ox/cs/data/Fragment.java +++ /dev/null | |||
| @@ -1,129 +0,0 @@ | |||
| 1 | package uk.ac.ox.cs.data; | ||
| 2 | |||
| 3 | import java.io.File; | ||
| 4 | import java.io.FileInputStream; | ||
| 5 | import java.io.FileNotFoundException; | ||
| 6 | import java.io.FileOutputStream; | ||
| 7 | import java.util.Random; | ||
| 8 | |||
| 9 | import org.openrdf.model.Statement; | ||
| 10 | import org.openrdf.rio.RDFHandler; | ||
| 11 | import org.openrdf.rio.RDFHandlerException; | ||
| 12 | import org.openrdf.rio.turtle.TurtleParser; | ||
| 13 | import org.openrdf.rio.turtle.TurtleWriter; | ||
| 14 | |||
| 15 | import uk.ac.ox.cs.pagoda.util.Utility; | ||
| 16 | |||
| 17 | public class Fragment { | ||
| 18 | |||
| 19 | private TurtleWriter m_writer; | ||
| 20 | private FragmentRDFHandler m_handler; | ||
| 21 | |||
| 22 | public Fragment(int fragment, String outFile) { | ||
| 23 | try { | ||
| 24 | m_writer = new TurtleWriter(new FileOutputStream(outFile)); | ||
| 25 | } catch (FileNotFoundException e) { | ||
| 26 | e.printStackTrace(); | ||
| 27 | } | ||
| 28 | m_handler = new FragmentRDFHandler(fragment, m_writer); | ||
| 29 | } | ||
| 30 | |||
| 31 | public void process(String prefix, String fileName) { | ||
| 32 | FileInputStream istream; | ||
| 33 | try { | ||
| 34 | TurtleParser parser = new TurtleParser(); | ||
| 35 | parser.setRDFHandler(m_handler); | ||
| 36 | |||
| 37 | File f = new File(fileName); | ||
| 38 | if (f.isDirectory()) | ||
| 39 | for (String tFileName: f.list()) { | ||
| 40 | if (tFileName.endsWith(".ttl")) { | ||
| 41 | parser.parse(istream = new FileInputStream(fileName + Utility.FILE_SEPARATOR + tFileName), prefix); | ||
| 42 | istream.close(); | ||
| 43 | } | ||
| 44 | } | ||
| 45 | else { | ||
| 46 | parser.parse(istream = new FileInputStream(fileName), prefix); | ||
| 47 | istream.close(); | ||
| 48 | } | ||
| 49 | } catch (Exception e) { | ||
| 50 | e.printStackTrace(); | ||
| 51 | Utility.logError("aoaoaoao ~~~~~"); | ||
| 52 | return ; | ||
| 53 | } | ||
| 54 | Utility.logInfo("DONE"); | ||
| 55 | } | ||
| 56 | |||
| 57 | public void dispose() { | ||
| 58 | try { | ||
| 59 | m_writer.endRDF(); | ||
| 60 | } catch (RDFHandlerException e) { | ||
| 61 | e.printStackTrace(); | ||
| 62 | } | ||
| 63 | } | ||
| 64 | |||
| 65 | public static void main(String[] args) { | ||
| 66 | /** | ||
| 67 | * for ChEMBL | ||
| 68 | */ | ||
| 69 | Fragment f = new Fragment(100, "data_01.ttl"); | ||
| 70 | f.process("http://rdf.ebi.ac.uk/terms/chembl#", "/media/krr-nas-share/Yujiao/ontologies/bio2rdf/chembl/data"); | ||
| 71 | |||
| 72 | /** | ||
| 73 | * for Reactome | ||
| 74 | * "http://www.biopax.org/release/biopax-level3.owl#", | ||
| 75 | "/home/scratch/yzhou/ontologies/bio2rdf/reactome" | ||
| 76 | "/home/scratch/yzhou/ontologies/bio2rdf/reactome/biopaxrdf", | ||
| 77 | */ | ||
| 78 | |||
| 79 | // Fragment f = new Fragment(1000, "data_001.ttl"); | ||
| 80 | // f.process("http://www.biopax.org/release/biopax-level3.owl#", "/media/krr-nas-share/Yujiao/ontologies/bio2rdf/reactome/data.ttl"); | ||
| 81 | |||
| 82 | f.dispose(); | ||
| 83 | } | ||
| 84 | |||
| 85 | } | ||
| 86 | |||
| 87 | |||
| 88 | class FragmentRDFHandler implements RDFHandler { | ||
| 89 | |||
| 90 | int m_mod; | ||
| 91 | TurtleWriter m_writer; | ||
| 92 | Random m_rand = new Random(); | ||
| 93 | |||
| 94 | public FragmentRDFHandler(int mod, TurtleWriter writer) { | ||
| 95 | m_mod = mod; | ||
| 96 | m_writer = writer; | ||
| 97 | } | ||
| 98 | |||
| 99 | @Override | ||
| 100 | public void endRDF() throws RDFHandlerException { | ||
| 101 | } | ||
| 102 | |||
| 103 | @Override | ||
| 104 | public void handleComment(String arg0) throws RDFHandlerException { | ||
| 105 | m_writer.handleComment(arg0); | ||
| 106 | Utility.logDebug("handling comment: " + arg0); | ||
| 107 | } | ||
| 108 | |||
| 109 | @Override | ||
| 110 | public void handleNamespace(String arg0, String arg1) throws RDFHandlerException { | ||
| 111 | m_writer.handleNamespace(arg0, arg1); | ||
| 112 | } | ||
| 113 | |||
| 114 | @Override | ||
| 115 | public void handleStatement(Statement arg0) throws RDFHandlerException { | ||
| 116 | if (m_rand.nextInt() % m_mod == 0) | ||
| 117 | m_writer.handleStatement(arg0); | ||
| 118 | } | ||
| 119 | |||
| 120 | boolean m_started = false; | ||
| 121 | |||
| 122 | @Override | ||
| 123 | public void startRDF() throws RDFHandlerException { | ||
| 124 | if (m_started) return ; | ||
| 125 | m_started = true; | ||
| 126 | m_writer.startRDF(); | ||
| 127 | } | ||
| 128 | |||
| 129 | } \ No newline at end of file | ||
