import org.apache.cassandra.locator.OldNetworkTopologyStrategy; //导入依赖的package包/类
@Test
public void testUpdateKeyspace() throws ConfigurationException
{
    // create a keyspace to serve as existing.
    CFMetaData cf = addTestTable("UpdatedKeyspace", "AddedStandard1", "A new cf for a new ks");
    KeyspaceMetadata oldKs = KeyspaceMetadata.create(cf.ksName, KeyspaceParams.simple(5), Tables.of(cf));

    MigrationManager.announceNewKeyspace(oldKs);

    assertNotNull(Schema.instance.getKSMetaData(cf.ksName));
    assertEquals(Schema.instance.getKSMetaData(cf.ksName), oldKs);

    // names should match.
    KeyspaceMetadata newBadKs2 = KeyspaceMetadata.create(cf.ksName + "trash", KeyspaceParams.simple(4));
    try
    {
        MigrationManager.announceKeyspaceUpdate(newBadKs2);
        throw new AssertionError("Should not have been able to update a KS with an invalid KS name.");
    }
    catch (ConfigurationException ex)
    {
        // expected.
    }

    Map<String, String> replicationMap = new HashMap<>();
    replicationMap.put(ReplicationParams.CLASS, OldNetworkTopologyStrategy.class.getName());
    replicationMap.put("replication_factor", "1");

    KeyspaceMetadata newKs = KeyspaceMetadata.create(cf.ksName, KeyspaceParams.create(true, replicationMap));
    MigrationManager.announceKeyspaceUpdate(newKs);

    KeyspaceMetadata newFetchedKs = Schema.instance.getKSMetaData(newKs.name);
    assertEquals(newFetchedKs.params.replication.klass, newKs.params.replication.klass);
    assertFalse(newFetchedKs.params.replication.klass.equals(oldKs.params.replication.klass));
}
 

import org.apache.cassandra.locator.OldNetworkTopologyStrategy; //导入依赖的package包/类
@Test
public void testUpdateKeyspace() throws ConfigurationException
{
    // create a keyspace to serve as existing.
    CFMetaData cf = addTestCF("UpdatedKeyspace", "AddedStandard1", "A new cf for a new ks");
    KSMetaData oldKs = KSMetaData.testMetadata(cf.ksName, SimpleStrategy.class, KSMetaData.optsWithRF(5), cf);

    MigrationManager.announceNewKeyspace(oldKs);

    Assert.assertNotNull(Schema.instance.getKSMetaData(cf.ksName));
    Assert.assertEquals(Schema.instance.getKSMetaData(cf.ksName), oldKs);

    // names should match.
    KSMetaData newBadKs2 = KSMetaData.testMetadata(cf.ksName + "trash", SimpleStrategy.class, KSMetaData.optsWithRF(4));
    try
    {
        MigrationManager.announceKeyspaceUpdate(newBadKs2);
        throw new AssertionError("Should not have been able to update a KS with an invalid KS name.");
    }
    catch (ConfigurationException ex)
    {
        // expected.
    }

    KSMetaData newKs = KSMetaData.testMetadata(cf.ksName, OldNetworkTopologyStrategy.class, KSMetaData.optsWithRF(1));
    MigrationManager.announceKeyspaceUpdate(newKs);

    KSMetaData newFetchedKs = Schema.instance.getKSMetaData(newKs.name);
    Assert.assertEquals(newFetchedKs.strategyClass, newKs.strategyClass);
    Assert.assertFalse(newFetchedKs.strategyClass.equals(oldKs.strategyClass));
}