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

更新日時:

2014/01/31 09:59:11 (11 年 前)

更新者:

nori

ログメッセージ:

クラス取得後、あとからインスタンス数をとってこれるようにcountInstancesメソッドを追加

パス:

BH13SPARQLBuilder/src/org/biohackathon/SPARQLBuilder/OWL

ファイル:

• OWLQueryBuilder.java (変更) (1 diff)
• OWLQueryBuilderImpl.java (変更) (4 diff)

BH13SPARQLBuilder/src/org/biohackathon/SPARQLBuilder/OWL/OWLQueryBuilder.java

@@ -107 +107 @@
                         ClassLink[] classLinks) throws Exception;
 
+        public SClass[] countInstances(String[] graphURIs, SClass[] classes) throws Exception;
 }

BH13SPARQLBuilder/src/org/biohackathon/SPARQLBuilder/OWL/OWLQueryBuilderImpl.java

@@ -63 +63 @@
                         System.out.println(cls);
                 }
-
-                System.out.println("CLS");
+                clz = builder.countInstances(null, clz);
+                for (SClass cls : clz) {
+                        System.out.println(cls);
+                }
+                
+
+/*
+                System.out.println("CLS");
+ 
                 ClassLink[] cls = builder.getNextClass(null, clz[1].getClassURI(), 100,
                                 false);
@@ -76 +83 @@
                         }
                 }
-
+*/
                 /*
                  * System.out.println("CLS-INS"); cls =
@@ -169 +176 @@
                         if (res != null) {
                                 String uri = res.getURI();
-                                int numOfInstances = sol.getLiteral("numOfInstances").getInt();
+                                int numOfInstances = 0;
+                                if( countInstances ){
+                                        numOfInstances = sol.getLiteral("numOfInstances").getInt();
+                                }
                                 // System.out.println(numOfInstances);
                                 Literal labelLiteral = sol.getLiteral("pLabel");
@@ -738 +748 @@
         }
 
+        public SClass[] countInstances(String[] graphURIs, SClass[] classes) throws Exception{
+                if( classes == null || classes.length == 0 ){
+                        return new SClass[0];
+                }
+                HashMap<String, SClass> classMap = new HashMap<String, SClass>();
+                for(SClass sc: classes){
+                        classMap.put(sc.getClassURI(), sc);
+                }
+                StringBuffer queryStr = new StringBuffer();
+                queryStr.append("PREFIX owl: <http://www.w3.org/2002/07/owl#>\n");
+                queryStr.append("PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n");
+                queryStr.append("PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n");
+                queryStr.append("SELECT DISTINCT ?cls  (COUNT(?is) AS ?numOfInstances)\n");
+                if (graphURIs != null) {
+                        for (String graphURI : graphURIs) {
+                                queryStr.append("FROM <");
+                                queryStr.append(graphURI);
+                                queryStr.append(">\n");
+                        }
+                }
+                queryStr.append("WHERE{\n");
+                queryStr.append("  ?is rdf:type ?cls.\n");
+                queryStr.append("  FILTER(?cls IN (");
+                boolean f = false;
+                Set<String> clsSet = classMap.keySet();
+                for (String clsURI : clsSet) {
+                        if (f) {
+                                queryStr.append(", ");
+                        }
+                        f = true;
+                        queryStr.append("<");
+                        queryStr.append(clsURI);
+                        queryStr.append(">");
+                }
+                queryStr.append("))\n");
+                queryStr.append("} GROUP BY ?cls");
+
+                System.out.println(queryStr.toString());
+
+                Query query = QueryFactory.create(queryStr.toString());
+                QueryExecution qexec = QueryExecutionFactory.sparqlService(endpointURI,
+                                query);
+
+                ResultSet results = qexec.execSelect();
+                for (; results.hasNext();) {
+                        QuerySolution sol = results.next();
+                        String uri = sol.getResource("cls").getURI();
+                        SClass sc = classMap.get(uri);
+                        Literal lit = sol.getLiteral("numOfInstances");
+                        if (lit != null) {
+                                int numOfInstances = lit.getInt();
+                                sc.setNumOfInstances(numOfInstances);
+                        }
+                }
+                qexec.close();
+        
+                return classes;
+        }
+
 }