Commit ed8d32f6 authored by unknown's avatar unknown

Merge bk-internal.mysql.com:/home/bk/mysql-4.1

into mysql.com:/home/my/mysql-4.1

parents 72a71135 be567b59
......@@ -7,6 +7,7 @@ DIRS := \
ndbapi \
mgmsrv \
mgmapi \
newtonapi \
rep \
mgmclient \
cw \
......
......@@ -15,6 +15,7 @@
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
#include "dba_internal.hpp"
#include "NdbSchemaCon.hpp"
static bool getNdbAttr(DBA_DataTypes_t,
Size_t,
......@@ -31,7 +32,7 @@ DBA_CreateTable(const char* TableName,
if(DBA_TableExists(TableName))
return DBA_NO_ERROR;
NdbSchemaCon * schemaCon = DBA__TheNdb->startSchemaTransaction();
NdbSchemaCon * schemaCon = NdbSchemaCon::startSchemaTrans(DBA__TheNdb);
if(schemaCon == 0){
DBA__SetLatestError(DBA_NDB_ERROR, 0,
"Internal NDB error: No schema transaction");
......@@ -40,7 +41,7 @@ DBA_CreateTable(const char* TableName,
NdbSchemaOp * schemaOp = schemaCon->getNdbSchemaOp();
if(schemaOp == 0){
DBA__TheNdb->closeSchemaTransaction(schemaCon);
NdbSchemaCon::closeSchemaTrans(schemaCon);
DBA__SetLatestError(DBA_NDB_ERROR, 0,
"Internal NDB error: No schema op");
return DBA_NDB_ERROR;
......@@ -56,7 +57,7 @@ DBA_CreateTable(const char* TableName,
80,
1,
false) == -1){
DBA__TheNdb->closeSchemaTransaction(schemaCon);
NdbSchemaCon::closeSchemaTrans(schemaCon);
DBA__SetLatestError(DBA_NDB_ERROR, 0,
"Internal NDB error: Create table failed");
return DBA_NDB_ERROR;
......@@ -71,7 +72,7 @@ DBA_CreateTable(const char* TableName,
&attrSize,
&arraySize,
&attrType)){
DBA__TheNdb->closeSchemaTransaction(schemaCon);
NdbSchemaCon::closeSchemaTrans(schemaCon);
DBA__SetLatestError(DBA_APPLICATION_ERROR, 0,
"Invalid datatype/size combination");
return DBA_APPLICATION_ERROR;
......@@ -82,7 +83,7 @@ DBA_CreateTable(const char* TableName,
attrSize,
arraySize,
attrType) == -1){
DBA__TheNdb->closeSchemaTransaction(schemaCon);
NdbSchemaCon::closeSchemaTrans(schemaCon);
DBA__SetLatestError(DBA_NDB_ERROR, 0,
"Internal NDB error: Create attribute failed");
return DBA_NDB_ERROR;
......@@ -90,13 +91,13 @@ DBA_CreateTable(const char* TableName,
}
if(schemaCon->execute() == -1){
DBA__TheNdb->closeSchemaTransaction(schemaCon);
NdbSchemaCon::closeSchemaTrans(schemaCon);
DBA__SetLatestError(DBA_NDB_ERROR, 0,
"Internal NDB error: Execute schema failed");
return DBA_NDB_ERROR;
}
DBA__TheNdb->closeSchemaTransaction(schemaCon);
NdbSchemaCon::closeSchemaTrans(schemaCon);
return DBA_NO_ERROR;
}
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment