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()

                            throw new InvalidArgumentException("SPARQL query type " + sparqlQuery.getClass() + " not supported!");
                        }


                        connection.commit();
                    } catch (Exception ex) {
                        connection.rollback();
                        throw ex;
                    } finally {
                        connection.close();
                    }
                } catch(RepositoryException e) {

View Full Code Here

                connection.begin();
                Update update = connection.prepareUpdate(queryLanguage,query,configurationService.getBaseUri());
                update.execute();
                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 {

View Full Code Here

                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

                    con.add(subject, FOAF.homepage, vf.createURI(data.get("link").toString()));
                }


                con.commit();
            } catch(RepositoryException ex) {
                con.rollback();
            } finally {
                con.close();
            }
        } catch(RepositoryException ex) {
            log.error("error while storing retrieved triples in repository",ex);

View Full Code Here

            ));




            con.commit();
        } catch(RepositoryException ex) {
            con.rollback();
        } finally {
            con.close();
        }
    }

View Full Code Here

                else
                    return null;
            } finally {
                // TODO: this is not the perfect way to do it, but the only way to avoid cycles
                // with the versioning
                conn.rollback();
                conn.close();
            }
        } catch (RepositoryException e) {
            handleRepositoryException(e, UserServiceImpl.class);

View Full Code Here

                it.close();
            }


            con.commit();
        } catch(RepositoryException ex) {
            con.rollback();
        } finally {
            con.close();
        }
    }

View Full Code Here

                it.close();
            }


            con.commit();
        } catch(RepositoryException ex) {
            con.rollback();
        } finally {
            con.close();
        }
    }

View Full Code Here

            ));




            con.commit();
        } catch(RepositoryException ex) {
            con.rollback();
        } finally {
            con.close();
        }
    }

View Full Code Here


                con.add(DummyProvider.class.getResourceAsStream(filename), resource, RDFFormat.TURTLE);


                con.commit();
            } catch(RepositoryException ex) {
                con.rollback();
            } catch (RDFParseException e) {
                throw new DataRetrievalException("could not parse resource data for file "+filename);
            } catch (IOException e) {
                throw new DataRetrievalException("could not load resource data for file "+filename);
            } finally {

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.