Java 类com.google.inject.persist.PersistService 实例源码

项目：J-Kinopoisk2IMDB 文件：Client.java

public Client(@NonNull Path filePath, @NonNull Config config, boolean cleanRun, @NonNull List<?> listeners) {
    this.filePath = checkFile(filePath);
    this.cleanRun = cleanRun;

    Injector injector = Guice.createInjector(
            Stage.PRODUCTION,
            new ConfigurationModule(ConfigValidator.checkValid(config.withFallback(ConfigFactory.load()))),
            new JpaRepositoryModule(),
            new ServiceModule()
    );

    persistService = injector.getInstance(PersistService.class);
    persistService.start();

    handlerType = injector.getInstance(MovieHandler.Type.class);
    handlerChain = injector.getInstance(MovieHandler.class);
    importProgressService = injector.getInstance(ImportProgressService.class);

    eventBus = new EventBus();
    listeners.forEach(eventBus::register);
}

项目：guice-persist-neo4j 文件：Neo4jPersistModule.java

@Override
protected final void configure() {
    configurePersistence();

    requireBinding(PersistService.class);
    requireBinding(UnitOfWork.class);
/*if[AOP]*/
    // wrapping in an if[AOP] just to allow this to compile in NO_AOP -- it won't be used

    // class-level @Transacational
    bindInterceptor(annotatedWith(Transactional.class),
            new TransactionalClassMethodMatcher(),
            getTransactionInterceptor());
    // method-level @Transacational
    bindInterceptor(any(), new TransactionalMethodMatcher(), getTransactionInterceptor());
   /*end[AOP]*/
}

项目：guice-persist-neo4j 文件：Neo4jPersistModule.java

protected void configurePersistence() {
    bind(String[].class).annotatedWith(Neo4j.class).toInstance(packages);

    if (null != properties) {
        bind(Properties.class).annotatedWith(Neo4j.class).toInstance(properties);
    } else {
        bind(Properties.class).annotatedWith(Neo4j.class).toProvider(Providers.of(null));
    }

    bind(Neo4jPersistService.class).in(Singleton.class);
    bind(PersistService.class).to(Neo4jPersistService.class);
    bind(UnitOfWork.class).to(Neo4jPersistService.class);
    bind(Session.class).toProvider(Neo4jPersistService.class);

    transactionInterceptor = new Neo4jLocalTxnInterceptor();
    requestInjection(transactionInterceptor);
}

项目：guice-persist-orient-examples 文件：InMemoryDbApp.java

public static void main(String[] args) {
    // admin/admin is default user, created for each new db
    final Injector injector = Guice.createInjector(new DbModule("memory:sample", "admin", "admin"));

    // to initialize db context we must manually call start
    final PersistService persistService = injector.getInstance(PersistService.class);
    persistService.start();

    try {
        final SampleService service = injector.getInstance(SampleService.class);

        System.out.println("Overall records: " + service.count());

        final ODocument rec = service.selectLast();
        System.out.println("Last record: " + rec.toJSON());

        service.replaceName(rec.<String>field("name"), "test");
        // pay attention to record @version property in console
        System.out.println("Renamed record: " + service.findByName("test").toJSON());
        System.out.println("Records count is the same: " + service.count());
    } finally {
        // at the end service must be stopped
        persistService.stop();
    }
}

项目：guice 文件：JpaPersistModule.java

@Override
protected void configurePersistence() {
  bindConstant().annotatedWith(Jpa.class).to(jpaUnit);

  bind(JpaPersistService.class).in(Singleton.class);

  bind(PersistService.class).to(JpaPersistService.class);
  bind(UnitOfWork.class).to(JpaPersistService.class);
  bind(EntityManager.class).toProvider(JpaPersistService.class);
  bind(EntityManagerFactory.class)
      .toProvider(JpaPersistService.EntityManagerFactoryProvider.class);

  transactionInterceptor = new JpaLocalTxnInterceptor();
  requestInjection(transactionInterceptor);

  // Bind dynamic finders.
  for (Class<?> finder : dynamicFinders) {
    bindFinder(finder);
  }
}

项目：guice-old 文件：JpaPersistModule.java

@Override protected void configurePersistence() {
  bindConstant().annotatedWith(Jpa.class).to(jpaUnit);

  if (null != properties) {
    bind(Properties.class).annotatedWith(Jpa.class).toInstance(properties);
  } else {
    bind(Properties.class).annotatedWith(Jpa.class)
        .toProvider(Providers.<Properties>of(null));
  }

  bind(JpaPersistService.class).in(Singleton.class);

  bind(PersistService.class).to(JpaPersistService.class);
  bind(UnitOfWork.class).to(JpaPersistService.class);
  bind(EntityManager.class).toProvider(JpaPersistService.class);
  bind(EntityManagerFactory.class)
      .toProvider(JpaPersistService.EntityManagerFactoryProvider.class);

  transactionInterceptor = new JpaLocalTxnInterceptor();
  requestInjection(transactionInterceptor);

  // Bind dynamic finders.
  for (Class<?> finder : dynamicFinders) {
    bindFinder(finder);
  }
}

项目：google-guice 文件：JpaPersistModule.java

@Override protected void configurePersistence() {
  bindConstant().annotatedWith(Jpa.class).to(jpaUnit);

  if (null != properties) {
    bind(Properties.class).annotatedWith(Jpa.class).toInstance(properties);
  } else {
    bind(Properties.class).annotatedWith(Jpa.class)
        .toProvider(Providers.<Properties>of(null));
  }

  bind(JpaPersistService.class).in(Singleton.class);

  bind(PersistService.class).to(JpaPersistService.class);
  bind(UnitOfWork.class).to(JpaPersistService.class);
  bind(EntityManager.class).toProvider(JpaPersistService.class);
  bind(EntityManagerFactory.class)
      .toProvider(JpaPersistService.EntityManagerFactoryProvider.class);

  transactionInterceptor = new JpaLocalTxnInterceptor();
  requestInjection(transactionInterceptor);

  // Bind dynamic finders.
  for (Class<?> finder : dynamicFinders) {
    bindFinder(finder);
  }
}

项目：devhub-prototype 文件：DatabaseTest.java

@Before
public void setUp() {
    InputStream src = DatabaseTest.class.getResourceAsStream("/databaseconfig.test-h2.json");
    DatabaseProperties props;
    try {
        props = new CommonModule().objectMapper().readValue(src, DatabaseProperties.class);
    } catch (IOException e) {
        throw new ConfigurationException("Could not read test config", e);
    }
    injector = createInjector(new PersistenceModule(props, ""));
    structure = injector.getInstance(DatabaseStructure.class);
    persistService = injector.getInstance(PersistService.class);
    persistService.start();

    em = injector.getInstance(EntityManager.class);

    beginTransaction();
}

项目：joynr 文件：DiscoveryEntryStorePersistedTest.java

@Before
public void setUp() throws Exception {

    Injector injector = Guice.createInjector(new JpaPersistModule("CapabilitiesDirectory"), new AbstractModule() {

        @Override
        protected void configure() {
            bind(DiscoveryEntryStore.class).to(DiscoveryEntryStorePersisted.class);
            bind(DiscoveryEntry.class).to(GlobalDiscoveryEntryPersisted.class);
            bind(CapabilitiesProvisioning.class).to(DefaultCapabilitiesProvisioning.class);
        }
    });
    service = injector.getInstance(PersistService.class);
    store = injector.getInstance(DiscoveryEntryStore.class);
    entityManager = injector.getInstance(EntityManager.class);
}

项目：metacat 文件：S3ConnectorFactory.java

private void init() {
    //JPA module
    final Map<String, Object> props = Maps.newHashMap(configuration);
    props.put("hibernate.connection.datasource",
        DataSourceManager.get().load(name, configuration).get(name));
    final Module jpaModule = new JpaPersistModule("s3").properties(props);
    final Module s3Module = new S3Module(name, configuration, infoConverter);
    final Injector injector = Guice.createInjector(jpaModule, s3Module);
    persistService = injector.getInstance(PersistService.class);
    persistService.start();
    this.databaseService = injector.getInstance(ConnectorDatabaseService.class);
    this.tableService = injector.getInstance(ConnectorTableService.class);
    this.partitionService = injector.getInstance(ConnectorPartitionService.class);
}

项目：sparkled 文件：App.java

@Inject
public App(PersistService persistService,
           SchemaUpdater schemaUpdater,
           RestApiServer restApiServer,
           UdpServer udpServer,
           SongSchedulerService songSchedulerService) throws Exception {

    this.persistService = persistService;
    this.restApiServer = restApiServer;
    this.udpServer = udpServer;
    this.songSchedulerService = songSchedulerService;
    this.schemaUpdater = schemaUpdater;
}

项目：geeMVC-Java-MVC-Framework 文件：BaseTest.java

protected static void initializeInjector() {
    if (injector == null) {
        injector = Guice.createInjector(new TestModule(), new JpaPersistModule("testPU"));

        Injectors.set(new InjectorProvider() {

            @Override
            public Injector provide() {
                return injector;
            }
        });

        injector.getInstance(PersistService.class).start();
    }
}

项目：guice-persist-orient-examples 文件：RepoDemoApp.java

public static void main(String[] args) {
    final Injector injector = Guice.createInjector(new RepoDbModule("memory:sample", "admin", "admin"));
    final PersistService persistService = injector.getInstance(PersistService.class);
    persistService.start();

    try {
        final SampleRepository repository = injector.getInstance(SampleRepository.class);

        System.out.println("Overall records: " + repository.count());

        Sample sample = repository.first();
        // not detached entity will not contain data outside of transaction (its a proxy!)
        System.out.println("Last record (not detached): " + sample);
        // use list here just to show how multiple entities could be returned
        List<Sample> samples = repository.selectDetached();
        sample = samples.get(0);
        System.out.println("Detached record: " + sample);

        // without detaching name would be null
        int res = repository.updateName("test", sample.getName());
        System.out.println("Rename result: " + res);
        // pay attention to record @version property in console
        System.out.println("Renamed record: " + repository.findByNameDetached("test"));
        System.out.println("Records count is the same: " + repository.count());

        System.out.println("Document search: " + repository.findDocumentByName("test"));
    } finally {
        // at the end service must be stopped
        persistService.stop();
    }
}

项目：guice-persist-orient-examples 文件：ObjectDemoApp.java

public static void main(String[] args) {
    final Injector injector = Guice.createInjector(new ObjectDbModule("memory:sample", "admin", "admin"));
    final PersistService persistService = injector.getInstance(PersistService.class);
    persistService.start();

    try {
        final SampleService service = injector.getInstance(SampleService.class);

        System.out.println("Overall records: " + service.count());
        System.out.println("Overall records with query: " + service.count2());

        Sample sample = service.selectLast();
        // not detached entity will not contain data outside of transaction (its a proxy!)
        System.out.println("Last record (not detached): " + sample);
        sample = service.detach(sample);
        System.out.println("Last record (detached): " + sample);

        // without detaching name would be null
        service.replaceName(sample.getName(), "test");
        // pay attention to record @version property in console
        System.out.println("Renamed record: " + service.detach(service.findByName("test")));
        System.out.println("Records count is the same: " + service.count());
    } finally {
        // at the end service must be stopped
        persistService.stop();
    }
}

项目：eureka 文件：AbstractResourceTest.java

/**
 * Runs any test set up code before the actual test is run. The data for the
 * test is created from this method.
 *
 * @throws Exception Thrown if there are errors while creating test data, or
 * propagating exception from super.setUp().
 */
@Override
public final void setUp() throws Exception {
    super.setUp();
    PersistService persistService = this.injector.getInstance(PersistService.class);
    persistService.start();
    this.persistService = persistService;

    TestDataProvider dataProvider = this.injector.getInstance(this.getDataProvider());
    dataProvider.setUp();
    this.dataProvider = dataProvider;
}

项目：MoodCat.me-Core 文件：BulkInsertApp.java

/**
 * Run the bulk insertion.
 *
 * @throws Exception
 *             when the bulkinsertion has failed.
 */
public void run() throws Exception {
    final Injector injector = Guice.createInjector(new BulkInsertServletModule());
    final PersistService persistService = injector.getInstance(PersistService.class);
    persistService.start();
    final BulkInsertData bulkInsertData = injector.getInstance(BulkInsertData.class);
    bulkInsertData.clear();
    bulkInsertData.insertData();
    bulkInsertData.insertRandomRooms(NUMBER_OF_ROOMS);
}

项目：guice-persist-jooq 文件：JooqPersistModule.java

@Override
protected void configurePersistence() {
  bind(JooqPersistService.class).in(Singleton.class);
  bind(PersistService.class).to(JooqPersistService.class);
  bind(UnitOfWork.class).to(JooqPersistService.class);
  bind(DSLContext.class).toProvider(JooqPersistService.class);

  transactionInterceptor = new JdbcLocalTxnInterceptor(getProvider(JooqPersistService.class),
                                                       getProvider(UnitOfWork.class));
  requestInjection(transactionInterceptor);
}

项目：croquet 文件：PersistanceUnitHibernateModule.java

@Override
protected void configure() {
    bind(PersistService.class).to(JpaPersistService.class);
    bind(UnitOfWork.class).to(JpaPersistService.class);
    bind(EntityManager.class).toProvider(JpaPersistService.class);

    bind(CroquetPersistService.class).to(JpaPersistService.class);
    bind(EntityManagerFactory.class).toProvider(CroquetPersistService.EntityManagerFactoryProvider.class);
}

项目：croquet 文件：DataSourceHibernateModule.java

@Override
protected void configure() {
    // bind the ConnectionProvider
    bind(ConnectionProvider.class).to(TomcatJDBCConnectionProvider.class);

    bind(PersistService.class).to(CroquetPersistService.class);
    bind(UnitOfWork.class).to(CroquetPersistService.class);
    bind(EntityManager.class).toProvider(CroquetPersistService.class);
    bind(EntityManagerFactory.class).toProvider(CroquetPersistService.EntityManagerFactoryProvider.class);
}

项目：st-toolset 文件：AbstractPersistenceTest.java

@Before
public final void setUp() {
    final Injector injector = Guice.createInjector(new JpaPersistModule(getPersistModuleName()));
    injector.injectMembers(this);

    final PersistService persistService = injector.getInstance(PersistService.class);
    persistService.start();
}

项目：guice-persist-orient 文件：OrientModule.java

@Override
protected void configurePersistence() {
    poolsMultibinder = Multibinder.newSetBinder(binder(), PoolManager.class);

    bindConstant().annotatedWith(Names.named("orient.uri")).to(uri);
    bindConstant().annotatedWith(Names.named("orient.user")).to(user);
    bindConstant().annotatedWith(Names.named("orient.password")).to(password);
    bindConstant().annotatedWith(Names.named("orient.db.autocreate")).to(autoCreateDb);

    bind(TxConfig.class).annotatedWith(Names.named("orient.txconfig"))
            .toInstance(txConfig == null ? new TxConfig() : txConfig);

    configureCustomTypes();
    bind(CustomTypesInstaller.class);

    // extension points
    bind(TransactionManager.class);
    // SchemeInitializer.class
    // DataInitializer.class

    bind(PersistService.class).to(DatabaseManager.class);
    bind(UnitOfWork.class).to(TransactionManager.class);

    configurePools();
    configureInterceptor();
    bindRetryInterceptor();
}

项目：guice-persist-orient 文件：AbstractSchemeModule.java

@Override
protected void configure() {
    // prevent usage without main OrientModule
    requireBinding(PersistService.class);

    // if package not provided empty string will mean root package (search all classpath)
    // not required if provided scheme initializers not used
    bindConstant().annotatedWith(Names.named("orient.model.package")).to(pkgs);

    // required explicit binding to inject correct injector instance (instead of always root injector)
    bind(ExtensionsDescriptorFactory.class);

    bindSchemeInitializer();
}

项目：guice 文件：ManualLocalTransactionsWithCustomMatcherTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：ClassLevelManagedLocalTransactionsTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：EntityManagerFactoryProvisionTest.java

public void testSessionCreateOnInjection() {

    assertEquals(
        "SINGLETON VIOLATION " + UnitOfWork.class.getName(),
        injector.getInstance(UnitOfWork.class),
        injector.getInstance(UnitOfWork.class));

    //startup persistence
    injector.getInstance(PersistService.class).start();

    //obtain em
    assertTrue(injector.getInstance(EntityManager.class).isOpen());
  }

项目：guice 文件：ManualLocalTransactionsTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：JoiningLocalTransactionsTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：ManagedLocalTransactionsTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：ManagedLocalTransactionsAcrossRequestTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：EntityManagerProvisionTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：EnsureJpaCanTakeObjectsInPropertiesTest.java

private void startPersistService(boolean passDataSource) {
  final DataSource dataSource = getDataSource();

  injector = Guice.createInjector(new DBModule(dataSource, passDataSource));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：EntityManagerPerRequestProvisionTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();

  injector.getInstance(UnitOfWork.class).begin();
}

项目：guice 文件：ManualLocalTransactionsConfidenceTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：CustomPropsEntityManagerFactoryProvisionTest.java

public void testSessionCreateOnInjection() {

    assertEquals(
        "SINGLETON VIOLATION " + UnitOfWork.class.getName(),
        injector.getInstance(UnitOfWork.class),
        injector.getInstance(UnitOfWork.class));

    //startup persistence
    injector.getInstance(PersistService.class).start();

    //obtain em
    assertTrue(injector.getInstance(EntityManager.class).isOpen());
  }

项目：guice 文件：JpaWorkManagerTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice 文件：JpaWorkManagerTest.java

public void testCloseMoreThanOnce() {
  injector.getInstance(PersistService.class).stop();

  try {
    injector.getInstance(PersistService.class).stop();
    fail();
  } catch (IllegalStateException e) {
    // Ignored.
  }
}

项目：guice 文件：DynamicFinderTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit").addFinder(JpaFinder.class));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice-old 文件：ManualLocalTransactionsWithCustomMatcherTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}

项目：guice-old 文件：EntityManagerFactoryProvisionTest.java

public void testSessionCreateOnInjection() {

    assertTrue("SINGLETON VIOLATION " + UnitOfWork.class.getName(),
        injector.getInstance(UnitOfWork.class)
        .equals(injector.getInstance(UnitOfWork.class)));

    //startup persistence
    injector.getInstance(PersistService.class).start();

    //obtain em
    assertTrue(injector.getInstance(EntityManager.class).isOpen());
  }

项目：guice-old 文件：JoiningLocalTransactionsTest.java

@Override
public void setUp() {
  injector = Guice.createInjector(new JpaPersistModule("testUnit"));

  //startup persistence
  injector.getInstance(PersistService.class).start();
}