DictTable.cpp
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:3k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2003 MySQL AB
  2.    This program is free software; you can redistribute it and/or modify
  3.    it under the terms of the GNU General Public License as published by
  4.    the Free Software Foundation; either version 2 of the License, or
  5.    (at your option) any later version.
  6.    This program is distributed in the hope that it will be useful,
  7.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  8.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  9.    GNU General Public License for more details.
  10.    You should have received a copy of the GNU General Public License
  11.    along with this program; if not, write to the Free Software
  12.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  13. #include <NdbApi.hpp>
  14. #include <common/common.hpp>
  15. #include <common/Ctx.hpp>
  16. #include <common/ConnArea.hpp>
  17. #include "DictSchema.hpp"
  18. #include "DictTable.hpp"
  19. #include "DictColumn.hpp"
  20. #include "DictColumn.hpp"
  21. DictTable::~DictTable()
  22. {
  23.     for (Columns::iterator i = m_columns.begin(); i != m_columns.end(); i++) {
  24. delete *i;
  25. *i = 0;
  26.     }
  27.     for (Indexes::iterator i = m_indexes.begin(); i != m_indexes.end(); i++) {
  28. delete *i;
  29. *i = 0;
  30.     }
  31. }
  32. DictColumn*
  33. DictTable::findColumn(const BaseString& name) const
  34. {
  35.     for (unsigned i = 1; i <= getSize(); i++) {
  36. DictColumn* column = m_columns[i];
  37. ctx_assert(column != 0);
  38. if (strcmp(column->getName().c_str(), name.c_str()) == 0)
  39.     return column;
  40.     }
  41.     return 0;
  42. }
  43. DictColumn*
  44. DictTable::loadColumn(Ctx& ctx, unsigned position)
  45. {
  46.     Ndb* ndb = m_connArea.ndbObject();
  47.     NdbDictionary::Dictionary* ndbDictionary = ndb->getDictionary();
  48.     if (ndbDictionary == 0) {
  49. ctx.pushStatus(ndb, "getDictionary");
  50. return 0;
  51.     }
  52.     const NdbDictionary::Table* ndbTable = ndbDictionary->getTable(m_name.c_str());
  53.     ctx_assert(ndbTable != 0);
  54.     ctx_assert(position != 0);
  55.     NdbAttrId attrId = position - 1;
  56.     const NdbDictionary::Column* ndbColumn = ndbTable->getColumn(attrId);
  57.     ctx_assert(ndbColumn != 0);
  58.     SqlType sqlType(ctx, ndbColumn);
  59.     if (! ctx.ok())
  60. return 0;
  61.     DictColumn* column = new DictColumn(m_connArea, ndbColumn->getName(), sqlType);
  62.     setColumn(position, column);
  63.     column->m_key = column->m_tupleId = false;
  64.     if (ndbColumn->getPrimaryKey())
  65. column->m_key = true;
  66.     if (ndbColumn->getTupleKey())
  67. column->m_key = column->m_tupleId = true;
  68.     if (column->m_key)
  69. m_keys.push_back(column);
  70.     // props
  71.     const char* value;
  72.     column->m_autoIncrement = false;
  73.     if (ndbColumn->getAutoIncrement())
  74. column->m_autoIncrement = true;
  75.     column->m_defaultValue = 0;
  76.     if ((value = ndbColumn->getDefaultValue()) != 0 && strlen(value) != 0)
  77. column->m_defaultValue = strcpy(new char[strlen(value) + 1], value);
  78.     ctx_log4(("column %u %s keyFlag=%d idFlag=%d", position, ndbColumn->getName(), column->m_key, column->m_tupleId));
  79.     if (column->m_tupleId)
  80. m_tupleId = position;
  81.     if (column->m_autoIncrement)
  82. m_autoIncrement = position;
  83.     return column;
  84. }