oracle 的RDF读取sample code

南京猿人

1. package org.bsirc.xmltoontology;
   
2. 
   
3. import java.io.FileOutputStream;
   
4. import java.io.OutputStream;
   
5. import java.sql.SQLException;
   
6. import java.util.Date;
   
7. import java.util.GregorianCalendar;
   
8. 
   
9. import org.bsirc.xmltoontology.db.oracle.OraRDFClient;
   
10. import org.bsirc.xmltoontology.db.oracle.OracleJenaConn;
    
11. 
    
12. import oracle.spatial.rdf.client.jena.GraphOracleSem;
    
13. import oracle.spatial.rdf.client.jena.ModelOracleSem;
    
14. import oracle.spatial.rdf.client.jena.Oracle;
    
15. import oracle.spatial.rdf.client.jena.OracleBulkUpdateHandler;
    
16. 
    
17. import com.hp.hpl.jena.graph.Graph;
    
18. import com.hp.hpl.jena.graph.GraphUtil;
    
19. import com.hp.hpl.jena.graph.Triple;
    
20. import com.hp.hpl.jena.ontology.OntClass;
    
21. import com.hp.hpl.jena.ontology.OntModel;
    
22. import com.hp.hpl.jena.ontology.OntModelSpec;
    
23. import com.hp.hpl.jena.rdf.model.Model;
    
24. import com.hp.hpl.jena.rdf.model.ModelFactory;
    
25. import com.hp.hpl.jena.rdf.model.RDFWriter;
    
26. import com.hp.hpl.jena.rdf.model.Resource;
    
27. import com.hp.hpl.jena.rdf.model.Statement;
    
28. import com.hp.hpl.jena.rdf.model.StmtIterator;
    
29. import com.hp.hpl.jena.vocabulary.RDF;
    
30. import com.hp.hpl.jena.vocabulary.RDFS;
    
31. 
    
32. public class OraExample {
    
33.        
    
34.         // some default values
    
35.         private static String userName = "rdf";
    
36.         private static String password = "rdf";
    
37.         private static String host = "192.168.0.31";
    
38.         private static String sid = "cbpr";
    
39.         private static String port = "1134";
    
40.         private static String semTblSpaceName="rdf_tblspace";
    
41.    
    
42.     private static OntModel oraOntModel;
    
43.         private static String Tmhhs = "http://www.phinformatics.org/Ontology/Tmhhs.owl";
    
44.        
    
45.     public static Oracle getOracle() throws SQLException
    
46.         {
    
47.                 Oracle orcl=null;
    
48.                 String jdbcConn = "jdbc:oracle:thin:@" + host + ":"
    
49.                 + port + ":" + sid;
    
50.                 try {
    
51.                         orcl=new Oracle(jdbcConn, userName, password);
    
52.                 }
    
53.                 catch(Exception ex)
    
54.                 {
    
55.                         ex.printStackTrace();
    
56.                 }
    
57.                 return orcl;
    
58.         }
    
59.    
    
60.         public static void main(String[] args) {
    
61.                 try
    
62.                 {
    
63.                         //Recording Start Time
    
64.                         GregorianCalendar day = new GregorianCalendar();
    
65.                         Date startProcessTime= day.getTime();
    
66.                         System.out.println(startProcessTime.toLocaleString());
    
67.                        
    
68.                         //Your model name goes here...Each OntModel will have a unique model name
    
69.                         String modelName="X7Param";
    
70.                        
    
71.                         //Getting Oracle Connection
    
72.                         Oracle orcl=getOracle();
    
73.                        
    
74.                         //Use this statement for loading already existing models from Oracle
    
75.                         //oraOntModel=createInMemOwlModel(orcl,modelName);
    
76.        
    
77.                         //Use this to load your local file to Oracle for first time
    
78.                         oraOntModel = ModelFactory.createOntologyModel( OntModelSpec.OWL_MEM, null );
    
79.                         oraOntModel.read("file:\\C:\\Users\\nkunapareddy\\NK_Workspace\\XMLToOntology\\Parameter.OWL");
    
80. 
    
81.                         /*Your custom code to modify OntModel goes here....
    
82.                         OntClass oTest=oraOntModel.createClass(Tmhhs+"#OraTest");
    
83.                         for(int i=0;i<1000;i++)
    
84.                         {
    
85.                                 oTest.addSubClass(oraOntModel.createResource(Tmhhs+"#OraTest"+String.valueOf(i)+"Sub").addProperty(RDF.type, RDFS.Class));
    
86.                         }
    
87.                         */
    
88.                        
    
89.                         //Model Connection
    
90.                         Model modelOracle = ModelOracleSem.createOracleSemModel(orcl, modelName);
    
91.                         GraphOracleSem g = (GraphOracleSem) modelOracle.getGraph();
    
92.                         try
    
93.                         {
    
94.                                 g.dropApplicationTableIndex();
    
95.                         }
    
96.                         catch(Exception ex)
    
97.                         {
    
98.                                 ex.printStackTrace();
    
99.                         }   
    
100.                     ((OracleBulkUpdateHandler) g.getBulkUpdateHandler()).addInBatch(
     
101.                       GraphUtil.findAll(oraOntModel.getGraph()), semTblSpaceName);
     
102.                     g.rebuildApplicationTableIndex();
     
103.                     orcl.dispose();
     
104.                        
     
105.                         //saveModel();
     
106.                     
     
107.                     //Recording End Time
     
108.                         GregorianCalendar day2 = new GregorianCalendar();
     
109.                         Date endProcessTime = day2.getTime();
     
110.                         System.out.println(endProcessTime.toLocaleString());
     
111.                 }
     
112.                 catch(Exception ex)
     
113.                 {
     
114.                         ex.printStackTrace();
     
115.                 }
     
116.         }
     
117.         /**
     
118.            * This method returns an in-memory OWL model given an Oracle RDF Model.
     
119.            */
     
120.           public static OntModel createInMemOwlModel(Oracle oracle,String modelName) throws SQLException
     
121.           {
     
122.             Graph gr = null;
     
123.             OntModel ontModel = null;
     
124.           
     
125.             try {
     
126.               Model modelOracle = ModelOracleSem.createOracleSemModel(oracle, modelName);
     
127.               gr = modelOracle.getGraph();
     
128.               ontModel = ModelFactory.createOntologyModel( OntModelSpec.OWL_MEM, null );
     
129.               ontModel.add(modelOracle);
     
130.             }
     
131.             finally {
     
132.               if (gr != null) gr.close();
     
133.             }
     
134.             return ontModel;
     
135.           }
     
136.           private static void saveModel() {
     
137.                  
     
138.                         try {
     
139.                                  
     
140.                                 // Now write the model in XML form to a file
     
141.                                 String fileName = "C:\\Documents and Settings\\nkunapareddy\\NK_Workspace\\XMLToOntology\\TmhhsOra.owl";
     
142.                                 FileOutputStream fout = new FileOutputStream(fileName);
     
143.                                 RDFWriter writer = oraOntModel.getWriter("RDF/XML");
     
144.                                 writer.setProperty("xmlbase", Tmhhs);
     
145.                                 writer.write(oraOntModel.getBaseModel(), fout, Tmhhs);
     
146.                         } catch (Exception ex) {
     
147.                                 System.out.println(ex);
     
148.                         }
     
149.                 }
     
150. }

复制代码

推理,也将在数据库层解决.速度会很快.