code: @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: ");
              }
          }
      }
docs: /*
  (non-Javadoc)
  
  @see
  com.impetus.kundera.configure.schema.api.AbstractSchemaManager#create
  (java.util.List)