~drizzle-trunk/drizzle/development

_("Enable named commands. Named commands mean this program's internal commands; see drizzle> help . When enabled, the named commands can be used from any line of the query, otherwise only from the first line, before an enter."))

1296

N_("Enable named commands. Named commands mean this program's internal commands; see drizzle> help . When enabled, the named commands can be used from any line of the query, otherwise only from the first line, before an enter."))

1345

1297

("no-beep,b", po::value<bool>(&opt_nobeep)->default_value(false)->zero_tokens(),

1346

_("Turn off beep on error."))

1347

("disable-line-numbers", _("Do not write line numbers for errors."))

1348

("disable-column-names", _("Do not write column names in results."))

1298

N_("Turn off beep on error."))

1299

("disable-line-numbers", N_("Do not write line numbers for errors."))

1300

("disable-column-names", N_("Do not write column names in results."))

1349

1301

("skip-column-names,N",

1350

_("Don't write column names in results. WARNING: -N is deprecated, use long version of this options instead."))

1302

N_("Don't write column names in results. WARNING: -N is deprecated, use long version of this options instead."))

1351

1303

("set-variable,O", po::value<string>(),

1352

_("Change the value of a variable. Please note that this option is deprecated; you can set variables directly with --variable-name=value."))

1304

N_("Change the value of a variable. Please note that this option is deprecated; you can set variables directly with --variable-name=value."))

1353

1305

("table,t", po::value<bool>(&output_tables)->default_value(false)->zero_tokens(),

1354

_("Output in table format."))

1306

N_("Output in table format."))

1355

1307

("safe-updates,U", po::value<bool>(&safe_updates)->default_value(false)->zero_tokens(),

1356

_("Only allow UPDATE and DELETE that uses keys."))

1308

N_("Only allow UPDATE and DELETE that uses keys."))

1357

1309

("i-am-a-dummy,U", po::value<bool>(&safe_updates)->default_value(false)->zero_tokens(),

1358

_("Synonym for option --safe-updates, -U."))

1310

N_("Synonym for option --safe-updates, -U."))

1359

1311

("verbose,v", po::value<string>(&opt_verbose)->default_value(""),

1360

_("-v vvv implies that verbose= 3, Used to specify verbose"))

1361

("version,V", _("Output version information and exit."))

1312

N_("-v vvv implies that verbose= 3, Used to specify verbose"))

1313

("version,V", N_("Output version information and exit."))

1362

1314

("secure-auth", po::value<bool>(&opt_secure_auth)->default_value(false)->zero_tokens(),

1363

_("Refuse client connecting to server if it uses old (pre-4.1.1) protocol"))

1315

N_("Refuse client connecting to server if it uses old (pre-4.1.1) protocol"))

1364

1316

("show-warnings", po::value<bool>(&show_warnings)->default_value(false)->zero_tokens(),

1365

_("Show warnings after every statement."))

1317

N_("Show warnings after every statement."))

1366

1318

("show-progress-size", po::value<uint32_t>(&show_progress_size)->default_value(0),

1367

_("Number of lines before each import progress report."))

1319

N_("Number of lines before each import progress report."))

1368

1320

("ping", po::value<bool>(&opt_ping)->default_value(false)->zero_tokens(),

1369

_("Ping the server to check if it's alive."))

1321

N_("Ping the server to check if it's alive."))

1370

1322

("no-defaults", po::value<bool>()->default_value(false)->zero_tokens(),

1371

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

1323

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

1372

1324

;

1373

1325

1374

po::options_description drizzle_options(_("Options specific to the drizzle client"));

1326

po::options_description drizzle_options(N_("Options specific to the drizzle client"));

1375

1327

drizzle_options.add_options()

1376

1328

("disable-auto-rehash,A",

1377

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

1329

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

1378

1330

("auto-vertical-output", po::value<bool>(&auto_vertical_output)->default_value(false)->zero_tokens(),

1379

_("Automatically switch to vertical output mode if the result is wider than the terminal width."))

1331

N_("Automatically switch to vertical output mode if the result is wider than the terminal width."))

1380

1332

("database,D", po::value<string>(&current_db)->default_value(""),

1381

_("Database to use."))

1333

N_("Database to use."))

1382

1334

("default-character-set",po::value<string>(),

1383

_("(not used)"))

1335

N_("(not used)"))

1384

1336

("delimiter", po::value<string>(&delimiter_str)->default_value(";"),

1385

_("Delimiter to be used."))

1337

N_("Delimiter to be used."))

1386

1338

("execute,e", po::value<string>(),

1387

_("Execute command and quit. (Disables --force and history file)"))

1339

N_("Execute command and quit. (Disables --force and history file)"))

1388

1340

("local-infile", po::value<bool>(&opt_local_infile)->default_value(false)->zero_tokens(),

1389

_("Enable LOAD DATA LOCAL INFILE."))

1341

N_("Enable LOAD DATA LOCAL INFILE."))

1390

1342

("unbuffered,n", po::value<bool>(&unbuffered)->default_value(false)->zero_tokens(),

1391

_("Flush buffer after each query."))

1343

N_("Flush buffer after each query."))

1392

1344

("sigint-ignore", po::value<bool>(&opt_sigint_ignore)->default_value(false)->zero_tokens(),

1393

_("Ignore SIGINT (CTRL-C)"))

1345

N_("Ignore SIGINT (CTRL-C)"))

1394

1346

("one-database,o", po::value<bool>(&one_database)->default_value(false)->zero_tokens(),

1395

_("Only update the default database. This is useful for skipping updates to other database in the update log."))

1347

N_("Only update the default database. This is useful for skipping updates to other database in the update log."))

1396

1348

("pager", po::value<string>(),

1397

_("Pager to use to display results. If you don't supply an option the default pager is taken from your ENV variable PAGER. Valid pagers are less, more, cat [> filename], etc. See interactive help (\\h) also. This option does not work in batch mode. Disable with --disable-pager. This option is disabled by default."))

1349

N_("Pager to use to display results. If you don't supply an option the default pager is taken from your ENV variable PAGER. Valid pagers are less, more, cat [> filename], etc. See interactive help (\\h) also. This option does not work in batch mode. Disable with --disable-pager. This option is disabled by default."))

1398

1350

("disable-pager", po::value<bool>(&opt_nopager)->default_value(false)->zero_tokens(),

1399

_("Disable pager and print to stdout. See interactive help (\\h) also."))

1351

N_("Disable pager and print to stdout. See interactive help (\\h) also."))

1400

1352

("prompt", po::value<string>(&current_prompt)->default_value(""),

1401

_("Set the drizzle prompt to this value."))

1353

N_("Set the drizzle prompt to this value."))

1402

1354

("quick,q", po::value<bool>(&quick)->default_value(false)->zero_tokens(),

1403

_("Don't cache result, print it row by row. This may slow down the server if the output is suspended. Doesn't use history file."))

1355

N_("Don't cache result, print it row by row. This may slow down the server if the output is suspended. Doesn't use history file."))

1404

1356

("raw,r", po::value<bool>(&opt_raw_data)->default_value(false)->zero_tokens(),

1405

_("Write fields without conversion. Used with --batch."))

1406

("disable-reconnect", _("Do not reconnect if the connection is lost."))

1357

N_("Write fields without conversion. Used with --batch."))

1358

("disable-reconnect", N_("Do not reconnect if the connection is lost."))

1407

1359

("shutdown", po::value<bool>()->zero_tokens(),

1408

_("Shutdown the server"))

1409

("silent,s", _("Be more silent. Print results with a tab as separator, each row on new line."))

1360

N_("Shutdown the server"))

1361

("silent,s", N_("Be more silent. Print results with a tab as separator, each row on new line."))

1410

1362

("tee", po::value<string>(),

1411

_("Append everything into outfile. See interactive help (\\h) also. Does not work in batch mode. Disable with --disable-tee. This option is disabled by default."))

1363

N_("Append everything into outfile. See interactive help (\\h) also. Does not work in batch mode. Disable with --disable-tee. This option is disabled by default."))

1412

1364

("disable-tee", po::value<bool>()->default_value(false)->zero_tokens(),

1413

_("Disable outfile. See interactive help (\\h) also."))

1414

("connect-timeout", po::value<uint32_t>(&opt_connect_timeout)->default_value(0)->notifier(&check_timeout_value),

1415

_("Number of seconds before connection timeout."))

1416

("max-input-line", po::value<uint32_t>(&opt_max_input_line)->default_value(16*1024L*1024L)->notifier(&check_max_input_line),

1417

_("Max length of input line"))

1418

("select-limit", po::value<uint32_t>(&select_limit)->default_value(1000L),

1419

_("Automatic limit for SELECT when using --safe-updates"))

1420

("max-join-size", po::value<uint32_t>(&max_join_size)->default_value(1000000L),

1421

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

1365

N_("Disable outfile. See interactive help (\\h) also."))

1366

("connect_timeout", po::value<uint32_t>(&opt_connect_timeout)->default_value(0)->notifier(&check_timeout_value),

1367

N_("Number of seconds before connection timeout."))

1368

("max_input_line", po::value<uint32_t>(&opt_max_input_line)->default_value(16*1024L*1024L)->notifier(&check_max_input_line),

1369

N_("Max length of input line"))

1370

("select_limit", po::value<uint32_t>(&select_limit)->default_value(1000L),

1371

N_("Automatic limit for SELECT when using --safe-updates"))

1372

("max_join_size", po::value<uint32_t>(&max_join_size)->default_value(1000000L),

1373

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

1422

1374

;

1423

1375

1424

po::options_description client_options(_("Options specific to the client"));

1376

po::options_description client_options(N_("Options specific to the client"));

1425

1377

client_options.add_options()

1426

1378

("host,h", po::value<string>(&current_host)->default_value("localhost"),

1427

_("Connect to host"))

1379

N_("Connect to host"))

1428

1380

("password,P", po::value<string>(&current_password)->default_value(PASSWORD_SENTINEL),

1429

_("Password to use when connecting to server. If password is not given it's asked from the tty."))

1381

N_("Password to use when connecting to server. If password is not given it's asked from the tty."))

1430

1382

("port,p", po::value<uint32_t>()->default_value(0),

1431

_("Port number to use for connection or 0 for default to, in order of preference, drizzle.cnf, $DRIZZLE_TCP_PORT, built-in default"))

1432

#ifdef DRIZZLE_ADMIN_TOOL

1433

("user,u", po::value<string>(&current_user)->default_value("root"),

1434

#else

1383

N_("Port number to use for connection or 0 for default to, in order of preference, drizzle.cnf, $DRIZZLE_TCP_PORT, built-in default"))

1435

1384

("user,u", po::value<string>(&current_user)->default_value(""),

1436

#endif

1437

_("User for login if not current user."))

1385

N_("User for login if not current user."))

1438

1386

("protocol",po::value<string>(&opt_protocol)->default_value("mysql"),

1439

_("The protocol of connection (mysql or drizzle)."))

1387

N_("The protocol of connection (mysql or drizzle)."))

1440

1388

;

1441

1389

1442

po::options_description long_options(_("Allowed Options"));

1390

po::options_description long_options(N_("Allowed Options"));

1443

1391

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

1444

1392

1445

1393

std::string system_config_dir_drizzle(SYSCONFDIR);

1449

1397

system_config_dir_client.append("/drizzle/client.cnf");

1450

1398

1451

1399

std::string user_config_dir((getenv("XDG_CONFIG_HOME")? getenv("XDG_CONFIG_HOME"):"~/.config"));

1452

1453

if (user_config_dir.compare(0, 2, "~/") == 0)

1454

{

1455

char *homedir;

1456

homedir= getenv("HOME");

1457

if (homedir != NULL)

1458

user_config_dir.replace(0, 1, homedir);

1459

}

1460

1400

1461

1401

po::variables_map vm;

1462

1402

1463

1403

po::positional_options_description p;

1493

1433

1494

1434

po::notify(vm);

1495

1435

1496

#ifdef DRIZZLE_ADMIN_TOOL

1497

default_prompt= strdup(getenv("DRIZZLE_PS1") ?

1498

getenv("DRIZZLE_PS1") :

1499

"drizzleadmin> ");

1500

#else

1501

1436

default_prompt= strdup(getenv("DRIZZLE_PS1") ?

1502

1437

getenv("DRIZZLE_PS1") :

1503

1438

"drizzle> ");

1504

#endif

1505

1439

if (default_prompt == NULL)

1506

1440

{

1507

1441

fprintf(stderr, _("Memory allocation error while constructing initial "

1508

1442

"prompt. Aborting.\n"));

1509

1443

exit(ENOMEM);

1510

1444

}

1511

1512

if (current_prompt.empty())

1513

current_prompt= strdup(default_prompt);

1514

1445

current_prompt= strdup(default_prompt);

1515

1446

if (current_prompt.empty())

1516

1447

{

1517

1448

fprintf(stderr, _("Memory allocation error while constructing initial "

1536

1467

if (! isatty(0) || ! isatty(1))

1537

1468

{

1538

1469

status.setBatch(1); opt_silent=1;

1470

ignore_errors=0;

1539

1471

}

1540

1472

else

1541

1473

status.setAddToHistory(1);

1712

1644

}

1713

1645

if (vm.count("silent"))

1714

1646

{

1715

opt_silent= 2;

1647

opt_silent++;

1716

1648

}

1717

1649

1718

1650

if (vm.count("help") || vm.count("version"))

1728

1660

"This is free software,\n"

1729

1661

"and you are welcome to modify and redistribute it "

1730

1662

"under the GPL license\n"));

1731

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

1663

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

1732

1664

cout << long_options;

1733

1665

exit(0);

1734

1666

}

1740

1672

}

1741

1673

1742

1674

memset(&drizzle, 0, sizeof(drizzle));

1743

if (sql_connect(current_host, current_db, current_user, opt_password))

1675

if (sql_connect(current_host, current_db, current_user, opt_password,opt_silent))

1744

1676

{

1745

1677

quick= 1; // Avoid history

1746

1678

status.setExitStatus(1);

1893

1825

void handle_sigint(int sig)

1894

1826

{

1895

1827

char kill_buffer[40];

1896

boost::scoped_ptr<drizzle_con_st> kill_drizzle(new drizzle_con_st);

1828

drizzle_con_st kill_drizzle;

1897

1829

drizzle_result_st res;

1898

1830

drizzle_return_t ret;

1899

1831

1902

1834

goto err;

1903

1835

}

1904

1836

1905

if (drizzle_con_add_tcp(&drizzle, kill_drizzle.get(), current_host.c_str(),

1837

if (drizzle_con_add_tcp(&drizzle, &kill_drizzle, current_host.c_str(),

1906

1838

opt_drizzle_port, current_user.c_str(), opt_password.c_str(), NULL,

1907

1839

use_drizzle_protocol ? DRIZZLE_CON_EXPERIMENTAL : DRIZZLE_CON_MYSQL) == NULL)

1908

1840

{

1913

1845

sprintf(kill_buffer, "KILL /*!50000 QUERY */ %u",

1914

1846

drizzle_con_thread_id(&con));

1915

1847

1916

if (drizzle_query_str(kill_drizzle.get(), &res, kill_buffer, &ret) != NULL)

1848

if (drizzle_query_str(&kill_drizzle, &res, kill_buffer, &ret) != NULL)

1917

1849

drizzle_result_free(&res);

1918

1850

1919

drizzle_con_free(kill_drizzle.get());

1851

drizzle_con_free(&kill_drizzle);

1920

1852

tee_fprintf(stdout, _("Query aborted by Ctrl+C\n"));

1921

1853

1922

1854

interrupted_query= 1;

2387

2319

{

2388

2320

*out++='\n';

2389

2321

uint32_t length=(uint32_t) (out-line);

2390

if ((buffer->length() + length) > opt_max_input_line)

2391

{

2392

status.setExitStatus(1);

2393

put_info(_("Not found a delimiter within max_input_line of input"), INFO_ERROR, 0, 0);

2394

return 1;

2395

}

2396

2322

if ((!*ml_comment || preserve_comments))

2397

2323

buffer->append(line, length);

2398

2324

}

2582

2508

drizzle_return_t ret;

2583

2509

drizzle_result_st databases,tables,fields;

2584

2510

drizzle_row_t database_row,table_row;

2511

drizzle_column_st *sql_field;

2585

2512

string tmp_str, tmp_str_lower;

2586

std::string query;

2587

2513

2588

2514

if (status.getBatch() || quick || current_db.empty())

2589

2515

return; // We don't need completion in batches

2603

2529

/* hash Drizzle functions (to be implemented) */

2604

2530

2605

2531

/* hash all database names */

2606

if (drizzle_query_str(&con, &databases, "select schema_name from information_schema.schemata", &ret) != NULL)

2532

if (drizzle_query_str(&con, &databases, "show databases", &ret) != NULL)

2607

2533

{

2608

2534

if (ret == DRIZZLE_RETURN_OK)

2609

2535

{

2623

2549

drizzle_result_free(&databases);

2624

2550

}

2625

2551

2626

query= "select table_name, column_name from information_schema.columns where table_schema='";

2627

query.append(current_db);

2628

query.append("' order by table_name");

2629

2630

if (drizzle_query(&con, &fields, query.c_str(), query.length(),

2631

&ret) != NULL)

2552

/* hash all table names */

2553

if (drizzle_query_str(&con, &tables, "show tables", &ret) != NULL)

2632

2554

{

2633

if (ret == DRIZZLE_RETURN_OK &&

2634

drizzle_result_buffer(&fields) == DRIZZLE_RETURN_OK)

2555

if (ret != DRIZZLE_RETURN_OK)

2556

{

2557

drizzle_result_free(&tables);

2558

return;

2559

}

2560

2561

if (drizzle_result_buffer(&tables) != DRIZZLE_RETURN_OK)

2562

put_info(drizzle_error(&drizzle),INFO_INFO,0,0);

2563

else

2635

2564

{

2636

2565

if (drizzle_result_row_count(&tables) > 0 && !opt_silent && write_info)

2637

2566

{

2641

2570

"You can turn off this feature to get a quicker "

2642

2571

"startup with -A\n\n"));

2643

2572

}

2644

2645

std::string table_name;

2646

while ((table_row=drizzle_row_next(&fields)))

2573

while ((table_row=drizzle_row_next(&tables)))

2647

2574

{

2648

if (table_name.compare(table_row[0]) != 0)

2649

{

2650

tmp_str= table_row[0];

2651

tmp_str_lower= lower_string(tmp_str);

2652

completion_map[tmp_str_lower]= tmp_str;

2653

table_name= table_row[0];

2654

}

2655

2575

tmp_str= table_row[0];

2656

tmp_str.append(".");

2657

tmp_str.append(table_row[1]);

2658

tmp_str_lower= lower_string(tmp_str);

2659

completion_map[tmp_str_lower]= tmp_str;

2660

2661

tmp_str= table_row[1];

2662

tmp_str_lower= lower_string(tmp_str);

2663

completion_map[tmp_str_lower]= tmp_str;

2664

}

2665

}

2666

}

2667

drizzle_result_free(&fields);

2576

tmp_str_lower= lower_string(tmp_str);

2577

completion_map[tmp_str_lower]= tmp_str;

2578

}

2579

}

2580

}

2581

else

2582

return;

2583

2584

/* hash all field names, both with the table prefix and without it */

2585

if (drizzle_result_row_count(&tables) == 0)

2586

{

2587

drizzle_result_free(&tables);

2588

return;

2589

}

2590

2591

drizzle_row_seek(&tables, 0);

2592

2593

while ((table_row=drizzle_row_next(&tables)))

2594

{

2595

string query;

2596

2597

query.append("show fields in '");

2598

query.append(table_row[0]);

2599

query.append("'");

2600

2601

if (drizzle_query(&con, &fields, query.c_str(), query.length(),

2602

&ret) != NULL)

2603

{

2604

if (ret == DRIZZLE_RETURN_OK &&

2605

drizzle_result_buffer(&fields) == DRIZZLE_RETURN_OK)

2606

{

2607

while ((sql_field=drizzle_column_next(&fields)))

2608

{

2609

tmp_str=table_row[0];

2610

tmp_str.append(".");

2611

tmp_str.append(drizzle_column_name(sql_field));

2612

tmp_str_lower= lower_string(tmp_str);

2613

completion_map[tmp_str_lower]= tmp_str;

2614

2615

tmp_str=drizzle_column_name(sql_field);

2616

tmp_str_lower= lower_string(tmp_str);

2617

completion_map[tmp_str_lower]= tmp_str;

2618

}

2619

}

2620

drizzle_result_free(&fields);

2621

}

2622

}

2623

drizzle_result_free(&tables);

2668

2624

completion_iter= completion_map.begin();

2669

2625

}

2670

2626

2809

2765

com_go(string *buffer, const char *)

2810

2766

{

2811

2767

char buff[200]; /* about 110 chars used so far */

2768

char time_buff[52+3+1]; /* time max + space&parens + NUL */

2812

2769

drizzle_result_st result;

2813

2770

drizzle_return_t ret;

2814

uint32_t warnings= 0;

2815

boost::posix_time::ptime timer;

2771

uint32_t timer, warnings= 0;

2816

2772

uint32_t error= 0;

2817

2773

uint32_t error_code= 0;

2818

2774

int err= 0;

2881

2837

goto end;

2882

2838

}

2883

2839

2884

string time_buff("");

2885

2840

if (verbose >= 3 || !opt_silent)

2886

2841

drizzle_end_timer(timer,time_buff);

2842

else

2843

time_buff[0]= '\0';

2887

2844

2888

2845

/* Every branch must truncate buff . */

2889

2846

if (drizzle_result_column_count(&result) > 0)

2934

2891

if (warnings != 1)

2935

2892

*pos++= 's';

2936

2893

}

2937

strcpy(pos, time_buff.c_str());

2894

strcpy(pos, time_buff);

2938

2895

put_info(buff,INFO_RESULT,0,0);

2939

2896

if (strcmp(drizzle_result_info(&result), ""))

2940

2897

put_info(drizzle_result_info(&result),INFO_RESULT,0,0);

3100

3057

{

3101

3058

tee_fprintf(PAGER, _("Field %3u: `%s`\n"

3102

3059

"Catalog: `%s`\n"

3103

"Schema: `%s`\n"

3060

"Database: `%s`\n"

3104

3061

"Table: `%s`\n"

3105

3062

"Org_table: `%s`\n"

3106

3063

"Type: UTF-8\n"

3739

3696

}

3740

3697

else

3741

3698

opt_rehash= 0;

3742

error=sql_connect(current_host, current_db, current_user, opt_password);

3699

error=sql_connect(current_host, current_db, current_user, opt_password,0);

3743

3700

opt_rehash= save_rehash;

3744

3701

3745

3702

if (connected)

3746

3703

{

3747

3704

sprintf(buff, _("Connection id: %u"), drizzle_con_thread_id(&con));

3748

3705

put_info(buff,INFO_INFO,0,0);

3749

sprintf(buff, _("Current schema: %.128s\n"),

3706

sprintf(buff, _("Current database: %.128s\n"),

3750

3707

!current_db.empty() ? current_db.c_str() : _("*** NONE ***"));

3751

3708

put_info(buff,INFO_INFO,0,0);

3752

3709

}

3859

3816

tmp= get_arg(buff, 0);

3860

3817

if (!tmp || !*tmp)

3861

3818

{

3862

put_info(_("USE must be followed by a schema name"), INFO_ERROR, 0, 0);

3819

put_info(_("USE must be followed by a database name"), INFO_ERROR, 0, 0);

3863

3820

return 0;

3864

3821

}

3865

3822

3927

3884

build_completion_hash(opt_rehash, 1);

3928

3885

}

3929

3886

3930

put_info(_("Schema changed"),INFO_INFO, 0, 0);

3887

put_info(_("Database changed"),INFO_INFO, 0, 0);

3931

3888

return 0;

3932

3889

}

3933

3890

3934

static int com_shutdown(string *, const char *)

3935

{

3936

drizzle_result_st result;

3937

drizzle_return_t ret;

3938

3939

if (verbose)

3940

{

3941

printf(_("shutting down drizzled"));

3942

if (opt_drizzle_port > 0)

3943

printf(_(" on port %d"), opt_drizzle_port);

3944

printf("... ");

3945

}

3946

3947

if (drizzle_shutdown(&con, &result, DRIZZLE_SHUTDOWN_DEFAULT,

3948

&ret) == NULL || ret != DRIZZLE_RETURN_OK)

3949

{

3950

if (ret == DRIZZLE_RETURN_ERROR_CODE)

3951

{

3952

fprintf(stderr, _("shutdown failed; error: '%s'"),

3953

drizzle_result_error(&result));

3954

drizzle_result_free(&result);

3955

}

3956

else

3957

{

3958

fprintf(stderr, _("shutdown failed; error: '%s'"),

3959

drizzle_con_error(&con));

3960

}

3961

return false;

3962

}

3963

3964

drizzle_result_free(&result);

3965

3966

if (verbose)

3967

printf(_("done\n"));

3968

3969

return false;

3970

}

3971

3972

3891

static int

3973

3892

com_warnings(string *, const char *)

3974

3893

{

4048

3967

4049

3968

4050

3969

static int

4051

sql_connect(const string &host, const string &database, const string &user, const string &password)

3970

sql_connect(const string &host, const string &database, const string &user, const string &password,

3971

uint32_t silent)

4052

3972

{

4053

3973

drizzle_return_t ret;

4054

3974

if (connected)

4058

3978

drizzle_free(&drizzle);

4059

3979

}

4060

3980

drizzle_create(&drizzle);

4061

4062

#ifdef DRIZZLE_ADMIN_TOOL

4063

drizzle_con_options_t options= (drizzle_con_options_t) (DRIZZLE_CON_ADMIN | (use_drizzle_protocol ? DRIZZLE_CON_EXPERIMENTAL : DRIZZLE_CON_MYSQL));

4064

#else

4065

drizzle_con_options_t options= (drizzle_con_options_t) (use_drizzle_protocol ? DRIZZLE_CON_EXPERIMENTAL : DRIZZLE_CON_MYSQL);

4066

#endif

4067

4068

3981

if (drizzle_con_add_tcp(&drizzle, &con, (char *)host.c_str(),

4069

3982

opt_drizzle_port, (char *)user.c_str(),

4070

3983

(char *)password.c_str(), (char *)database.c_str(),

4071

options) == NULL)

3984

use_drizzle_protocol ? DRIZZLE_CON_EXPERIMENTAL : DRIZZLE_CON_MYSQL) == NULL)

4072

3985

{

4073

3986

(void) put_error(&con, NULL);

4074

3987

(void) fflush(stdout);

4097

4010

4098

4011

if ((ret= drizzle_con_connect(&con)) != DRIZZLE_RETURN_OK)

4099

4012

{

4100

4101

if (opt_silent < 2)

4013

if (!silent || (ret != DRIZZLE_RETURN_GETADDRINFO &&

4014

ret != DRIZZLE_RETURN_COULD_NOT_CONNECT))

4102

4015

{

4103

4016

(void) put_error(&con, NULL);

4104

4017

(void) fflush(stdout);

4143

4056

drizzle_row_t cur=drizzle_row_next(&result);

4144

4057

if (cur)

4145

4058

{

4146

tee_fprintf(stdout, _("Current schema:\t%s\n"), cur[0] ? cur[0] : "");

4059

tee_fprintf(stdout, _("Current database:\t%s\n"), cur[0] ? cur[0] : "");

4147

4060

tee_fprintf(stdout, _("Current user:\t\t%s\n"), cur[1]);

4148

4061

}

4149

4062

drizzle_result_free(&result);

4162

4075

if (skip_updates)

4163

4076

{

4164

4077

vidattr(A_BOLD);

4165

tee_fprintf(stdout, _("\nAll updates ignored to this schema\n"));

4078

tee_fprintf(stdout, _("\nAll updates ignored to this database\n"));

4166

4079

vidattr(A_NORMAL);

4167

4080

}

4168

4081

tee_fprintf(stdout, _("Current pager:\t\t%s\n"), pager.c_str());

4388

4301

}

4389

4302

4390

4303

#include <sys/times.h>

4304

#ifdef _SC_CLK_TCK // For mit-pthreads

4305

#undef CLOCKS_PER_SEC

4306

#define CLOCKS_PER_SEC (sysconf(_SC_CLK_TCK))

4307

#endif

4391

4308

4392

static boost::posix_time::ptime start_timer(void)

4309

static uint32_t start_timer(void)

4393

4310

{

4394

return boost::posix_time::microsec_clock::universal_time();

4311

struct tms tms_tmp;

4312

return times(&tms_tmp);

4395

4313

}

4396

4314

4397

static void nice_time(boost::posix_time::time_duration duration, string &buff)

4315

4316

/**

4317

Write as many as 52+1 bytes to buff, in the form of a legible

4318

duration of time.

4319

4320

len("4294967296 days, 23 hours, 59 minutes, 60.00 seconds") -> 52

4321

4322

static void nice_time(double sec,char *buff,bool part_second)

4398

4323

{

4324

uint32_t tmp;

4399

4325

ostringstream tmp_buff_str;

4400

4326

4401

if (duration.hours() > 0)

4402

{

4403

tmp_buff_str << duration.hours();

4404

if (duration.hours() > 1)

4327

if (sec >= 3600.0*24)

4328

{

4329

tmp=(uint32_t) floor(sec/(3600.0*24));

4330

sec-= 3600.0*24*tmp;

4331

tmp_buff_str << tmp;

4332

4333

if (tmp > 1)

4334

tmp_buff_str << " days ";

4335

else

4336

tmp_buff_str << " day ";

4337

4338

}

4339

if (sec >= 3600.0)

4340

{

4341

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

4342

sec-=3600.0*tmp;

4343

tmp_buff_str << tmp;

4344

4345

if (tmp > 1)

4405

4346

tmp_buff_str << _(" hours ");

4406

4347

else

4407

4348

tmp_buff_str << _(" hour ");

4408

4349

}

4409

if (duration.hours() > 0 || duration.minutes() > 0)

4350

if (sec >= 60.0)

4410

4351

{

4411

tmp_buff_str << duration.minutes() << _(" min ");

4352

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

4353

sec-=60.0*tmp;

4354

tmp_buff_str << tmp << _(" min ");

4412

4355

}

4413

4414

tmp_buff_str.precision(duration.num_fractional_digits());

4415

4416

double seconds= duration.fractional_seconds();

4417

4418

seconds/= pow(10.0,duration.num_fractional_digits());

4419

4420

seconds+= duration.seconds();

4421

tmp_buff_str << seconds << _(" sec");

4422

4423

buff.append(tmp_buff_str.str());

4424

}

4425

4426

static void end_timer(boost::posix_time::ptime start_time, string &buff)

4427

{

4428

boost::posix_time::ptime end_time= start_timer();

4429

boost::posix_time::time_period duration(start_time, end_time);

4430

4431

nice_time(duration.length(), buff);

4432

}

4433

4434

4435

static void drizzle_end_timer(boost::posix_time::ptime start_time, string &buff)

4436

{

4437

buff.append(" (");

4438

end_timer(start_time,buff);

4439

buff.append(")");

4356

if (part_second)

4357

tmp_buff_str.precision(2);

4358

else

4359

tmp_buff_str.precision(0);

4360

tmp_buff_str << sec << _(" sec");

4361

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

4362

}

4363

4364

4365

static void end_timer(uint32_t start_time,char *buff)

4366

{

4367

nice_time((double) (start_timer() - start_time) /

4368

CLOCKS_PER_SEC,buff,1);

4369

}

4370

4371

4372

static void drizzle_end_timer(uint32_t start_time,char *buff)

4373

{

4374

buff[0]=' ';

4375

buff[1]='(';

4376

end_timer(start_time,buff+2);

4377

strcpy(strchr(buff, '\0'),")");

4440

4378

}

4441

4379

4442

4380

static const char * construct_prompt()

4575

4513

add_int_to_prompt(t->tm_sec);

4576

4514

break;

4577

4515

case 'w':

4578

processed_prompt->append(get_day_name(t->tm_wday));

4516

processed_prompt->append(day_names[t->tm_wday]);

4579

4517

break;

4580

4518

case 'P':

4581

4519

processed_prompt->append(t->tm_hour < 12 ? "am" : "pm");

4584

4522

add_int_to_prompt(t->tm_mon+1);

4585

4523

break;

4586

4524

case 'O':

4587

processed_prompt->append(get_month_name(t->tm_mon));

4525

processed_prompt->append(month_names[t->tm_mon]);

4588

4526

break;

4589

4527

case '\'':

4590

4528

processed_prompt->append("'");

Older »