~drizzle-trunk/drizzle/development

using namespace std;

namespace po=boost::program_options;

 

/* Don't try to make a nice table if the data is too big */

const uint32_t MAX_COLUMN_LENGTH= 1024;

 

 

  if (verbose)

  {

    if (opt_drizzle_port > 0)

    printf("... ");

  }

 

  {

    if (ret == DRIZZLE_RETURN_ERROR_CODE)

    {

              drizzle_result_error(&result));

      drizzle_result_free(&result);

    }

    else

    {

              drizzle_con_error(&con));

    }

    return false;

  drizzle_result_free(&result);

 

  if (verbose)

 

  return true;

}

  if (drizzle_ping(&con, &result, &ret) != NULL && ret == DRIZZLE_RETURN_OK)

  {

    if (opt_silent < 2)

  }

  else

  {

    if (ret == DRIZZLE_RETURN_ERROR_CODE)

    {

              drizzle_result_error(&result));

      drizzle_result_free(&result);

    }

    else

    {

              drizzle_con_error(&con));

    }

    return false;

  opt_connect_timeout= 0;

  if (in_connect_timeout > 3600*12)

  {

    exit(-1);

  }

  opt_connect_timeout= in_connect_timeout;

  opt_max_input_line= 0;

  if (in_max_input_line < 4096 || in_max_input_line > (int64_t)2*1024L*1024L*1024L)

  {

    exit(-1);

  }

  opt_max_input_line= in_max_input_line - (in_max_input_line % 1024);

{

try

{

#if defined(ENABLE_NLS)

# if defined(HAVE_LOCALE_H)

  setlocale(LC_ALL, "");

  textdomain("drizzle");

#endif

 

  commandline_options.add_options()

  ("help,?",N_("Displays this help and exit."))

  ("batch,B",N_("Don't use history file. Disable interactive behavior. (Enables --silent)"))

  N_("Configuration file defaults are not used if no-defaults is set"))

  ;

 

  drizzle_options.add_options()

  ("auto-rehash", po::value<bool>(&opt_rehash)->default_value(true)->zero_tokens(),

  N_("Enable automatic rehashing. One doesn't need to use 'rehash' to get table and field completion, but startup and reconnecting may take a longer time. Disable with --disable-auto-rehash."))

  N_("Automatic limit for rows in a join when using --safe-updates"))

  ;

 

  client_options.add_options()

  ("mysql,m", po::value<bool>(&opt_mysql)->default_value(true)->zero_tokens(),

  N_("Use MySQL Protocol."))

  N_("The protocol of connection (tcp,socket,pipe,memory)."))

  ;

 

  long_options.add(commandline_options).add(drizzle_options).add(client_options);

 

  std::string system_config_dir_drizzle(SYSCONFDIR); 

  {

    opt_silent++;

  }

  

  {

           HOST_VENDOR, HOST_OS, HOST_CPU,

           rl_library_version);

    printf(_("Copyright (C) 2008 Sun Microsystems\n"

           "This software comes with ABSOLUTELY NO WARRANTY. "

           "This is free software,\n"

           "and you are welcome to modify and redistribute it "

           "under the GPL license\n"));

    printf(_("Usage: drizzle [OPTIONS] [database]\n"));

    exit(0);

  }

 

 

  catch(exception &err)

  {

  }

  return(0);        // Keep compiler happy

}

  {

    if (!(PAGER= popen(pager.c_str(), "w")))

    {

      PAGER= stdout;

    }

  }

    end_tee();

  if (!(new_outfile= fopen(file_name, "a")))

  {

    return;

  }

  OUTFILE = new_outfile;

  outfile.assign(file_name);

  opt_outfile= 1;

 

  return;

 

  while ((field = drizzle_column_next(result)))

  {

                "Catalog:    `%s`\n"

                "Database:   `%s`\n"

                "Table:      `%s`\n"

                "Length:     %lu\n"

                "Max_length: %lu\n"

                "Decimals:   %u\n"

                ++i,

                drizzle_column_name(field), drizzle_column_catalog(field),

                drizzle_column_db(field), drizzle_column_table(field),

  {

    if (outfile.empty())

    {

      return 0;

    }

    else if (opt_outfile)

    {

      return 0;

    }

    else

  end[0]= 0;

  if (end == file_name)

  {

    return 0;

  }

  init_tee(file_name);

{

  if (opt_outfile)

    end_tee();

  return 0;

}

 

  {

    if (!default_pager_set)

    {

      opt_nopager=1;

      pager.assign("stdout");

      PAGER= stdout;

    default_pager.assign(pager_name);

  }

  opt_nopager=0;

  return 0;

}

 

  pager.assign("stdout");

  opt_nopager=1;

  PAGER= stdout;

  return 0;

}

 

 

  if (connected)

  {

    put_info(buff,INFO_INFO,0,0);

    put_info(buff,INFO_INFO,0,0);

  }

  return error;

  while (isspace(*line))

    line++;

  if (!(param = strchr(line, ' ')))    // Skip command name

                    INFO_ERROR, 0,0);

  while (isspace(*param))

    param++;

  if (!(sql_file = fopen(source_name, "r")))

  {

    char buff[FN_REFLEN+60];

    return put_info(buff, INFO_ERROR, 0 ,0);

  }

 

  if (line_buff == NULL)

  {

    fclose(sql_file);

  }

 

  /* Save old status */

 

  if (!tmp || !*tmp)

  {

             INFO_ERROR, 0, 0);

    return 0;

  }

  {

    if (strstr(tmp, "\\"))

    {

               INFO_ERROR, 0, 0);

      return 0;

    }

  tmp= get_arg(buff, 0);

  if (!tmp || !*tmp)

  {

    return 0;

  }

  /*

      build_completion_hash(opt_rehash, 1);

  }

 

  return 0;

}

 

com_warnings(string *, const char *)

{

  show_warnings = 1;

  return 0;

}

 

com_nowarnings(string *, const char *)

{

  show_warnings = 0;

  return 0;

}

 

  drizzle_return_t ret;

 

  tee_puts("--------------", stdout);

 

  if (connected)

  {

    /*

      Don't remove "limit 1",

      it is protection againts SQL_SELECT_LIMIT=0

      drizzle_row_t cur=drizzle_row_next(&result);

      if (cur)

      {

      }

      drizzle_result_free(&result);

    }

    else if (ret == DRIZZLE_RETURN_ERROR_CODE)

      drizzle_result_free(&result);

  }

  else

  {

    vidattr(A_BOLD);

    vidattr(A_NORMAL);

    return 0;

  }

  if (skip_updates)

  {

    vidattr(A_BOLD);

    vidattr(A_NORMAL);

  }

/* XXX need to save this from result

  if ((id= drizzleclient_insert_id(&drizzle)))

    tee_fprintf(stdout, "Insert id:\t\t%s\n", internal::llstr(id, buff));

*/

 

  if (drizzle_con_uds(&con))

  else

 

  if (safe_updates)

  {

    vidattr(A_BOLD);

    vidattr(A_NORMAL);

UPDATEs and DELETEs that don't use a key in the WHERE clause are not allowed.\n\

(One can force an UPDATE/DELETE by adding LIMIT # at the end of the command.)\n \

SELECT has an automatic 'LIMIT %lu' if LIMIT is not used.\n             \

                select_limit, max_join_size);

  }

  tee_puts("--------------\n", stdout);

    if (info_type == INFO_ERROR)

    {

      (void) fflush(file);

      if (error)

      {

        if (sqlstate)

      if (error)

      {

        if (sqlstate)

        else

      }

      else

    }

    else

      vidattr(A_BOLD);

    tmp_buff_str << tmp;

 

    if (tmp > 1)

    else

  }

  if (sec >= 60.0)

  {

    tmp=(uint32_t) floor(sec/60.0);

    sec-=60.0*tmp;

  }

  if (part_second)

    tmp_buff_str.precision(2);

  else

    tmp_buff_str.precision(0);

  strcpy(buff, tmp_buff_str.str().c_str());

}

 

        if (!full_username)

          init_username();

        processed_prompt->append(part_username ? part_username :

        break;

      case PROMPT_CHAR:

        {

{

  const char *ptr=strchr(line, ' ');

  if (ptr == NULL)

                default_prompt);

  prompt_counter = 0;

  char * tmpptr= strdup(ptr ? ptr+1 : default_prompt);

  if (tmpptr == NULL)

  else

  {

    current_prompt.erase();

    current_prompt= tmpptr;

  }

  return 0;

}