summaryrefslogtreecommitdiff
path: root/ndb/tools/create_index/create_index.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ndb/tools/create_index/create_index.cpp')
-rw-r--r--ndb/tools/create_index/create_index.cpp95
1 files changed, 95 insertions, 0 deletions
diff --git a/ndb/tools/create_index/create_index.cpp b/ndb/tools/create_index/create_index.cpp
new file mode 100644
index 00000000000..32da39a5208
--- /dev/null
+++ b/ndb/tools/create_index/create_index.cpp
@@ -0,0 +1,95 @@
+/* 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 <stdio.h>
+
+#include <NdbOut.hpp>
+#include <NdbApi.hpp>
+#include <NDBT.hpp>
+
+#include <getarg.h>
+
+
+
+int
+main(int argc, const char** argv){
+
+ const char* _dbname = "TEST_DB";
+ int _help = 0;
+
+ struct getargs args[] = {
+ { "database", 'd', arg_string, &_dbname, "dbname",
+ "Name of database table is in"},
+ { "usage", '?', arg_flag, &_help, "Print help", "" }
+ };
+
+ int num_args = sizeof(args) / sizeof(args[0]);
+ int optind = 0;
+ char desc[] =
+ "<tabname>+\n"\
+ "This program will create one unique hash index named ind_<tabname> "
+ " for each table. The index will contain all columns in the table";
+
+ if(getarg(args, num_args, argc, argv, &optind) || _help ||
+ argv[optind] == NULL){
+ arg_printusage(args, num_args, argv[0], desc);
+ return NDBT_ProgramExit(NDBT_WRONGARGS);
+ }
+
+
+ Ndb MyNdb(_dbname);
+ if(MyNdb.init() != 0){
+ ERR(MyNdb.getNdbError());
+ return NDBT_ProgramExit(NDBT_FAILED);
+ }
+
+ while(MyNdb.waitUntilReady() != 0)
+ ndbout << "Waiting for ndb to become ready..." << endl;
+
+ NdbDictionary::Dictionary * dict = MyNdb.getDictionary();
+
+ for(int i = optind; i<argc; i++){
+ const NdbDictionary::Table * tab = dict->getTable(argv[i]);
+ if(tab == 0){
+ g_err << "Unknown table: " << argv[i] << endl;
+ continue;
+ }
+
+ if(tab->getNoOfColumns() > 16){
+ g_err << "Table " << argv[i] << " has more than 16 columns" << endl;
+ }
+
+ NdbDictionary::Index ind;
+ char buf[512];
+ sprintf(buf, "IND_%s", argv[i]);
+ ind.setName(buf);
+ ind.setTable(argv[i]);
+ ind.setType(NdbDictionary::Index::UniqueHashIndex);
+ for(int c = 0; c<tab->getNoOfColumns(); c++)
+ ind.addIndexColumn(tab->getColumn(c)->getName());
+
+ ndbout << "creating index " << buf << " on table " << argv[i] << "...";
+ const int res = dict->createIndex(ind);
+ if(res != 0)
+ ndbout << endl << dict->getNdbError() << endl;
+ else
+ ndbout << "OK" << endl;
+ }
+
+ return NDBT_ProgramExit(NDBT_OK);
+}
+
+