Examples of org.openrdf.repository.RepositoryConnection.rollback()

Class org.openrdf.repository.RepositoryConnection

Examples of org.openrdf.repository.RepositoryConnection.rollback()

org.openrdf.repository.RepositoryConnection.rollback()
Rolls back all updates that have been performed as part of this connection so far. @throws StoreException If the connection could not be rolled back, or if the connection does not have an active connection. @see #isAutoCommit() @see #begin()

                connection.commit();
            } catch (UpdateExecutionException e) {
                connection.rollback();
                throw new MarmottaException("error while executing update",e);
            } catch (MalformedQueryException e) {
                connection.rollback();
                throw new MarmottaException("malformed query, update failed",e);
            } finally {
                connection.close();
            }
        } catch(RepositoryException ex) {

View Full Code Here


            log.trace("Checking existence of {}", resource);
            if (!ldpService.exists(conn, resource)) {
                log.debug("{} does not exist", resource);
                final Response.ResponseBuilder resp = createResponse(conn, Response.Status.NOT_FOUND, resource);
                conn.rollback();
                return resp;
            } else {
                log.trace("{} exists, continuing", resource);
            }

View Full Code Here

                    cID.close();
                }


                kiwiCon.commit();
            } catch (final Throwable t){
                kiwiCon.rollback();
                throw t;
            } finally {
                kiwiCon.close();
            }

View Full Code Here

                            try {
                                outputConn.begin();
                                ldpService.exportBinaryResource(outputConn, resource, out);
                                outputConn.commit();
                            } catch (RepositoryException | IOException e) {
                                outputConn.rollback();
                                throw new WebApplicationException(e, createResponse(Response.status(Response.Status.INTERNAL_SERVER_ERROR)).entity(e).build());
                            } finally {
                                outputConn.close();
                            }
                        } catch (RepositoryException e) {

View Full Code Here

                            try {
                                outputConn.begin();
                                ldpService.exportResource(outputConn, resource, output, format);
                                outputConn.commit();
                            } catch (RDFHandlerException e) {
                                outputConn.rollback();
                                throw new NoLogWebApplicationException(e, createResponse(Response.status(Response.Status.INTERNAL_SERVER_ERROR)).entity(e.getMessage()).build());
                            } catch (final Throwable t) {
                                outputConn.rollback();
                                throw t;
                            } finally {

View Full Code Here

                                outputConn.commit();
                            } catch (RDFHandlerException e) {
                                outputConn.rollback();
                                throw new NoLogWebApplicationException(e, createResponse(Response.status(Response.Status.INTERNAL_SERVER_ERROR)).entity(e.getMessage()).build());
                            } catch (final Throwable t) {
                                outputConn.rollback();
                                throw t;
                            } finally {
                                outputConn.close();
                            }
                        } catch (RepositoryException e) {

View Full Code Here

                }
                conn.commit();
                return response.build();
            } catch (IOException | RDFParseException e) {
                final Response.ResponseBuilder resp = createResponse(conn, Response.Status.BAD_REQUEST, container).entity(e.getClass().getSimpleName() + ": " + e.getMessage());
                conn.rollback();
                return resp.build();
            } catch (UnsupportedRDFormatException e) {
                final Response.ResponseBuilder resp = createResponse(conn, Response.Status.UNSUPPORTED_MEDIA_TYPE, container).entity(e);
                conn.rollback();
                return resp.build();

View Full Code Here

                final Response.ResponseBuilder resp = createResponse(conn, Response.Status.BAD_REQUEST, container).entity(e.getClass().getSimpleName() + ": " + e.getMessage());
                conn.rollback();
                return resp.build();
            } catch (UnsupportedRDFormatException e) {
                final Response.ResponseBuilder resp = createResponse(conn, Response.Status.UNSUPPORTED_MEDIA_TYPE, container).entity(e);
                conn.rollback();
                return resp.build();
            }
        } catch (InvalidInteractionModelException e) {
            log.debug("POST with invalid interaction model <{}> to <{}>", e.getHref(), container);
            final Response.ResponseBuilder response = createResponse(conn, Response.Status.BAD_REQUEST, container);

View Full Code Here

            log.debug("POST with invalid interaction model <{}> to <{}>", e.getHref(), container);
            final Response.ResponseBuilder response = createResponse(conn, Response.Status.BAD_REQUEST, container);
            conn.commit();
            return response.entity(e.getMessage()).build();
        } catch (final Throwable t) {
            conn.rollback();
            throw t;
        } finally {
            conn.close();
        }
    }

View Full Code Here

        try {
            con.begin();


            if (!ldpService.exists(con, resource)) {
                final Response.ResponseBuilder resp = createResponse(con, Response.Status.NOT_FOUND, resource);
                con.rollback();
                return resp.build();
            }


            if (eTag == null) {
                // check for If-Match header (ETag) -> 428 Precondition Required (Sec. 4.2.4.5)

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.