ndb - minor style fixes

parent 0d1f3920
...@@ -1078,7 +1078,7 @@ Ndb::opTupleIdOnNdb(const NdbTableImpl* table, ...@@ -1078,7 +1078,7 @@ Ndb::opTupleIdOnNdb(const NdbTableImpl* table,
tOperation->incValue("NEXTID", opValue); tOperation->incValue("NEXTID", opValue);
tRecAttrResult = tOperation->getValue("NEXTID"); tRecAttrResult = tOperation->getValue("NEXTID");
if (tConnection->execute( Commit ) == -1 ) if (tConnection->execute( NdbTransaction::Commit ) == -1 )
goto error_handler; goto error_handler;
tValue = tRecAttrResult->u_64_value(); tValue = tRecAttrResult->u_64_value();
...@@ -1093,7 +1093,7 @@ Ndb::opTupleIdOnNdb(const NdbTableImpl* table, ...@@ -1093,7 +1093,7 @@ Ndb::opTupleIdOnNdb(const NdbTableImpl* table,
tOperation->equal("SYSKEY_0", aTableId ); tOperation->equal("SYSKEY_0", aTableId );
tOperation->setValue("NEXTID", opValue); tOperation->setValue("NEXTID", opValue);
if (tConnection->execute( Commit ) == -1 ) if (tConnection->execute( NdbTransaction::Commit ) == -1 )
goto error_handler; goto error_handler;
range.reset(); range.reset();
...@@ -1110,7 +1110,7 @@ Ndb::opTupleIdOnNdb(const NdbTableImpl* table, ...@@ -1110,7 +1110,7 @@ Ndb::opTupleIdOnNdb(const NdbTableImpl* table,
tOperation->def_label(0); tOperation->def_label(0);
tOperation->interpret_exit_nok(9999); tOperation->interpret_exit_nok(9999);
if (tConnection->execute( Commit ) == -1) if (tConnection->execute( NdbTransaction::Commit ) == -1)
{ {
if (tConnection->theError.code != 9999) if (tConnection->theError.code != 9999)
goto error_handler; goto error_handler;
...@@ -1127,7 +1127,7 @@ Ndb::opTupleIdOnNdb(const NdbTableImpl* table, ...@@ -1127,7 +1127,7 @@ Ndb::opTupleIdOnNdb(const NdbTableImpl* table,
tOperation->readTuple(); tOperation->readTuple();
tOperation->equal("SYSKEY_0", aTableId ); tOperation->equal("SYSKEY_0", aTableId );
tRecAttrResult = tOperation->getValue("NEXTID"); tRecAttrResult = tOperation->getValue("NEXTID");
if (tConnection->execute( Commit ) == -1 ) if (tConnection->execute( NdbTransaction::Commit ) == -1 )
goto error_handler; goto error_handler;
opValue = tRecAttrResult->u_64_value(); // out opValue = tRecAttrResult->u_64_value(); // out
break; break;
......
...@@ -735,7 +735,7 @@ verifyHeadInline(const Tup& tup) ...@@ -735,7 +735,7 @@ verifyHeadInline(const Tup& tup)
if (! g_opt.m_oneblob) if (! g_opt.m_oneblob)
CHK((ra2 = g_opr->getValue("BL2")) != 0); CHK((ra2 = g_opr->getValue("BL2")) != 0);
if (tup.m_exists) { if (tup.m_exists) {
CHK(g_con->execute(Commit) == 0); CHK(g_con->execute(Commit, AbortOnError) == 0);
DBG("verifyHeadInline BL1"); DBG("verifyHeadInline BL1");
CHK(verifyHeadInline(g_opt.m_blob1, tup.m_blob1, ra1) == 0); CHK(verifyHeadInline(g_opt.m_blob1, tup.m_blob1, ra1) == 0);
if (! g_opt.m_oneblob) { if (! g_opt.m_oneblob) {
...@@ -743,7 +743,8 @@ verifyHeadInline(const Tup& tup) ...@@ -743,7 +743,8 @@ verifyHeadInline(const Tup& tup)
CHK(verifyHeadInline(g_opt.m_blob2, tup.m_blob2, ra2) == 0); CHK(verifyHeadInline(g_opt.m_blob2, tup.m_blob2, ra2) == 0);
} }
} else { } else {
CHK(g_con->execute(Commit) == -1 && g_con->getNdbError().code == 626); CHK(g_con->execute(Commit, AbortOnError) == -1 &&
g_con->getNdbError().code == 626);
} }
g_ndb->closeTransaction(g_con); g_ndb->closeTransaction(g_con);
g_opr = 0; g_opr = 0;
...@@ -1535,7 +1536,7 @@ testperf() ...@@ -1535,7 +1536,7 @@ testperf()
g_dic = g_ndb->getDictionary(); g_dic = g_ndb->getDictionary();
NdbDictionary::Table tab(g_opt.m_tnameperf); NdbDictionary::Table tab(g_opt.m_tnameperf);
if (g_dic->getTable(tab.getName()) != 0) if (g_dic->getTable(tab.getName()) != 0)
CHK(g_dic->dropTable(tab) == 0); CHK(g_dic->dropTable(tab.getName()) == 0);
// col A - pk // col A - pk
{ NdbDictionary::Column col("A"); { NdbDictionary::Column col("A");
col.setType(NdbDictionary::Column::Unsigned); col.setType(NdbDictionary::Column::Unsigned);
......
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