Method EffectSchema

IO/SQL/vtkSQLDatabase.cxx:398–635

------------------------------------------------------------------------------

//------------------------------------------------------------------------------
bool vtkSQLDatabase::EffectSchema(vtkSQLDatabaseSchema* schema, bool dropIfExists)
{
  if (!this->IsOpen())
  {
    vtkGenericWarningMacro("Unable to effect the schema: no database is open");
    return false;
  }

  // Instantiate an empty query and begin the transaction.
  vtkSQLQuery* query = this->GetQueryInstance();
  if (!query->BeginTransaction())
  {
    vtkGenericWarningMacro("Unable to effect the schema: unable to begin transaction");
    return false;
  }

  // Loop over preamble statements of the schema and execute them only if they are relevant
  int numPre = schema->GetNumberOfPreambles();
  for (int preHandle = 0; preHandle < numPre; ++preHandle)
  {
    // Don't execute if the statement is not for this backend
    const char* preBackend = schema->GetPreambleBackendFromHandle(preHandle);
    if (strcmp(preBackend, VTK_SQL_ALLBACKENDS) != 0 &&
      strcmp(preBackend, this->GetClassName()) != 0)
    {
      continue;
    }

    vtkStdString preStr = schema->GetPreambleActionFromHandle(preHandle);
    query->SetQuery(preStr.c_str());
    if (!query->Execute())
    {
      vtkGenericWarningMacro("Unable to effect the schema: unable to execute query.\nDetails: "
        << query->GetLastErrorText());
      query->RollbackTransaction();
      query->Delete();
      return false;
    }
  }

  // Loop over all tables of the schema and create them
  int numTbl = schema->GetNumberOfTables();
  for (int tblHandle = 0; tblHandle < numTbl; ++tblHandle)
  {
    // Construct the CREATE TABLE query for this table
    std::string queryStr("CREATE TABLE ");
    queryStr += this->GetTablePreamble(dropIfExists);
    queryStr += schema->GetTableNameFromHandle(tblHandle);
    queryStr += " (";

    // Loop over all columns of the current table
    int numCol = schema->GetNumberOfColumnsInTable(tblHandle);
    if (numCol < 0)
    {
      query->RollbackTransaction();
      query->Delete();
      return false;
    }