@Test void createSessionShouldKeepTheSetSchemaVersionWhenTypesAndTablesHaveNotChanged() { Session session = testee.get(); assertThat(versionManager(session).computeVersion().block()) .isEqualTo(MAX_VERSION); new CassandraTableManager(MODULE, session).clearAllTables(); versionManagerDAO(session).updateVersion(MIN_VERSION); assertThat(versionManager(session).computeVersion().block()) .isEqualTo(MIN_VERSION); assertThat(versionManager(testee.get()).computeVersion().block()) .isEqualTo(MIN_VERSION); }
@Override public Session get() { return session; }
SessionWithInitializedTablesFactory implements Provider<Session> { @Override public Session get() { return session; } }
SessionWithInitializedTablesFactory implements Provider<Session> { @Override public Session get() { return session; } @Inject  SessionWithInitializedTablesFactory(KeyspaceConfiguration keyspaceConfiguration,
                                               Cluster cluster,
                                               CassandraModule module); }
SessionWithInitializedTablesFactory implements Provider<Session> { @Override public Session get() { return session; } @Inject  SessionWithInitializedTablesFactory(KeyspaceConfiguration keyspaceConfiguration,
                                               Cluster cluster,
                                               CassandraModule module); @Override Session get(); @PreDestroy synchronized void destroy(); }
SessionWithInitializedTablesFactory implements Provider<Session> { @Override public Session get() { return session; } @Inject  SessionWithInitializedTablesFactory(KeyspaceConfiguration keyspaceConfiguration,
                                               Cluster cluster,
                                               CassandraModule module); @Override Session get(); @PreDestroy synchronized void destroy();  }