Package org.openrdf.repository.http

Examples of org.openrdf.repository.http.HTTPRepository


      BindException errors)
    throws Exception
  {
    ModelAndView result = null;

    HTTPRepository repo = (HTTPRepository)request.getSession().getAttribute(SessionKeys.REPOSITORY_KEY);

    SelectQueryInfo qInfo = (SelectQueryInfo)command;

    TupleQueryResult queryResult = null;

    RepositoryConnection conn = null;
    try {
      conn = repo.getConnection();

      HTTPTupleQuery query = (HTTPTupleQuery)conn.prepareTupleQuery(qInfo.getQueryLanguage(),
          qInfo.getQueryString());
      query.setIncludeInferred(qInfo.isIncludeInferred());
      try {
View Full Code Here


      BindException errors)
    throws Exception
  {
    ModelAndView result = null;

    HTTPRepository repo = (HTTPRepository)request.getSession().getAttribute(SessionKeys.REPOSITORY_KEY);

    BooleanQueryInfo qInfo = (BooleanQueryInfo)command;

    boolean queryResult = false;

    RepositoryConnection conn = null;
    try {
      conn = repo.getConnection();

      HTTPBooleanQuery query = (HTTPBooleanQuery)conn.prepareBooleanQuery(qInfo.getQueryLanguage(),
          qInfo.getQueryString());
      query.setIncludeInferred(qInfo.isIncludeInferred());
      try {
View Full Code Here

  }

  private List<Namespace> getNamespaces(HttpServletRequest request) {
    List<Namespace> result = null;

    HTTPRepository repo = (HTTPRepository)request.getSession().getAttribute(SessionKeys.REPOSITORY_KEY);

    RepositoryConnection conn = null;
    try {
      conn = repo.getConnection();
      CloseableIteration<? extends Namespace, RepositoryException> namespaces = conn.getNamespaces();
      result = new ArrayList<Namespace>();
      while (namespaces.hasNext()) {
        result.add(namespaces.next());
      }
View Full Code Here

  }

  @Override
  protected void initBinder(HttpServletRequest request, ServletRequestDataBinder binder) {
    HttpSession session = request.getSession();
    HTTPRepository repo = (HTTPRepository)session.getAttribute(SessionKeys.REPOSITORY_KEY);

    binder.registerCustomEditor(Resource.class, new ResourcePropertyEditor(repo.getValueFactory()));
  }
View Full Code Here

  }

  private List<Resource> getContexts(HttpServletRequest request) {
    List<Resource> result = null;

    HTTPRepository repo = (HTTPRepository)request.getSession().getAttribute(SessionKeys.REPOSITORY_KEY);

    RepositoryConnection conn = null;
    try {
      conn = repo.getConnection();
      CloseableIteration<? extends Resource, RepositoryException> contexts = conn.getContextIDs();
      result = new ArrayList<Resource>();
      while (contexts.hasNext()) {
        result.add(contexts.next());
      }
View Full Code Here

    throws RepositoryException, QueryEvaluationException, MalformedQueryException
  {
    List<Resource> result = new ArrayList<Resource>();

    HttpSession session = request.getSession();
    HTTPRepository repo = (HTTPRepository)session.getAttribute(SessionKeys.REPOSITORY_KEY);

    RepositoryConnection conn = null;
    try {
      conn = repo.getConnection();
      String query = "SELECT DISTINCT C FROM {} rdf:type {C}";
      TupleQueryResult classes = conn.prepareTupleQuery(QueryLanguage.SERQL, query).evaluate();
      try {
        while (classes.hasNext()) {
          BindingSet bindingSet = classes.next();
View Full Code Here

  final Logger logger = LoggerFactory.getLogger(this.getClass());

  @Override
  protected void initBinder(HttpServletRequest request, ServletRequestDataBinder binder) {
    HttpSession session = request.getSession();
    HTTPRepository repo = (HTTPRepository)session.getAttribute(SessionKeys.REPOSITORY_KEY);

    binder.registerCustomEditor(Resource.class, new ResourcePropertyEditor(repo.getValueFactory()));
    binder.registerCustomEditor(URI.class, new UriPropertyEditor(repo.getValueFactory()));
    binder.registerCustomEditor(Value.class, new ValuePropertyEditor(repo.getValueFactory()));

    binder.registerCustomEditor(RDFFormat.class, new RDFFormatPropertyEditor());
  }
View Full Code Here

  @Override
  public ModelAndView onSubmit(HttpServletRequest request, HttpServletResponse response, Object command,
      BindException errors)
  {
    HTTPRepository repo = (HTTPRepository)request.getSession().getAttribute(SessionKeys.REPOSITORY_KEY);

    ExtractionSettings settings = (ExtractionSettings)command;
    RDFFormat format = settings.getResultFormat();

    RepositoryConnection conn = null;
    try {
      response.setContentType(format.getDefaultMIMEType());
      String filename = "extract";
      if (format.getDefaultFileExtension() != null) {
        filename += "." + format.getDefaultFileExtension();
      }
      response.setHeader("Content-Disposition", "attachment; filename=" + filename);

      RDFWriter writer = Rio.createWriter(format, response.getOutputStream());

      conn = repo.getConnection();
      conn.exportStatements(settings.getSubject(), settings.getPredicate(), settings.getObject(),
          settings.isIncludeInferred(), writer, settings.getContexts());
    }
    catch (RepositoryException e) {
      e.printStackTrace();
View Full Code Here

    logger.info("Clearing data...");
    String actionResult = "repository.modify.remove.clear.success";

    RemovalSpecification toRemove = (RemovalSpecification)command;

    HTTPRepository repo = (HTTPRepository)request.getSession().getAttribute(SessionKeys.REPOSITORY_KEY);
    RepositoryConnection conn = null;
    try {
      conn = repo.getConnection();
      conn.clear(toRemove.getContexts());
      conn.commit();
      logger.info("Clear committed.");
    }
    catch (RepositoryException e) {
View Full Code Here

  final Logger logger = LoggerFactory.getLogger(this.getClass());

  @Override
  protected void initBinder(HttpServletRequest request, ServletRequestDataBinder binder) {
    HttpSession session = request.getSession();
    HTTPRepository repo = (HTTPRepository)session.getAttribute(SessionKeys.REPOSITORY_KEY);

    binder.registerCustomEditor(Resource.class, new ResourcePropertyEditor(repo.getValueFactory()));
    binder.registerCustomEditor(URI.class, new UriPropertyEditor(repo.getValueFactory()));
    binder.registerCustomEditor(Value.class, new ValuePropertyEditor(repo.getValueFactory()));
  }
View Full Code Here

TOP

Related Classes of org.openrdf.repository.http.HTTPRepository

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.