Category

Development Platform
Home > SourceCode/Document > Database system > MySQL > View Code
dba_schema.cpp
Package: mysql-4.1.16-win-src.zip　[view]
Upload User: romrleung
Upload Date: 2022-05-23
Package Size: 18897k
Code Size: 4k
Category:

MySQL

Development Platform:

Visual C++

dba_schema.cpp：Code Content
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. #include "dba_internal.hpp"
  18. #include "NdbSchemaCon.hpp"
  20. static bool getNdbAttr(DBA_DataTypes_t,
  21.        Size_t,
  22.        int * attrSize,
  23.        int * arraySize,
  24.        AttrType * attrType);
  26. extern "C"
  27. DBA_Error_t 
  28. DBA_CreateTable(const char* TableName, 
  29. int NbColumns, 
  30. const DBA_ColumnDesc_t Columns[] ){
  31.   
  32.   if(DBA_TableExists(TableName))
  33.     return DBA_NO_ERROR;
  34.   
  35.   NdbSchemaCon * schemaCon = NdbSchemaCon::startSchemaTrans(DBA__TheNdb);
  36.   if(schemaCon == 0){
  37.     DBA__SetLatestError(DBA_NDB_ERROR, 0,
  38. "Internal NDB error: No schema transaction");
  39.     return DBA_NDB_ERROR;
  40.   }
  41.   
  42.   NdbSchemaOp * schemaOp   = schemaCon->getNdbSchemaOp();
  43.   if(schemaOp == 0){    
  44.     NdbSchemaCon::closeSchemaTrans(schemaCon);    
  45.     DBA__SetLatestError(DBA_NDB_ERROR, 0,
  46. "Internal NDB error: No schema op");
  47.     return DBA_NDB_ERROR;
  48.   }
  50.   if(schemaOp->createTable( TableName,
  51.     8, // Data Size
  52.     TupleKey,
  53.     2, // Index size
  54.     All,
  55.     6,
  56.     78,
  57.     80,
  58.     1,
  59.     false) == -1){
  60.     NdbSchemaCon::closeSchemaTrans(schemaCon);    
  61.     DBA__SetLatestError(DBA_NDB_ERROR, 0,
  62. "Internal NDB error: Create table failed");
  63.     return DBA_NDB_ERROR;
  64.   }
  65.   
  66.   for (int i = 0; i < NbColumns; i++){
  67.     int attrSize;
  68.     int arraySize;
  69.     AttrType attrType;
  70.     
  71.     if(!getNdbAttr(Columns[i].DataType, Columns[i].Size,
  72.    &attrSize,
  73.    &arraySize,
  74.    &attrType)){
  75.       NdbSchemaCon::closeSchemaTrans(schemaCon);    
  76.       DBA__SetLatestError(DBA_APPLICATION_ERROR, 0,
  77.   "Invalid datatype/size combination");
  78.       return DBA_APPLICATION_ERROR;
  79.     }
  80.     
  81.     if(schemaOp->createAttribute( Columns[i].Name,
  82.   Columns[i].IsKey ? TupleKey : NoKey,
  83.   attrSize,
  84.   arraySize,
  85.   attrType) == -1){
  86.       NdbSchemaCon::closeSchemaTrans(schemaCon);    
  87.       DBA__SetLatestError(DBA_NDB_ERROR, 0,
  88.   "Internal NDB error: Create attribute failed");
  89.       return DBA_NDB_ERROR;
  90.     }
  91.   }
  92.   
  93.   if(schemaCon->execute() == -1){
  94.     NdbSchemaCon::closeSchemaTrans(schemaCon);    
  95.     DBA__SetLatestError(DBA_NDB_ERROR, 0,
  96. "Internal NDB error: Execute schema failed");
  97.     return DBA_NDB_ERROR;
  98.   }
  99.   
  100.   NdbSchemaCon::closeSchemaTrans(schemaCon);    
  101.     
  102.   return DBA_NO_ERROR;
  103. }
  105. DBA_Error_t 
  106. DBA_DropTable( char* TableName ){
  107.   return DBA_NOT_IMPLEMENTED;
  108. }
  110. Boolean_t 
  111. DBA_TableExists( const char* TableName ){
  112.   NdbDictionary::Dictionary * dict = DBA__TheNdb->getDictionary();
  113.   if(dict == 0){
  114.     return 0;
  115.   }
  116.   
  117.   const NdbDictionary::Table * tab = dict->getTable(TableName);
  118.   if(tab == 0){
  119.     return 0;
  120.   }
  121.   return 1;
  122. }
  124. static
  125. bool 
  126. getNdbAttr(DBA_DataTypes_t type,
  127.    Size_t size,
  128.    int * attrSize,
  129.    int * arraySize,
  130.    AttrType * attrType) {
  131.   
  132.   if(type == DBA_CHAR){
  133.     * attrType = String;
  134.     * attrSize  = 8;
  135.     * arraySize = size;
  136.     return true;
  137.   }
  138.   
  139.   * attrType = Signed;
  140.   if((size % 4) == 0){
  141.     * attrSize  = 32;
  142.     * arraySize = size / 4;
  143.     return true;
  144.   }
  145.   
  146.   * attrSize  = 8;
  147.   * arraySize = size;
  148.   
  149.   return true;
  150. }