import org.springframework.data.cassandra.config.CassandraSessionFactoryBean; //导入依赖的package包/类
@Test
public void hasRecreateSchemaActionSet() {
	createTestKeyspaceIfNotExists();
	this.context = new AnnotationConfigApplicationContext();
	String cityPackage = City.class.getPackage().getName();
	AutoConfigurationPackages.register(this.context, cityPackage);
	EnvironmentTestUtils.addEnvironment(this.context,
			"spring.data.cassandra.schemaAction:RECREATE_DROP_UNUSED",
			"spring.data.cassandra.keyspaceName:boot_test");
	this.context.register(CassandraAutoConfiguration.class,
			CassandraDataAutoConfiguration.class);
	this.context.refresh();
	CassandraSessionFactoryBean bean = this.context
			.getBean(CassandraSessionFactoryBean.class);
	assertThat(bean.getSchemaAction()).isEqualTo(SchemaAction.RECREATE_DROP_UNUSED);
}
 

import org.springframework.data.cassandra.config.CassandraSessionFactoryBean; //导入依赖的package包/类
/**
 * Create new session factory bean for provided cassandra endpoint
 *
 * @param connectionData connection metadata
 * @return future providing new instance of {@link CassandraAdminTemplate template} to manage cassandra data
 */
public CompletableFuture<CassandraAdminTemplate> connect(ConnectionData connectionData) {
    return CompletableFuture.supplyAsync(() -> {
        if (isNullOrEmpty(connectionData.getKeyspace()) || isNullOrEmpty(connectionData.getUrl())) {
            throw new UrlSyntaxException("Both url and keyspace are required");
        }
        String[] urlParts = connectionData.getUrl().split(":");
        if (urlParts.length != 2) {
            throw new UrlSyntaxException("Url should contain host:port");
        }
        int port;
        try {
            port = Integer.parseInt(urlParts[1]);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            throw new UrlSyntaxException("Invalid port : " + urlParts[1]);
        }

        Cluster.Builder builder = Cluster.builder()
                .addContactPoint(urlParts[0])
                .withPort(port);

        if (StringUtils.isNoneBlank(connectionData.getUsername(), connectionData.getPassword())) {
            builder.withCredentials(connectionData.getUsername(), connectionData.getPassword());
        }

        Cluster cluster = builder.build();

        CassandraSessionFactoryBean factory =
                beanFactory.getBean(CassandraSessionFactoryBean.class, cluster, connectionData.getKeyspace());
        Field adminTemplateField = findField(CassandraSessionFactoryBean.class, "admin");
        adminTemplateField.setAccessible(true);
        CassandraAdminTemplate template = (CassandraAdminTemplate) getField(adminTemplateField, factory);
        this.template.set(template);
        return template;
    });
}
 

import org.springframework.data.cassandra.config.CassandraSessionFactoryBean; //导入依赖的package包/类
@Test
public void hasDefaultSchemaActionSet() {
	this.context = new AnnotationConfigApplicationContext();
	String cityPackage = City.class.getPackage().getName();
	AutoConfigurationPackages.register(this.context, cityPackage);
	this.context.register(CassandraAutoConfiguration.class,
			CassandraDataAutoConfiguration.class);
	this.context.refresh();

	CassandraSessionFactoryBean bean = this.context
			.getBean(CassandraSessionFactoryBean.class);
	assertThat(bean.getSchemaAction()).isEqualTo(SchemaAction.NONE);
}