@Override
    protected void create(List<TableInfo> tableInfos)
    {
        StatementResult result = null;
        String statement = null;

        for (TableInfo tableInfo : tableInfos)
        {
            try
            {
                result = tableAPI.executeSync("DROP TABLE IF EXISTS " + tableInfo.getTableName());
                if (!result.isSuccessful())
                {
                    throw new SchemaGenerationException("Unable to DROP TABLE " + tableInfo.getTableName());
                }
                statement = buildCreateDDLQuery(tableInfo);
                result = tableAPI.executeSync(statement);
                if (!result.isSuccessful())
                {
                    throw new SchemaGenerationException("Unable to CREATE TABLE " + tableInfo.getTableName());
                }
                createIndexOnTable(tableInfo);
            }
            catch (IllegalArgumentException e)
            {
                logger.error("Invalid Statement. Caused By: ", e);
                throw new SchemaGenerationException(e, "Invalid Statement. Caused By: ");
            }
            catch (FaultException e)
            {
                logger.error("Statement couldn't be executed. Caused By: ", e);
                throw new SchemaGenerationException(e, "Statement couldn't be executed. Caused By: ");
            }
        }
    }
@ Override protected void create ( List < TableInfo > tableInfos ) { StatementResult result = null ; String statement = null ; for ( TableInfo tableInfo : tableInfos ) { try { result = tableAPI . executeSync ( "DROP TABLE IF EXISTS " + tableInfo . getTableName ( ) ) ; if ( ! result . isSuccessful ( ) ) { throw new SchemaGenerationException ( "Unable to DROP TABLE " + tableInfo . getTableName ( ) ) ; } statement = buildCreateDDLQuery ( tableInfo ) ; result = tableAPI . executeSync ( statement ) ; if ( ! result . isSuccessful ( ) ) { throw new SchemaGenerationException ( "Unable to CREATE TABLE " + tableInfo . getTableName ( ) ) ; } createIndexOnTable ( tableInfo ) ; } catch ( IllegalArgumentException e ) { logger . error ( "Invalid Statement. Caused By: " , e ) ; throw new SchemaGenerationException ( e , "Invalid Statement. Caused By: " ) ; } catch ( FaultException e ) { logger . error ( "Statement couldn't be executed. Caused By: " , e ) ; throw new SchemaGenerationException ( e , "Statement couldn't be executed. Caused By: " ) ; } } }
/*
(non-Javadoc)

@see
com.impetus.kundera.configure.schema.api.AbstractSchemaManager#create
(java.util.List)