root/BH13SPARQLBuilder/src/hozo/sparql/AllegroAccessor.java @ 9

package jp.ac.osaka_u.sanken.sparql;


import jp.ac.osaka_u.sanken.sparql.edit.AllegroEditor;

import com.franz.agraph.jena.AGModel;
import com.franz.agraph.jena.AGQuery;
import com.franz.agraph.jena.AGQueryExecutionFactory;
import com.franz.agraph.jena.AGQueryFactory;
import com.hp.hpl.jena.query.QueryExecution;
/**
 * AllegroAccessor繧｢繧ｯ繧ｻ繝�し
 * @author kato
 *
 */
public class AllegroAccessor extends PlainSparqlAccessor {
        public AllegroAccessor(EndpointSettings endpoint, SparqlQueryListener queryListener){
                super(endpoint, queryListener);
}

        public AllegroAccessor(EndpointSettings endpoint){
                this(endpoint, null);
        }
        
        /**
         * query繧貞娼縺�※邨先棡繧定ｿ斐☆
         * @param query
         * @return
         */
        protected QueryExecution makeQuery(String queryString){
                QueryExecution qe = null;
                if (this.getSetting().isEditable()){
                        System.out.println("query:["+queryString+"]");
                        // TODO 譛ｬ譚･縺ｪ繧影ndpoint縺ｮ螳溯｣�↓蠢懊§縺ｦfactory縺九ｉ蝗ｺ譛峨�Accessor繧貞叙蠕励☆繧句ｽ｢縺ｫ縺吶∋縺阪□縺後€�
                        // 迴ｾ迥ｶ縺ｯ縲憩ditable=true縲阪�蝣ｴ蜷医�AllegroGraph縺ｫ豎ｺ繧∵遠縺｡縺励※縺�ｋ縲�
                        AllegroEditor ae;
                        try {
                                ae = new AllegroEditor(this, this.getSetting().getRepositoryURL(), getSetting().getRepository(), getSetting().getUser(), getSetting().getPass());
                                AGQuery sparql = AGQueryFactory.create(queryString);
                                qe = AGQueryExecutionFactory.create(sparql, (AGModel)ae.getModel());
                        } catch (Exception e) {
                                e.printStackTrace();
                        }
                } else {
                        qe = super.makeQuery(queryString);
                }

                return qe;
        }
}