问Java中的Cassandra迁移库

EN

    <dependency>
        <groupId>com.builtamont</groupId>
        <artifactId>cassandra-migration</artifactId>
        <version>0.9</version>
    </dependency>

import com.builtamont.cassandra.migration.CassandraMigration;
import com.builtamont.cassandra.migration.api.configuration.KeyspaceConfiguration;
import org.springframework.beans.factory.InitializingBean;

class CassandraDataSourceMigration implements InitializingBean {
    private final String ip;
    private final String clusterName;
    private final Integer port;
    private final String keyspaceName;
    private final String migrationsPath;

    public CassandraDataSourceMigration(String ip, String clusterName, Integer port, String keyspaceName, String migrationsPath) {
        this.ip = ip;
        this.clusterName = clusterName;
        this.port = port;
        this.keyspaceName = keyspaceName;
        this.migrationsPath = migrationsPath;
    }

    // getters/setters

    @Override
    public void afterPropertiesSet() throws Exception {

        final KeyspaceConfiguration keyspaceConfig = new KeyspaceConfiguration();
        keyspaceConfig.setName(keyspaceName);
        keyspaceConfig.getClusterConfig().setContactpoints(new String[]{ip});
        if (port != null) {
            keyspaceConfig.getClusterConfig().setPort(port);
        }

        final CassandraMigration migrationProcessor = new CassandraMigration();
        migrationProcessor.setLocations(new String[]{migrationsPath});
        migrationProcessor.setKeyspaceConfig(keyspaceConfig);
        migrationProcessor.migrate();
    }
}

cassandra.ip=127.0.0.1
cassandra.cluster=My cluster
cassandra.keyspace=saya
cassandra.migration=classpath:db/migration
cassandra.port=9042