Mutagen Cassandra is a framework (based on Mutagen) that provides schema versioning and mutation for Apache Cassandra.
Mutagen is a lightweight framework for applying versioned changes (known as mutations) to a resource, in this case a Cassandra schema. Mutagen takes into account the resource's existing state and only applies changes that haven't yet been applied.
Schema mutation with Mutagen helps you make manageable changes to the schema of live Cassandra instances as you update your software, and is especially useful when used across development, test, staging, and production environments to automatically keep schemas in sync.
Create a Java-style package in your project to contain versioned schema mutation files. The package name can be anything, but it should ideally be specific to the schema you will be mutating. (In the same way that Java packages prevent namespace collisions for classes, you don't want to accidentally mix someone else's mutations into your schema by using a common package name.)
Mutations can be either declarative CQL2/3 or Java classes that use whatever Cassandra client you like (Astyanax is supported directly).
The root package name should be the same for both, and the mutation file names should start with a version tag--a prefix that orders the files naturally with a zero-padded integer, like V001. (Anything following the version tag is just a comment for your own use; the verion tag ends with the first non-numeric character.)
Examples:
V001_Some_cql_update.cqlV002_Some_java_update.javaV003.cql003.cql(Note that this convention doesn't work for Java classes, so I recommend using a prefix that is compatible with Java identifier rules.)
Lastly, note that if you use Maven, you'll need to put .cql files and .java files under separate source roots, but Mutagen will find them and order them properly as long as the version tags are consistent.
try {
// Get an instance of CassandraMutagen somehow (ideally inject it)
CassandraMutagen mutagen = ... // e.g. new CassandraMutagenImpl();
// Initialize the list of mutations
mutagen.initialize("my/cassandra/mutations");
// Get an Astyanax keyspace
Keyspace keyspace = ...
// Mutate! Note, this method may not throw an exception.
Plan.Result<Integer> result = mutagen.mutate(keyspace);
// Inspect result, especially for an exception
if (result.getException() != null) {
// Throw an exception
}
// Did something else go wrong?
if (!result.isMutationComplete()) {
// Figure out what happened
}
}
catch (IOException e) {
// Problem loading the mutations
}
catch (MutagenException e) {
// Mutation failed
}At runtime (normally during app startup), get or create an instance of CassandraMutagen. You can use Nu, Guice, or another dependency injection framework, or if you really want, you can create an instance the old fashioned way: new CassandraMutageImpl().
Call CassandraMutagen.initialize() and provide the package name containing your mutations. You should see log messages listing all the resources that were found.
Obtain an Astyanax Keyspace instance. Mutagen Cassandra use the Netflix Astyanax Cassandra client, and requires a configured Keyspace instance to work. This should obviously be straightforward if you already use Astyanax. If not, please see the Keyspace documentation on the Astyanax wiki.
To perform the mutations, call CassandraMutagen.mutate(Keyspace); to update the Cassandra schema to the latest version. Please note, this method may not throw an exception if there is a problem. Instead, use the returned value of type Plan.Result<Integer> to check for any exceptions thrown during the process. This may change in the future, so it would be prudent to surround your call to mutate() with a try...catch for MutagenException.
As you continue development, continue adding mutation files to the mutations package and running Mutagen Cassandra during startup. There is no need to conditionalize running Mutagen, as its purpose is to check each time for new schema mutations and apply them.
For examples of using Mutagen Cassandra, see the unit tests. To run the tests, you'll need a running instance of Cassandra running on the default port (9160).
Note that the unit test mixes declarative CQL mutations with a Java mutation (V003), which are in different directories according to the standard Maven layout but they get merged into the same directory in the build.
Mutagen Cassandra adds a column family to your keyspace called schema_version which tracks the current version of the schema. It doesn't otherwise change your keyspace in any way (like dropping and recreating it--whoops!), so it's possible to mix and match versioned and non-versioned column families in the same keyspace.
Mutagen mutates schemas; it doesn't assume it owns them. If you already have a schema in Cassandra and want to start mutating it with Mutagen, you needn't do anything but use Mutagen as described above (starting with whatever version number you like). It will automatically create the schema_version column family and happily start applying mutations. Mutagen doesn't know or care semantically what the mutations it's applying are; just be sure that mutations targeting existing column familes alter them instead of creating them.
Although it's best practice to always use Mutagen to mutate your schema, it's possible to make manual modifications to your schema outside of Mutagen. As long as future mutations take these changes into account, Mutagen won't itself have a problem. This capability might come in useful during disaster recovery, for example.
However, it then becomes your responsibility to be sure that all instances of the schema (for example, between dev, test, and production) apply the same manual changes, which is sort of the point of using Mutagen in the first place!
It might instead make sense to create mutations reflecting the manual changes, but then manually update the version column (it's an int)in the state row of the schema_version column family to prevent those mutations from being applied. That way, if you ever recreate the schema, every change will be there.
The easiest way to mutate your Cassandra schema is by using declarative CQL statements. Just be aware that Mutagen Cassandra treats all CQL statements in a single mutation file (separated by semicolons) as a single mutation.
The CQL version that you use is governed by the configuration of the Astyanax Keyspace passed to CassandraMutagen. Make sure that you set the CQL version to match the statements you'll be using.
Mutagen Cassandra doesn't support undoing mutations. Once a mutant, always a mutant.
In practice, this means that you need to take the approach of "patching your way to the future". If you made a change in a past mutation that you want to undo, create a new mutation to undo it. Never go back and change existing mutations, as they won't be applied, and worst case they will be applied to another schema instance and things will get horribly out of sync. You've been warned.
Recent versions of Cassandra handle schema changes in clustered deployments just fine, so no problems there.
However, the current version of Mutagen Cassandra only provides VM-wide synchronization for mutations. This means that if you have multiple client nodes that embed Mutagen Cassandra, you will need to provide your own external coordination to ensure that only a single node is updating the schema with Mutagen at any given time.
In practice, if you're already dealing with a clustered environment, this should be relatively straightforward. For example, you could use ZooKeeper, a file on an external Web server (or S3), Quartz, a queue with reservations, or something else that has reasonable semantics for coordinating multiple nodes. (If you are running a clustered environment and don't know what any of those mean, you probably have bigger fish to fry.)
The proper thing is for Mutagen Cassandra to handle this coordination via a cluster-aware Coordinator implementation (ideally using Cassandra itself), but that is an upcoming feature and not yet available.