Package org.ontoware.rdf2go.model

Examples of org.ontoware.rdf2go.model.Model


  }
 
  public void addVisits(List<Visit> visited){
   
   
    Model md = Repository.S3B_HISTORY.getModel();
    md.open();
    /*ClosableIterator<Statement> rows3 = md.findStatements(null , null, null);
    while(rows3.hasNext()){
      md.removeStatement(rows3.next());
    }*/
    int i=0;
   
    String visitURI = "http://s3b.corrib.org/s3b/0.1/Visits/";;
    String randomID = "";
    String finalURI = "";
    while (true)
    {
    randomID = gerateId();
    finalURI = visitURI+"visit#"+randomID;
    ClosableIterator<Statement> rows2 = md.findStatements(md.createURI(finalURI), null, null);
    if(rows2.hasNext())
      {
        i=1;
      }
    else break;
    }
   
   
    String hasVisited = "http://s3b.corrib.org/s3b/0.1/hasVisited";
    String visit = "http://s3b.corrib.org/s3b/0.1/Visit";
    String visitDate = "http://s3b.corrib.org/s3b/0.1/visitDate";
    String visitResource = "http://s3b.corrib.org/s3b/0.1/visitResource";
    String userUri = "";
    String date = "";
    String res = "";
   
    for(Visit singleVisit: visited)
    {
      userUri = singleVisit.getPerson().getURI().toString();
      date = singleVisit.getVisitDate().toString();
      res = singleVisit.getResourceURI().toString();
      md.addStatement(md.createURI(userUri.toString()), md.createURI(visit), md.createURI(finalURI));
      md.addStatement(md.createURI(finalURI), md.createURI(visitDate), date);
      md.addStatement(md.createURI(finalURI), md.createURI(visitResource), md.createURI(res));
    }
   
   
   
    ClosableIterator<Statement> rows2 = md.findStatements(null, null, null);
    while(rows2.hasNext()){
        System.out.println(rows2.next());
    }
    rows2.close();
    //md.dump();
    md.commit();
    md.close();
  }
View Full Code Here


  }
 
  public List<Visit> getVisits(Person person, List<Visit> visited){
   
    List<Visit> oldVisited = new ArrayList<Visit>();
    Model md = Repository.S3B_HISTORY.getModel();
    md.open()
    String hasVisited = "http://s3b.corrib.org/s3b/0.1/hasVisited";
    String visit = "http://s3b.corrib.org/s3b/0.1/Visit";
    String visitDate = "http://s3b.corrib.org/s3b/0.1/visitDate";
    String visitResource = "http://s3b.corrib.org/s3b/0.1/visitResource";
    String query2 = SparqlQuery.LOAD_VISITED_BY_PERSON_AND_PROPERTY.getFormatedQuery(person.getURI().toString(),visitDate);
    ClosableIterator<Statement> dateStatements = md.sparqlConstruct(query2).iterator();
    String query3 = SparqlQuery.LOAD_VISITED_BY_PERSON_AND_PROPERTY.getFormatedQuery(person.getURI().toString(),visitResource);
    ClosableIterator<Statement> resourceStatements = md.sparqlConstruct(query3).iterator();
   
     
    while (dateStatements.hasNext())
    { 
      Statement test1 = dateStatements.next();
View Full Code Here

  }
public Map<URI,Double> getTerms(Person person){
 
 
    Map<URI,Double> termsList = new HashMap<URI,Double>();
    Model md = Repository.S3B_HISTORY.getModel();
   
    md.open()
    //md.removeAll();
    //md.commit();
    /*ClosableIterator<Statement> rows3 = md.findStatements(null , null, null);
    while(rows3.hasNext()){
      md.removeStatement(rows3.next());
    }*/
    String hasSearched = "http://s3b.corrib.org/s3b/0.1/hasSearched";
    String Search = "http://s3b.corrib.org/s3b/0.1/Search";
    String SearchDate = "http://s3b.corrib.org/s3b/0.1/SearchDate";
    String SearchTerm = "http://s3b.corrib.org/s3b/0.1/SearchTerm";
    String query2 = SparqlQuery.LOAD_VISITED_BY_PERSON_AND_PROPERTY.getFormatedQuery(person.getURI().toString(),SearchDate);
    ClosableIterator<Statement> dateStatements = md.sparqlConstruct(query2).iterator();
    String query3 = SparqlQuery.LOAD_VISITED_BY_PERSON_AND_PROPERTY.getFormatedQuery(person.getURI().toString(),SearchTerm);
    ClosableIterator<Statement> resourceStatements = md.sparqlConstruct(query3).iterator();
   
     
    while (dateStatements.hasNext())
    { 
      Statement test1 = dateStatements.next();
View Full Code Here

   * @return
   */
  public RdfResultObject getRdfResultObject(Map<String, Double> queries) {
    RdfResultObject result = new RdfResultObject();
   
    Model md = Repository.JOINED.getModel();
    md.open();
   
    result.addResults(getResourcesFromCache(queries));
       
    IndexResourceLoader<Person, TaxonomyEntry, KOSEntry, String, String> rl = new IndexBookResourceLoader();
    List<IndexResource<Person, TaxonomyEntry, KOSEntry, String, String>> list = rl.loadResources(queries, md);
    for(IndexResource<Person, TaxonomyEntry, KOSEntry, String, String> res : list){
      if(!resourceCache.containsKey(res.getURIAsString())){
        resourceCache.put(res.getURIAsString(),(IndexRdfResource) res);
      }
    }
    md.close();
    result.addResults(list);
    return result;
  }
View Full Code Here

   * @param user Person visiting resource
   * @param resource Resource that was selected
   */
  @SuppressWarnings("unchecked")
  public void addVisit(URI mbox,Resource resource){
    Model md = Repository.S3B_HISTORY.getModel();
    md.open();
    String hasVisited = "http://s3b.corrib.org/s3b/0.1/hasVisited";
    String Visit = "http://s3b.corrib.org/s3b/0.1/Visit";
    String visitDate = "http://s3b.corrib.org/s3b/0.1/visitDate";
    md.addStatement(md.createURI(mbox.toString()), md.createURI(hasVisited), md.createURI(resource.getURIAsString()));
  //  md.addStatement(md.createURI(mbox.toString()), md.createURI("http://s3b.corrib.org/s3b/0.1/hasVisited"), md.createURI(resource.getURIAsString()));
    ClosableIterator<Statement> rows2 = md.findStatements(null, null, null);
    while(rows2.hasNext()){
        System.out.println(rows2.next());
    }
    rows2.close();
    md.dump();
    md.commit();
    md.close();
  }
View Full Code Here

        logger.warning("Something was wrong when processing the jonto.repository.spec parameter ("+repoSpec+"); Using memory repository instead");
        repository = new SailRepository(new MemoryStore());
      }
    }
   
    Model _model;
    try {
      repository.initialize();

      // Then 'wrap' the sesame thing in an RDF2Go Model:
      _model = new RepositoryModel(repository)
      _model.open();
    } catch (RepositoryException e) {
      logger.log(Level.SEVERE, "Problem with initializing connection to the RDF storage ", e);
      return null;
    }
View Full Code Here

   * @param userUri
   */
  public void saveUserRecommendationPrefs(Person person) {
    URI prefsNode = S3BRepository.getInstance().getModel().createURI(person.getUri().toString()+"/recommendationPrefs");
   
    Model m = person.getGraph(Concepts.HAS_RECOMMENDATION_PREF.get(), prefsNode);
    boolean newmodel = m == null;

    if(m == null
      m = S3BRepository.getInstance().parseModel(null);
     
    URI node = m.createURI(person.getUri().toString()+"/recommendationPrefs/"+this.getName());
   
    if(!newmodel || m.contains(node, Variable.ANY, Variable.ANY))
      m.removeStatements(node, Variable.ANY, Variable.ANY);
   
    m.addStatement(prefsNode, Concepts.HAS_PREFERENCE.get(), node);
     
    m.addStatement(node, Concepts.HAS_LIMIT.get(), m.createDatatypeLiteral(String.valueOf(this.getLimit()), XSD._int));
    m.addStatement(node, Concepts.HAS_TYPE.get(), m.createDatatypeLiteral(String.valueOf(this.getName()), XSD._string));
    if(this.weight != null)
      m.addStatement(node, Concepts.HAS_WEIGHT.get(), m.createDatatypeLiteral(String.valueOf(this.getWeight()), XSD._int));

    if(newmodel)
      person.setGraph(Concepts.HAS_RECOMMENDATION_PREF.get(), prefsNode, m);
  }
View Full Code Here

  public static UserRecommendationPrefs[] getUserRecommendationPrefs(Person person) {
    UserRecommendationPrefs[] result = null;
   
    if(person != null){
      URI prefsNode = S3BRepository.getInstance().getModel().createURI(person.getUri().toString()+"/recommendationPrefs");
      Model m = person.getGraph(Concepts.HAS_RECOMMENDATION_PREF.get(), prefsNode);
      if(m != null) {
        String q = Queries.LIST_RECOMMENDATION_PREFERENCES.getQuery(prefsNode.toString());
        QueryResultTable table = m.querySelect(q, "SPARQL");
       
        if(table != null){
          ClosableIterator<QueryRow> it = table.iterator();
          Set<UserRecommendationPrefs> sprefs = new HashSet<UserRecommendationPrefs>();
         
View Full Code Here

   * @param url URL of the SIOC data to be saved.
   *     The HTTP repsponse for that url contains all information about that sioc data saved in the RDF type.  
   */
  public void bookmarkSiocData(String siocDataUri, String url) {
 
    Model tempModel = null;
    try
    {
      //get the rdf response for that url
      StringBuilder sb = new StringBuilder();
      getRdfResponse(sb, url);
       
      tempModel = DbFace.getTempModel();
      tempModel.readFrom(new StringReader(sb.toString()));
     
      ClosableIterator<Statement> statements = tempModel.findStatements(Variable.ANY, RDF.type, tempModel.createURI(siocDataUri));
           
      List<String> postExludedPredicates = null;
      if (siocDataUri.equals(SIOC.Post)) {
        //this is the list of predicates which define the post' details, that isn't needed in the bookmarks
        postExludedPredicates = new ArrayList<String>();
        postExludedPredicates.add(SIOC.contentEncoded);
        postExludedPredicates.add(SIOC.postedBy)
      }
     
     
      /* get the first statement (parhaps there is only one at all) and get more information about it -
       * get more information on desired sioc data */
      while(statements.hasNext()) {
        Statement stmt = statements.next();
       
        //in case od sioc:post there are a lot of information, some of which can be ommited in bookmarks
        if (siocDataUri.equals(SIOC.Post)) {
          /* For each piece of information about the post, scheck wheter it is unneeded.
           * If so, remove it from the graph containing the details. */
          ClosableIterator<Statement> ss = tempModel.findStatements(stmt.getSubject(), null, null);
          while (ss.hasNext()) {
            Statement s = ss.next();
            if(postExludedPredicates!=null)
              for (String exclPred : postExludedPredicates) {
                if (exclPred.equals(s.getPredicate().toString())) {
                  tempModel.removeStatement(s);
                }
              }
          }
          ss.close();
        }
       
        // for bookmarks engine issue, add the information
        // that current sioc data isIn one's sioc data directory in his/her private bookshelf
        tempModel.addStatement(stmt.getSubject(), tempModel.createURI(S3B_SSCF.isIn), tempModel.createURI(ownerSiocDirUri));
        break;
      }
     
      //it was removed
      /*siocDataGraph.remove(tmpRepository.performGraphQuery(
 
View Full Code Here

   */
  public void addPost(SiocPostBean post, String rootPostUri)
  {   
      try
      {
        Model tempModel = DbFace.getTempModel();
       
        //XXX:may be wrong - there is no addStatement(String, URI, URI)
        tempModel.addStatement(post.getUri(), RDF.type, SIOC.Post);
        tempModel.addStatement(post.getUri(), model.createURI(SIOC.postedBy), post.getPostedBy().getMbox().toString());
        tempModel.addStatement(post.getUri(), model.createURI(SIOC.postedWhen), post.getPostedWhen());
        tempModel.addStatement(post.getUri(), model.createURI(SIOC.title), post.getPostTitle());
        tempModel.addStatement(post.getUri(), model.createURI(SIOC.postBody), post.getPostBody());
        //XXX:may be wrong - there is no addStatement(String, URI, URI)
        tempModel.addStatement(post.getUri(), model.createURI(SIOC.postedResource), uri);
        for (String hasKeyword : post.getKeywords()) {
          tempModel.addStatement(post.getUri(), model.createURI(SIOC.topic), hasKeyword);
        }

        //if the post was an reply, add a triple informaing that his parent has it as a reply
        if (rootPostUri != null && !"".equals(rootPostUri)) {
          //XXX:may be wrong - there is no addStatement(String, URI, URI)
          tempModel.addStatement(post.getUri(), model.createURI(SIOC.hasReply),post.getUri());
        }
        model.addModel(tempModel);
       
        tempModel = null;
       
View Full Code Here

TOP

Related Classes of org.ontoware.rdf2go.model.Model

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.