Exec_create_index.cpp
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:2k
源码类别:
MySQL数据库
开发平台:
Visual C++
- /* Copyright (C) 2003 MySQL AB
- This program is free software; you can redistribute it and/or modify
- it under the terms of the GNU General Public License as published by
- the Free Software Foundation; either version 2 of the License, or
- (at your option) any later version.
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU General Public License for more details.
- You should have received a copy of the GNU General Public License
- along with this program; if not, write to the Free Software
- Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
- #include <NdbApi.hpp>
- #include <dictionary/DictSchema.hpp>
- #include <codegen/Code_create_index.hpp>
- void
- Exec_create_index::execute(Ctx& ctx, Ctl& ctl)
- {
- const Code& code = getCode();
- Data& data = getData();
- Ndb* const ndb = ndbObject();
- NdbDictionary::Dictionary* ndbDictionary = ndb->getDictionary();
- if (ndbDictionary == 0) {
- ctx.pushStatus(ndb, "getDictionary");
- return;
- }
- NdbDictionary::Index ndbIndex(code.m_indexName.c_str());
- ndbIndex.setTable(code.m_tableName.c_str());
- ndbIndex.setType((NdbDictionary::Index::Type)code.m_type);
- for (unsigned i = 1; i <= code.m_attrCount; i++) {
- ndbIndex.addIndexColumn(code.m_attrList[i]);
- }
- // setting fragment type not supported in ndb api
- ndbIndex.setLogging(code.m_logging);
- dictSchema().deleteTable(ctx, code.m_tableName);
- if (ndbDictionary->createIndex(ndbIndex) == -1) {
- ctx.pushStatus(ndbDictionary->getNdbError(), "createIndex %s", ndbIndex.getName());
- return;
- }
- ctx_log1(("index %s on %s created", ndbIndex.getName(), ndbIndex.getTable()));
- }