Category

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

MySQL

Development Platform:

Visual C++

dba_init.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 */
  18. #include "dba_internal.hpp"
  19. #include "dba_process.hpp"
  20. #include <NdbOut.hpp>
  23. #ifdef NDB_WIN32
  24. static NdbMutex & DBA__InitMutex = * NdbMutex_Create();
  25. #else
  26. static NdbMutex DBA__InitMutex = NDB_MUTEX_INITIALIZER;
  27. #endif
  29. Ndb      * DBA__TheNdb           = 0;
  30. NdbMutex * DBA__TheNewtonMutex   = 0;
  31. unsigned DBA__SentTransactions   = 0;
  32. unsigned DBA__RecvTransactions   = 0;
  33. NewtonBatchProcess * DBA__TheNBP = 0;
  35. extern "C"
  36. DBA_Error_t
  37. DBA_Open( ) {
  38.   NdbMutex_Lock(&DBA__InitMutex);
  39.   
  40.   if(DBA__TheNdb != 0){
  41.     NdbMutex_Unlock(&DBA__InitMutex);
  42.     return DBA_NO_ERROR;
  43.   }
  44.   
  45.   DBA__TheNdb = new Ndb("Newton");
  46.   DBA__TheNdb->init(1024);
  47.   if(DBA__TheNdb->waitUntilReady() != 0){
  48.     delete DBA__TheNdb; DBA__TheNdb = 0;
  49.     NdbMutex_Unlock(&DBA__InitMutex);
  50.     return DBA_NDB_ERROR;
  51.   }
  52.   DBA__TheNewtonMutex = NdbMutex_Create();
  53.   DBA__TheNBP = new NewtonBatchProcess(* DBA__TheNdb, * DBA__TheNewtonMutex);
  54.   DBA__TheNBP->doStart();
  55.   NdbMutex_Unlock(&DBA__InitMutex);
  56.   return DBA_NO_ERROR;
  57. }
  60. /**
  61.  * Closes the database.
  62.  * 
  63.  * @return Error status
  64.  */
  65. extern "C"
  66. DBA_Error_t
  67. DBA_Close(void){
  69.   NdbMutex_Lock(&DBA__InitMutex);
  71.   if(DBA__TheNBP != 0)
  72.     DBA__TheNBP->doStop(true);
  73.   delete DBA__TheNBP; 
  74.   DBA__TheNBP = 0;
  75.   
  76.   if(DBA__TheNdb != 0)
  77.     delete DBA__TheNdb;
  78.   DBA__TheNdb = 0;
  79.   
  80.   if(DBA__TheNewtonMutex != 0)
  81.     NdbMutex_Destroy(DBA__TheNewtonMutex);
  82.   DBA__TheNewtonMutex = 0;
  84.   NdbMutex_Unlock(&DBA__InitMutex);
  85.   return DBA_NO_ERROR;
  86. }