| /********************************************************************** |
| // @@@ START COPYRIGHT @@@ |
| // |
| // Licensed to the Apache Software Foundation (ASF) under one |
| // or more contributor license agreements. See the NOTICE file |
| // distributed with this work for additional information |
| // regarding copyright ownership. The ASF licenses this file |
| // to you under the Apache License, Version 2.0 (the |
| // "License"); you may not use this file except in compliance |
| // with the License. You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, |
| // software distributed under the License is distributed on an |
| // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| // KIND, either express or implied. See the License for the |
| // specific language governing permissions and limitations |
| // under the License. |
| // |
| // @@@ END COPYRIGHT @@@ |
| **********************************************************************/ |
| |
| /* -*-C++-*- |
| ***************************************************************************** |
| * |
| * File: CmpSeabaseDDLinitraf.cpp |
| * Description: Implements initialize trafodion |
| * |
| * |
| * Created: |
| * Language: C++ |
| * |
| * |
| ***************************************************************************** |
| */ |
| |
| #include "CmpSeabaseDDLincludes.h" |
| |
| enum InitTrafSteps { |
| IT_NO_CHANGE = -1, |
| IT_START = 0, |
| IT_VERIFY_USER, |
| IT_VERSION_CHECK, |
| IT_TDDL_TRUNCATE, |
| IT_START_XN, |
| IT_CREATE_MD_TABLES, |
| IT_UPDATE_MD_TABLES, |
| IT_CREATE_SCHEMA_OBJECTS, |
| IT_CREATE_MD_VIEWS, |
| IT_CREATE_REPOS, |
| IT_CREATE_PRIVMGR_REPOS, |
| IT_CREATE_LIBMGR, |
| IT_STEP_FAILED, |
| IT_ABORT_XN, |
| IT_FAILED, |
| IT_DONE, |
| }; |
| |
| |
| static void initDWS(CmpDDLwithStatusInfo *dws) |
| { |
| dws->setBlackBoxLen(0); |
| dws->setBlackBox(NULL); |
| dws->setComputeST(FALSE); |
| dws->setComputeET(FALSE); |
| dws->setReturnET(FALSE); |
| } |
| |
| static void setValuesInDWS( |
| CmpDDLwithStatusInfo *dws, |
| Lng32 nextStep, |
| const char * msg = NULL, |
| Lng32 subStep = 0, NABoolean isEndStep = FALSE, |
| NABoolean computeST = FALSE, |
| NABoolean computeET = FALSE, |
| NABoolean returnET = FALSE, |
| NABoolean done = FALSE) |
| { |
| if (msg) |
| dws->setMsg(msg); |
| if (nextStep != IT_NO_CHANGE) |
| dws->setStep(nextStep); |
| if (subStep >= 0) |
| dws->setSubstep(subStep); |
| dws->setEndStep(isEndStep); |
| |
| if (computeST) |
| dws->setComputeST(computeST); |
| if (computeET) |
| dws->setComputeET(computeET); |
| if (returnET) |
| dws->setReturnET(computeET); |
| |
| if (done) |
| dws->setDone(TRUE); |
| } |
| |
| short CmpSeabaseDDL::initTrafMD(CmpDDLwithStatusInfo *dws) |
| { |
| Lng32 cliRC = 0; |
| |
| initDWS(dws); |
| |
| while (1) // exit via return from within the while loop |
| { |
| switch (dws->step()) |
| { |
| case IT_START: |
| { |
| setValuesInDWS(dws, IT_VERIFY_USER, |
| "Initialize Trafodion: Started", |
| 0, TRUE); |
| |
| return 0; |
| } |
| break; |
| |
| case IT_VERIFY_USER: |
| { |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Verify User: Started", 1, FALSE, |
| TRUE); |
| |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| // verify user is authorized |
| if (!ComUser::isRootUserID()) |
| { |
| //*CmpCommon::diags() << DgSqlCode(CAT_NOT_AUTHORIZED); |
| |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| " Current user is not authorized to Initialize Trafodion. Must be Root to perform this operation.", 2, FALSE); |
| |
| return 0; |
| } |
| |
| CmpCommon::diags()->clear(); |
| |
| setValuesInDWS(dws, IT_VERSION_CHECK, |
| "Verify User: Completed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| return 0; |
| } // case 1 |
| break; |
| |
| case 2: |
| { |
| setValuesInDWS(dws, IT_FAILED, |
| "Verify User: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| break; |
| |
| } // switch |
| } |
| break; |
| |
| case IT_VERSION_CHECK: |
| { |
| Lng32 hbaseErrNum = 0; |
| NAString hbaseErrStr; |
| |
| ExpHbaseInterface * ehi = allocEHI(); |
| if (ehi == NULL) |
| { |
| setValuesInDWS(dws, IT_FAILED, NULL, |
| 0, TRUE); |
| |
| break; |
| } |
| |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Version Check: Started", 1, FALSE, |
| TRUE); |
| |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| // check if traf is already initialized |
| Lng32 errNum = validateVersions(&ActiveSchemaDB()->getDefaults(), ehi, |
| NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, |
| &hbaseErrNum, &hbaseErrStr); |
| deallocEHI(ehi); |
| if (errNum == 0) |
| { |
| CmpCommon::context()->setIsUninitializedSeabase(FALSE); |
| |
| // add warning 1392 to indicate that traf is already init. |
| // This is needed as installer checks for this error code to |
| // determine if traf is initialized. |
| *CmpCommon::diags() << DgSqlCode(TRAF_ALREADY_INITIALIZED); |
| |
| // Metadata is initialized |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| " Trafodion is already initialized on this system.", |
| 2, FALSE); |
| |
| return 0; |
| } |
| |
| CmpCommon::context()->setIsUninitializedSeabase(TRUE); |
| CmpCommon::context()->uninitializedSeabaseErrNum() = errNum; |
| CmpCommon::context()->hbaseErrNum() = hbaseErrNum; |
| CmpCommon::context()->hbaseErrStr() = hbaseErrStr; |
| |
| // Return any other error besides uninitialized traf error. |
| if (errNum != -TRAF_NOT_INITIALIZED) |
| { |
| // add returned error nums as warnings. |
| // It will show why init traf failed. |
| if (errNum == -TRAF_HBASE_ACCESS_ERROR) |
| *CmpCommon::diags() << DgSqlCode(-errNum) |
| << DgInt0(hbaseErrNum) |
| << DgString0(hbaseErrStr); |
| else |
| *CmpCommon::diags() << DgSqlCode(-errNum); |
| |
| char msgBuf[1000]; |
| sprintf(msgBuf, " Error %d returned. See error details for further action.", -errNum); |
| |
| setValuesInDWS(dws, IT_NO_CHANGE, msgBuf, 3, FALSE); |
| |
| return 0; |
| } |
| |
| CmpCommon::diags()->clear(); |
| |
| setValuesInDWS(dws, IT_TDDL_TRUNCATE, |
| "Version Check: Completed", |
| 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } // case 1 |
| break; |
| |
| case 2: |
| { |
| setValuesInDWS(dws, IT_DONE, |
| "Version Check: Completed", |
| 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| break; |
| |
| case 3: |
| { |
| setValuesInDWS(dws, IT_FAILED, "Version Check: Failed", |
| 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| break; |
| |
| } // switch |
| } |
| break; |
| |
| case IT_TDDL_TRUNCATE: |
| { |
| ExpHbaseInterface * ehi = allocEHI(); |
| if (ehi == NULL) |
| { |
| setValuesInDWS(dws, IT_FAILED); |
| |
| break; |
| } |
| |
| // truncate DTM table TDDL. |
| // Do not do this operation under a dtm transaction. |
| // See file core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/client/transactional/TmDDL.java |
| // Keep the name TRAFODION._DTM_.TDDL and col fam "tddlcf" in sync with |
| // that file. |
| HbaseStr tddlTable; |
| const NAString tddlNAS("TRAFODION._DTM_.TDDL"); |
| tddlTable.val = (char*)tddlNAS.data(); |
| tddlTable.len = tddlNAS.length(); |
| if (ehi->exists(tddlTable) == -1) // exists |
| { |
| ehi->truncate(tddlTable, TRUE, TRUE); |
| } |
| |
| deallocEHI(ehi); |
| |
| setValuesInDWS(dws, IT_START_XN); |
| } |
| break; |
| |
| case IT_START_XN: |
| { |
| if (dws->getDDLXns()) |
| { |
| ExeCliInterface cliInterface(STMTHEAP, 0, NULL, |
| CmpCommon::context()->sqlSession()->getParentQid()); |
| |
| NABoolean xnWasStartedHere = FALSE; |
| if (beginXnIfNotInProgress(&cliInterface, xnWasStartedHere)) |
| { |
| setValuesInDWS(dws, IT_FAILED); |
| break; |
| } |
| dws->setXnStarted(TRUE); |
| } |
| |
| setValuesInDWS(dws, IT_CREATE_MD_TABLES); |
| } |
| break; |
| |
| case IT_CREATE_MD_TABLES: |
| { |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Create Metadata Tables: Started", 1, FALSE, |
| TRUE, FALSE, FALSE); |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| ExpHbaseInterface * ehi = allocEHI(); |
| if (ehi == NULL) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Create Metadata Tables: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| Lng32 numTables = sizeof(allMDtablesInfo) / sizeof(MDTableInfo); |
| const char* sysCat = |
| ActiveSchemaDB()->getDefaults().getValue(SEABASE_CATALOG); |
| |
| // create hbase physical objects |
| for (Lng32 i = 0; i < numTables; i++) |
| { |
| const MDTableInfo &mdti = allMDtablesInfo[i]; |
| |
| HbaseStr hbaseObject; |
| NAString hbaseObjectStr(sysCat); |
| hbaseObjectStr += "."; |
| hbaseObjectStr += SEABASE_MD_SCHEMA; |
| hbaseObjectStr += "."; |
| hbaseObjectStr += mdti.newName; |
| hbaseObject.val = (char*)hbaseObjectStr.data(); |
| hbaseObject.len = hbaseObjectStr.length(); |
| if (createHbaseTable(ehi, &hbaseObject, SEABASE_DEFAULT_COL_FAMILY, NULL, |
| 0, 0, NULL, |
| FALSE, dws->getDDLXns()) == -1) |
| { |
| deallocEHI(ehi); |
| |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Create Metadata Tables: Failed", |
| 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| } // for |
| |
| deallocEHI(ehi); |
| ehi = NULL; |
| |
| setValuesInDWS(dws, IT_UPDATE_MD_TABLES, |
| "Create Metadata Tables: Completed", |
| 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| break; |
| |
| } // switch |
| } |
| break; |
| |
| case IT_UPDATE_MD_TABLES: |
| { |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Update Metadata Tables: Started", 1, FALSE, |
| TRUE, FALSE, FALSE); |
| |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| ExeCliInterface cliInterface(STMTHEAP, 0, NULL, |
| CmpCommon::context()->sqlSession()->getParentQid()); |
| |
| cliRC = cliInterface.holdAndSetCQD("traf_bootstrap_md_mode", "ON"); |
| if (cliRC < 0) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Update Metadata Tables: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| Int64 objectFlags = 0; |
| Int64 schemaUID = -1; |
| |
| const char* sysCat = |
| ActiveSchemaDB()->getDefaults().getValue(SEABASE_CATALOG); |
| |
| // Create Seabase metadata schema |
| schemaUID = -1; |
| if (updateSeabaseMDObjectsTable(&cliInterface,sysCat,SEABASE_MD_SCHEMA, |
| SEABASE_SCHEMA_OBJECTNAME, |
| COM_PRIVATE_SCHEMA_OBJECT,"Y",SUPER_USER, |
| SUPER_USER,objectFlags, schemaUID)) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Update Metadata Tables: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| // update MD with information about metadata objects |
| Lng32 numTables = sizeof(allMDtablesInfo) / sizeof(MDTableInfo); |
| for (Lng32 i = 0; i < numTables; i++) |
| { |
| const MDTableInfo &mdti = allMDtablesInfo[i]; |
| MDDescsInfo &mddi = CmpCommon::context()->getTrafMDDescsInfo()[i]; |
| |
| if (mdti.isIndex) |
| continue; |
| |
| Int64 objUID = -1; |
| if (updateSeabaseMDTable(&cliInterface, |
| sysCat, SEABASE_MD_SCHEMA, mdti.newName, |
| COM_BASE_TABLE_OBJECT, |
| "Y", |
| mddi.tableInfo, |
| mddi.numNewCols, |
| mddi.newColInfo, |
| mddi.numNewKeys, |
| mddi.newKeyInfo, |
| mddi.numIndexes, |
| mddi.indexInfo, |
| objUID)) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Update Metadata Tables: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| } // for |
| |
| // update metadata with metadata indexes information |
| for (Lng32 i = 0; i < numTables; i++) |
| { |
| const MDTableInfo &mdti = allMDtablesInfo[i]; |
| MDDescsInfo &mddi = CmpCommon::context()->getTrafMDDescsInfo()[i]; |
| |
| if (NOT mdti.isIndex) |
| continue; |
| |
| ComTdbVirtTableTableInfo * tableInfo = |
| new(STMTHEAP) ComTdbVirtTableTableInfo[1]; |
| |
| tableInfo->tableName = NULL; |
| tableInfo->createTime = 0; |
| tableInfo->redefTime = 0; |
| tableInfo->objUID = 0; |
| tableInfo->objOwnerID = SUPER_USER; |
| tableInfo->schemaOwnerID = SUPER_USER; |
| tableInfo->isAudited = 1; |
| tableInfo->validDef = 1; |
| tableInfo->hbaseCreateOptions = NULL; |
| tableInfo->numSaltPartns = 0; |
| tableInfo->rowFormat = COM_UNKNOWN_FORMAT_TYPE; |
| tableInfo->objectFlags = 0; |
| |
| Int64 objUID = -1; |
| if (updateSeabaseMDTable(&cliInterface, |
| sysCat, SEABASE_MD_SCHEMA, mdti.newName, |
| COM_INDEX_OBJECT, |
| "Y", |
| tableInfo, |
| mddi.numNewCols, |
| mddi.newColInfo, |
| mddi.numNewKeys, |
| mddi.newKeyInfo, |
| 0, NULL, |
| objUID)) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Update Metadata Tables: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| return 0; |
| } |
| } // for |
| |
| // update SPJ info |
| // Note that this is not an existing jar file, the class |
| // loader will attempt to load the class from the CLASSPATH if |
| // it can't find this jar |
| NAString installJar(getenv("TRAF_HOME")); |
| installJar += "/export/lib/trafodion-sql-currversion.jar"; |
| if (updateSeabaseMDSPJ(&cliInterface, sysCat, SEABASE_MD_SCHEMA, |
| SEABASE_VALIDATE_LIBRARY, |
| installJar.data(),SUPER_USER,SUPER_USER, |
| &seabaseMDValidateRoutineInfo, |
| sizeof(seabaseMDValidateRoutineColInfo) / sizeof(ComTdbVirtTableColumnInfo), |
| seabaseMDValidateRoutineColInfo)) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Update Metadata Tables: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| updateSeabaseVersions(&cliInterface, sysCat); |
| updateSeabaseAuths(&cliInterface, sysCat); |
| |
| CmpCommon::context()->setIsUninitializedSeabase(FALSE); |
| CmpCommon::context()->uninitializedSeabaseErrNum() = 0; |
| |
| setValuesInDWS(dws, IT_CREATE_SCHEMA_OBJECTS, |
| "Update Metadata Tables: Completed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } // case 1 |
| } // switch |
| } |
| break; |
| |
| case IT_CREATE_SCHEMA_OBJECTS: |
| { |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Create Schema Objects: Started", 1, FALSE, |
| TRUE, FALSE, FALSE); |
| |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| ExeCliInterface cliInterface(STMTHEAP, 0, NULL, |
| CmpCommon::context()->sqlSession()->getParentQid()); |
| |
| if (createDefaultSystemSchema(&cliInterface)) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Create Schema Objects: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| if (createSchemaObjects(&cliInterface)) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Create Schema Objects: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| setValuesInDWS(dws, IT_CREATE_MD_VIEWS, |
| "Create Schema Objects: Completed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } // case 1 |
| } // switch |
| } |
| break; |
| |
| case IT_CREATE_MD_VIEWS: |
| { |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Create Metadata Views: Started", 1, FALSE, |
| TRUE, FALSE, FALSE); |
| |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| ExeCliInterface cliInterface(STMTHEAP, 0, NULL, |
| CmpCommon::context()->sqlSession()->getParentQid()); |
| |
| if (createMetadataViews(&cliInterface)) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Create Metadata Views: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| // If this is a MINIMAL initialization, don't create the |
| // repository or privilege manager tables. |
| // (This happens underneath an upgrade, for example, |
| // because the repository and privilege manager tables |
| // already exist and we will later upgrade them.) |
| setValuesInDWS(dws, |
| (dws->getMinimalInitTraf() ? IT_CREATE_LIBMGR : IT_CREATE_REPOS), |
| "Create Metadata Views: Completed", |
| 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } // case |
| } // switch |
| } |
| break; |
| |
| case IT_CREATE_REPOS: |
| { |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Create Repository Tables: Started", 1, FALSE, |
| TRUE, FALSE, FALSE); |
| |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| ExeCliInterface cliInterface(STMTHEAP, 0, NULL, |
| CmpCommon::context()->sqlSession()->getParentQid()); |
| |
| if (createRepos(&cliInterface)) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Create Repository Tables: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| return 0; |
| } |
| |
| setValuesInDWS(dws, IT_CREATE_PRIVMGR_REPOS, |
| "Create Repository Tables: Completed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } // case 1 |
| } // switch |
| } |
| break; |
| |
| case IT_CREATE_PRIVMGR_REPOS: |
| { |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Create PrivMgr Tables: Started", 1, FALSE, |
| TRUE, FALSE, FALSE); |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| ExeCliInterface cliInterface(STMTHEAP, 0, NULL, |
| CmpCommon::context()->sqlSession()->getParentQid()); |
| |
| if (createPrivMgrRepos(&cliInterface, dws->getDDLXns())) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Create PrivMgr Tables: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| return 0; |
| } |
| |
| setValuesInDWS(dws, IT_CREATE_LIBMGR, |
| "Create PrivMgr Tables: Completed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } // case 1 |
| } // switch |
| } |
| break; |
| |
| case IT_CREATE_LIBMGR: |
| { |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Create Library Manager: Started", 1, FALSE, |
| TRUE, FALSE, FALSE); |
| |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| ExeCliInterface cliInterface(STMTHEAP, 0, NULL, |
| CmpCommon::context()->sqlSession()->getParentQid()); |
| |
| if (createSeabaseLibmgr (&cliInterface)) |
| { |
| setValuesInDWS(dws, IT_STEP_FAILED, |
| "Create Library Manager: Failed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| |
| cliRC = cliInterface.restoreCQD("traf_bootstrap_md_mode"); |
| |
| setValuesInDWS(dws, IT_DONE, |
| "Create Library Manager: Completed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } // case 1 |
| } // switch |
| } |
| break; |
| |
| case IT_STEP_FAILED: |
| { |
| setValuesInDWS(dws, (dws->xnStarted() ? IT_ABORT_XN : IT_FAILED)); |
| |
| break; |
| } |
| break; |
| |
| case IT_ABORT_XN: |
| { |
| switch (dws->subStep()) |
| { |
| case 0: |
| { |
| setValuesInDWS(dws, IT_NO_CHANGE, |
| "Abort Transaction: Started", 1, FALSE, |
| TRUE, FALSE, FALSE); |
| |
| return 0; |
| } |
| break; |
| |
| case 1: |
| { |
| ExeCliInterface cliInterface(STMTHEAP, 0, NULL, |
| CmpCommon::context()->sqlSession()->getParentQid()); |
| |
| NABoolean xnWasStartedHere = dws->xnStarted(); |
| endXnIfStartedHere(&cliInterface, xnWasStartedHere, -1); |
| dws->setXnStarted(xnWasStartedHere); |
| |
| setValuesInDWS(dws, IT_FAILED, |
| "Abort Transaction: Completed", 0, TRUE, |
| FALSE, TRUE, TRUE); |
| |
| return 0; |
| } |
| break; |
| } // switch |
| } |
| break; |
| |
| case IT_FAILED: |
| { |
| setValuesInDWS(dws, IT_START, |
| "Initialize Trafodion: Failed", 0, FALSE, |
| FALSE, TRUE, TRUE, TRUE); |
| |
| return -1; |
| } |
| break; |
| |
| case IT_DONE: |
| { |
| ExeCliInterface cliInterface(STMTHEAP, 0, NULL, |
| CmpCommon::context()->sqlSession()->getParentQid()); |
| |
| NABoolean xnWasStartedHere = dws->xnStarted(); |
| endXnIfStartedHere(&cliInterface, xnWasStartedHere, 0); |
| dws->setXnStarted(xnWasStartedHere); |
| |
| setValuesInDWS(dws, IT_START, |
| "Initialize Trafodion: Completed", 0, FALSE, |
| FALSE, TRUE, TRUE, TRUE); |
| |
| return 0; |
| } |
| break; |
| } // switch |
| } // while |
| |
| return 0; |
| } |
