Persistence.java

  1. /*
  2.  * *********************************************************************************************************************
  3.  *
  4.  * blueMarine II: Semantic Media Centre
  5.  * http://tidalwave.it/projects/bluemarine2
  6.  *
  7.  * Copyright (C) 2015 - 2021 by Tidalwave s.a.s. (http://tidalwave.it)
  8.  *
  9.  * *********************************************************************************************************************
  10.  *
  11.  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
  12.  * the License. You may obtain a copy of the License at
  13.  *
  14.  *     http://www.apache.org/licenses/LICENSE-2.0
  15.  *
  16.  * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
  17.  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.  See the License for the
  18.  * specific language governing permissions and limitations under the License.
  19.  *
  20.  * *********************************************************************************************************************
  21.  *
  22.  * git clone https://bitbucket.org/tidalwave/bluemarine2-src
  23.  * git clone https://github.com/tidalwave-it/bluemarine2-src
  24.  *
  25.  * *********************************************************************************************************************
  26.  */
  27. package it.tidalwave.bluemarine2.persistence;

  28. import javax.annotation.Nonnull;
  29. import java.io.IOException;
  30. import java.nio.file.Path;
  31. import org.eclipse.rdf4j.repository.Repository;
  32. import org.eclipse.rdf4j.repository.RepositoryConnection;
  33. import org.eclipse.rdf4j.repository.RepositoryException;
  34. import org.eclipse.rdf4j.rio.RDFHandlerException;

  35. /***********************************************************************************************************************
  36.  *
  37.  * This interface should not exist. For storing data into Persistence we're firing events to the messageBus. Why instead
  38.  * we retrieve data by directly accessing the repository? Perhaps we could switch to a coherently sync model for
  39.  * Persistence. In this case, AddStatementsRequest should me a private affair of DefaultMediaScanner.
  40.  *
  41.  * @author  Fabrizio Giudici
  42.  *
  43.  **********************************************************************************************************************/
  44. public interface Persistence
  45.   {
  46.     public static final Class<Persistence> _Persistence_ = Persistence.class;

  47.     public static interface TransactionalTask<E extends Exception>
  48.       {
  49.         public void run (@Nonnull RepositoryConnection connection)
  50.           throws E, RepositoryException;
  51.       }

  52.     @Nonnull
  53.     public Repository getRepository();

  54.     public <E extends Exception> void runInTransaction (@Nonnull TransactionalTask<E> task)
  55.       throws E, RepositoryException;

  56.     public void exportToFile (@Nonnull final Path path)
  57.       throws RDFHandlerException, IOException, RepositoryException;
  58.   }