开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
NdbSchemaCon.cpp
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：5k
源码类别：

MySQL数据库

开发平台：

Visual C++

NdbSchemaCon.cpp：源码内容
  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 */
  19. /*********************************************************************
  20. Name:          NdbSchemaCon.cpp
  21. Include:
  22. Link:
  23. Author:        UABMNST Mona Natterkvist UAB/B/SD
  24.                EMIKRON Mikael Ronstrom                         
  25. Date:          020826
  26. Version:       3.0
  27. Description:   Old Interface between application and NDB
  28. Documentation:
  29. Adjust:  980126  UABMNST   First version.
  30.          020826  EMIKRON   New version adapted to new DICT version
  31.          040524  Magnus Svensson - Adapted to not be included in public NdbApi
  32.                                    unless the user wants to use it.
  34.   NOTE: This file is only used as a compatibility layer for old test programs,
  35.         New programs should use NdbDictionary.hpp
  36. *********************************************************************/
  38. #include <ndb_global.h>
  39. #include <NdbApi.hpp>
  40. #include <NdbSchemaCon.hpp>
  41. #include <NdbSchemaOp.hpp>
  44. /*********************************************************************
  45. NdbSchemaCon(Ndb* aNdb);
  47. Parameters:    aNdb: Pointers to the Ndb object 
  48. Remark:        Creates a schemacon object. 
  49. ************************************************************************************************/
  50. NdbSchemaCon::NdbSchemaCon( Ndb* aNdb ) :
  51.   theNdb(aNdb),
  52.   theFirstSchemaOpInList(NULL),
  53.   theMagicNumber(0x75318642)
  54. { 
  55.   theError.code = 0;
  56. }//NdbSchemaCon::NdbSchemaCon()
  58. /*********************************************************************
  59. ~NdbSchemaCon();
  61. Remark:        Deletes the connection object. 
  62. ************************************************************************************************/
  63. NdbSchemaCon::~NdbSchemaCon()
  64. {
  65. }//NdbSchemaCon::~NdbSchemaCon()
  67. /*********************************************************************
  68. NdbSchemaOp* getNdbSchemaOp();
  70. Return Value    Return a pointer to a NdbSchemaOp object if getNdbSchemaOp was sussesful.
  71.                 Return NULL: In all other case. 
  72. Parameters:     tableId : Id of the database table beeing deleted.
  73. ************************************************************************************************/
  74. NdbSchemaOp*
  75. NdbSchemaCon::getNdbSchemaOp()
  76. { 
  77.   NdbSchemaOp* tSchemaOp;
  78.   if (theFirstSchemaOpInList != NULL) {
  79.     theError.code = 4401; // Only support one add table per transaction
  80.     return NULL;
  81.   }//if
  82.   tSchemaOp = new NdbSchemaOp(theNdb);
  83.   if ( tSchemaOp == NULL ) {
  84.     theError.code = 4000; // Could not allocate schema operation
  85.     return NULL;
  86.   }//if
  87.   theFirstSchemaOpInList = tSchemaOp;
  88.   int retValue = tSchemaOp->init(this);
  89.   if (retValue == -1) {
  90.     release();
  91.     theError.code = 4000; // Could not allocate buffer in schema operation
  92.     return NULL;
  93.   }//if
  94.   return tSchemaOp;
  95. }//NdbSchemaCon::getNdbSchemaOp()
  97. /*********************************************************************
  98. int execute();
  100. Return Value:  Return 0 : execute was successful.
  101.                Return -1: In all other case.  
  102. Parameters :   aTypeOfExec: Type of execute.
  103. Remark:        Initialise connection object for new transaction. 
  104. ************************************************************************************************/
  105. int 
  106. NdbSchemaCon::execute()
  107. {
  108.   if(theError.code != 0) {
  109.     return -1;
  110.   }//if
  112.   NdbSchemaOp* tSchemaOp;
  114.   tSchemaOp = theFirstSchemaOpInList;
  115.   if (tSchemaOp == NULL) {
  116.     theError.code = 4402;
  117.     return -1;
  118.   }//if
  120.   if ((tSchemaOp->sendRec() == -1) || (theError.code != 0)) {
  121.     // Error Code already set in other place
  122.     return -1;
  123.   }//if
  124.   
  125.   return 0;
  126. }//NdbSchemaCon::execute()
  128. /*********************************************************************
  129. void release();
  131. Remark:         Release all schemaop.
  132. ************************************************************************************************/
  133. void 
  134. NdbSchemaCon::release()
  135. {
  136.   NdbSchemaOp* tSchemaOp;
  137.   tSchemaOp = theFirstSchemaOpInList;
  138.   if (tSchemaOp != NULL) {
  139.     tSchemaOp->release();
  140.     delete tSchemaOp;
  141.   }//if
  142.   theFirstSchemaOpInList = NULL;
  143.   return;
  144. }//NdbSchemaCon::release()
  146. #include <NdbError.hpp>
  148. static void
  149. update(const NdbError & _err){
  150.   NdbError & error = (NdbError &) _err;
  151.   ndberror_struct ndberror = (ndberror_struct)error;
  152.   ndberror_update(&ndberror);
  153.   error = NdbError(ndberror);
  154. }
  156. const 
  157. NdbError & 
  158. NdbSchemaCon::getNdbError() const {
  159.   update(theError);
  160.   return theError;
  161. }
  166.