List of generateLiveAlterDDL() Examples

Examples of generateLiveAlterDDL()

org.caffinitas.mapper.core.SchemaGenerator.generateLiveAlterDDL()
Create {@code ALTER} and {@code CREATE} statements based on the coded model and the current schema the Cassandra.Unlike {@link MappedSchemaObject#getAlterDDL(com.datastax.driver.core.Cluster) MappedSchemaObject.getAlterDDL()} methodsthis method checks if a schema object already exists. It generates {@code CREATE} statements for non-existing objects and{@code ALTER} statements (if necessary) for existing objects.

Examples of org.caffinitas.mapper.core.SchemaGenerator.generateLiveAlterDDL()


            SchemaGenerator schemaGenerator = persistenceManager.createSchemaGenerator();


            System.out.println("Executing CQL DDL statements...");
            System.out.println();
            for (String stmt : schemaGenerator.generateLiveAlterDDL().getStatements())
            {
                System.out.println(stmt);
            }


            CqlStatementList cqlDDL = schemaGenerator.generateLiveAlterDDL();

View Full Code Here

Examples of org.caffinitas.mapper.core.SchemaGenerator.generateLiveAlterDDL()

            for (String stmt : schemaGenerator.generateLiveAlterDDL().getStatements())
            {
                System.out.println(stmt);
            }


            CqlStatementList cqlDDL = schemaGenerator.generateLiveAlterDDL();
            cqlDDL.execute(persistenceManager.driverSession());


            System.out.println("Wait until all schema objects are available...");
            System.out.println();
            persistenceManager.refreshSchema(); // This is necessary until schema changes are propagated from the Java Driver to Caffinitas Mappe automatically!

View Full Code Here

Examples of org.caffinitas.mapper.core.SchemaGenerator.generateLiveAlterDDL()

        System.out.println();
        System.out.println(schemaGenerator.generateOfflineDropDDL());
        System.out.println();
        System.out.println("-- ALTER DDL statements");
        System.out.println();
        System.out.println(schemaGenerator.generateLiveAlterDDL());
    }


    @SuppressWarnings("BusyWait") protected final void waitEntityExists(MappedSchemaObject entity) throws InterruptedException {
        persistenceManager.refreshSchema();
        for (int i = 0; i < 200; i++) {

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.