← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to client/drizzleimport.cc

Merge Monty

Show diffs side-by-side

added added

removed removed

Lines of Context:
client/drizzleimport.cc
37
37
#include <drizzled/gettext.h>
38
38
 
39
39
using namespace std;
 
40
using namespace drizzled;
40
41
 
41
 
extern "C"
42
 
{
43
 
  bool get_one_option(int optid, const struct my_option *, char *argument);
44
 
  void * worker_thread(void *arg);
45
 
}
 
42
extern "C" void * worker_thread(void *arg);
46
43
 
47
44
int exitcode= 0;
48
45
 
150
147
 
151
148
static void print_version(void)
152
149
{
153
 
  printf("%s  Ver %s Distrib %s, for %s-%s (%s)\n" ,my_progname,
 
150
  printf("%s  Ver %s Distrib %s, for %s-%s (%s)\n" ,internal::my_progname,
154
151
    IMPORT_VERSION, drizzle_version(),HOST_VENDOR,HOST_OS,HOST_CPU);
155
152
}
156
153
 
167
164
read the text file directly. In other cases the client will open the text\n\
168
165
file. The SQL command 'LOAD DATA INFILE' is used to import the rows.\n");
169
166
 
170
 
  printf("\nUsage: %s [OPTIONS] database textfile...",my_progname);
171
 
  print_defaults("drizzle",load_default_groups);
 
167
  printf("\nUsage: %s [OPTIONS] database textfile...",internal::my_progname);
 
168
  internal::print_defaults("drizzle",load_default_groups);
172
169
  my_print_help(my_long_options);
173
170
  my_print_variables(my_long_options);
174
171
}
175
172
 
176
 
bool get_one_option(int optid, const struct my_option *, char *argument)
 
173
static bool get_one_option(int optid, const struct my_option *, char *argument)
177
174
{
178
175
  char *endchar= NULL;
179
176
  uint64_t temp_drizzle_port= 0;
278
275
  drizzle_result_st result;
279
276
  drizzle_return_t ret;
280
277
 
281
 
  fn_format(tablename, filename, "", "", 1 | 2); /* removes path & ext. */
 
278
  internal::fn_format(tablename, filename, "", "", 1 | 2); /* removes path & ext. */
282
279
  if (!opt_local_file)
283
280
    strcpy(hard_path,filename);
284
281
  else
285
 
    my_load_path(hard_path, filename, NULL); /* filename includes the path */
 
282
    internal::my_load_path(hard_path, filename, NULL); /* filename includes the path */
286
283
 
287
284
  if (opt_delete)
288
285
  {
377
374
  query.append("LOCK TABLES ");
378
375
  for (i=0 ; i < tablecount ; i++)
379
376
  {
380
 
    fn_format(tablename, raw_tablename[i], "", "", 1 | 2);
 
377
    internal::fn_format(tablename, raw_tablename[i], "", "", 1 | 2);
381
378
    query.append(tablename);
382
379
    query.append(" WRITE,");
383
380
  }
552
549
  counter--;
553
550
  pthread_cond_signal(&count_threshhold);
554
551
  pthread_mutex_unlock(&counter_mutex);
555
 
  my_thread_end();
 
552
  internal::my_thread_end();
556
553
 
557
554
  return 0;
558
555
}
564
561
  char **argv_to_free;
565
562
  MY_INIT(argv[0]);
566
563
 
567
 
  load_defaults("drizzle",load_default_groups,&argc,&argv);
 
564
  internal::load_defaults("drizzle",load_default_groups,&argc,&argv);
568
565
  /* argv is changed in the program */
569
566
  argv_to_free= argv;
570
567
  if (get_options(&argc, &argv))
571
568
  {
572
 
    free_defaults(argv_to_free);
 
569
    internal::free_defaults(argv_to_free);
573
570
    return(1);
574
571
  }
575
572
 
606
603
        counter--;
607
604
        pthread_mutex_unlock(&counter_mutex);
608
605
        fprintf(stderr,"%s: Could not create thread\n",
609
 
                my_progname);
 
606
                internal::my_progname);
610
607
      }
611
608
    }
612
609
 
634
631
    drizzle_return_t ret;
635
632
    if (!(con= db_connect(current_host,current_db,current_user,opt_password)))
636
633
    {
637
 
      free_defaults(argv_to_free);
 
634
      internal::free_defaults(argv_to_free);
638
635
      return(1);
639
636
    }
640
637
 
659
656
    db_disconnect(current_host, con);
660
657
  }
661
658
  free(opt_password);
662
 
  free_defaults(argv_to_free);
663
 
  my_end();
 
659
  internal::free_defaults(argv_to_free);
 
660
  internal::my_end();
664
661
  return(exitcode);
665
662
}