チェンジセット 160 : BH13SPARQLBuilder/src/org/biohackathon

更新日時:

2014/09/25 15:42:35 (10 年 前)

更新者:

nori

ログメッセージ:

Metadataファイルの管理プログラム　V1

パス:

BH13SPARQLBuilder/src/org/biohackathon/SPARQLBuilder/endpointMetadata

ファイル:

• MetadataFile.java (変更) (2 diff)
• MetadataManager.java (変更) (3 diff)

BH13SPARQLBuilder/src/org/biohackathon/SPARQLBuilder/endpointMetadata/MetadataFile.java

@@ -2 +2 @@
 
 import java.io.File;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.HashSet;
+
+import jp.riken.accc.db.rdf.crawler.dataStructure.sparql.URICollection;
+
+import org.apache.jena.riot.RDFDataMgr;
+
+import com.hp.hpl.jena.rdf.model.Literal;
+import com.hp.hpl.jena.rdf.model.Model;
+import com.hp.hpl.jena.rdf.model.NodeIterator;
+import com.hp.hpl.jena.rdf.model.Property;
+import com.hp.hpl.jena.rdf.model.RDFNode;
+import com.hp.hpl.jena.rdf.model.Resource;
 
 public class MetadataFile {
 
+        Model model = null;
+        String endpointURI = null;
+        Calendar startDateTime = null;
+        Calendar endDateTime = null;
         
         public MetadataFile(File file) throws Exception{
@@ -10 +28 @@
         }
 
+        public String getEndpointURI(){
+                return endpointURI;
+        }
+
+        public Calendar getStartDateTime(){
+                return startDateTime;
+        }
+
+        public Calendar getEndDateTime(){
+                return endDateTime;
+        }
+        
+        
         private void readFile(File file) throws Exception{
+                model = RDFDataMgr.loadModel(file.getAbsolutePath());
+                Property sd_endpoint = model.getProperty(URICollection.PROPERTY_SD_ENDPOINT);
+                NodeIterator nit = model.listObjectsOfProperty(sd_endpoint);
+                Resource endPointRes = null;
+                endpointURI = null;
+                if( nit.hasNext() ){
+                                RDFNode endPointNode = nit.next();
+                                endPointRes = endPointNode.asResource();
+                                endpointURI = endPointRes.getURI();
+                }
                 
+                Property sd_default_dataset = model.getProperty(URICollection.PROPERTY_SD_DEFAULT_DATA_SET);
+                nit = model.listObjectsOfProperty(sd_default_dataset);
+                Resource defaultDataSet = null;
+                if( nit.hasNext() ){
+                        RDFNode node = nit.next();
+                        defaultDataSet = node.asResource();
+                }
+                // log
+                Property sbm_crawlLog = model.getProperty(URICollection.PROPERTY_SB_CRAWL_LOG);
+                nit = model.listObjectsOfProperty(sbm_crawlLog);
+                Resource crawlLogBlankNode = null;
+                if( nit.hasNext() ){
+                                RDFNode node = nit.next();
+                                crawlLogBlankNode = node.asResource();
+                }
+                // start
+                Property sbm_startTime = model.getProperty(URICollection.PROPERTY_SB_CRAWL_START_TIME);
+                nit = model.listObjectsOfProperty(sbm_startTime);
+                startDateTime = null;
+                if( nit.hasNext() ){
+                        Literal startTimeLit = null;
+                        RDFNode node = nit.next();
+                        startTimeLit = node.asLiteral();
+                        startDateTime = ((com.hp.hpl.jena.datatypes.xsd.XSDDateTime)(startTimeLit.getValue())).asCalendar();
+                }
+                // end
+                Property sbm_endTime = model.getProperty(URICollection.PROPERTY_SB_CRAWL_END_TIME);
+                nit = model.listObjectsOfProperty(sbm_endTime);
+                endDateTime = null;
+                if( nit.hasNext() ){
+                        Literal endTimeLit = null;
+                        RDFNode node = nit.next();
+                        endTimeLit = node.asLiteral();
+                        endDateTime = ((com.hp.hpl.jena.datatypes.xsd.XSDDateTime)(endTimeLit.getValue())).asCalendar();
+                }
+
         }
 

BH13SPARQLBuilder/src/org/biohackathon/SPARQLBuilder/endpointMetadata/MetadataManager.java

@@ -2 +2 @@
 
 import java.io.File;
-import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Set;
 
 public class MetadataManager {
 
+        HashMap<String,MetadataFile> metadataTable = null;
+        
+        
+        public static void main(String[] args) throws Exception{
+                String dirStr = "c:\\temp\\crawl";
+                MetadataManager manager = new MetadataManager(dirStr);
+                String[] uris = manager.getURIList();
+                for(String uri: uris){
+                        System.out.println(uri);
+                        MetadataFile mFile = manager.getMetadataFile(uri);
+                        System.out.println(mFile.getStartDateTime().getTime().toString());
+                        System.out.println(mFile.getEndDateTime().getTime().toString());
+                }
+        }       
 
-        MetadataFile[] metadataFiles = null;
+        public MetadataFile getMetadataFile(String uri){
+                return metadataTable.get(uri);
+        }
+
+        public String[] getURIList(){
+                Set<String> keySet = metadataTable.keySet();
+                return keySet.toArray(new String[0]);
+        }
+        
         
         public MetadataManager(String metadataDirStr) throws Exception {
@@ -15 +38 @@
         
         public void init(String metadataDirStr) throws Exception{
+                metadataTable = new HashMap<String,MetadataFile>();
                 File metadataDir = new File(metadataDirStr);
                 File[] files = null;
@@ -30 +54 @@
                         throw new Exception("File/Directory not found: " + metadataDirStr);
                 }
-                ArrayList<MetadataFile> aList = new ArrayList<MetadataFile>();
                 for(File file: files){
                         MetadataFile metadataFile = null;
                         try{
                                 metadataFile = new MetadataFile(file);
-                                aList.add(metadataFile);
+                                String uri = metadataFile.getEndpointURI();
+                                if( uri != null ){
+                                        metadataTable.put(uri, metadataFile);
+                                }
                         }catch(Exception ex){
                                 // WARNING
                                 System.out.println("Invalid metadata file: " + file.getAbsolutePath());
+                                ex.printStackTrace();
                         }
                 }
-                metadataFiles = aList.toArray(new MetadataFile[0]);
         }