~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."))

1297

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

1298

("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."))

1299

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

1300

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

1301

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

1349

1302

("skip-column-names,N",

1350

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

1303

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

1351

1304

("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."))

1305

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

1353

1306

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

1354

_("Output in table format."))

1307

N_("Output in table format."))

1355

1308

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

1356

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

1309

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

1357

1310

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

1358

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

1311

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

1359

1312

("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."))

1313

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

1314

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

1362

1315

("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"))

1316

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

1364

1317

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

1365

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

1318

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

1366

1319

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

1367

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

1320

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

1368

1321

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

1369

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

1322

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

1370

1323

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

1371

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

1324

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

1372

1325

;

1373

1326

1374

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

1327

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

1375

1328

drizzle_options.add_options()

1376

("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

("disable-auto-rehash",

1330

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

1331

("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."))

1332

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

1380

1333

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

1381

_("Database to use."))

1334

N_("Database to use."))

1382

1335

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

1383

_("(not used)"))

1336

N_("(not used)"))

1384

1337

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

1385

_("Delimiter to be used."))

1338

N_("Delimiter to be used."))

1386

1339

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

1387

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

1340

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

1388

1341

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

1389

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

1342

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

1390

1343

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

1391

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

1344

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

1392

1345

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

1393

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

1346

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

1394

1347

("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."))

1348

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

1396

1349

("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."))

1350

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

1351

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

1399

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

1352

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

1400

1353

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

1401

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

1354

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

1402

1355

("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."))

1356

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

1357

("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."))

1407

("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."))

1358

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

1359

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

1360

("shutdown", po::value<bool>(&opt_shutdown)->default_value(false)->zero_tokens(),

1361

N_("Shutdown the server"))

1362

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

1410

1363

("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."))

1364

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

1365

("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"))

1366

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

1367

("wait,w", N_("Wait and retry if connection is down."))

1368

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

1369

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

1370

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

1371

N_("Max length of input line"))

1372

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

1373

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

1374

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

1375

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

1422

1376

;

1423

1377

1424

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

1378

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

1425

1379

client_options.add_options()

1426

1380

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

1427

_("Connect to host"))

1381

N_("Connect to host"))

1428

1382

("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."))

1383

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

1430

1384

("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

1385

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

1386

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

1436

#endif

1437

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

1387

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

1438

1388

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

1439

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

1389

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

1440

1390

;

1441

1391

1442

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

1392

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

1443

1393

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

1444

1394

1445

1395

std::string system_config_dir_drizzle(SYSCONFDIR);

1449

1399

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

1450

1400

1451

1401

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

1402

1461

1403

po::variables_map vm;

1462

1404

1463

1405

po::positional_options_description p;

1479

1421

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

1480

1422

1481

1423

ifstream user_drizzle_ifs(user_config_dir_drizzle.c_str());

1482

po::store(dpo::parse_config_file(user_drizzle_ifs, drizzle_options), vm);

1424

po::store(parse_config_file(user_drizzle_ifs, drizzle_options), vm);

1483

1425

1484

1426

ifstream user_client_ifs(user_config_dir_client.c_str());

1485

po::store(dpo::parse_config_file(user_client_ifs, client_options), vm);

1427

po::store(parse_config_file(user_client_ifs, client_options), vm);

1486

1428

1487

1429

ifstream system_drizzle_ifs(system_config_dir_drizzle.c_str());

1488

store(dpo::parse_config_file(system_drizzle_ifs, drizzle_options), vm);

1430

store(parse_config_file(system_drizzle_ifs, drizzle_options), vm);

1489

1431

1490

1432

ifstream system_client_ifs(system_config_dir_client.c_str());

1491

po::store(dpo::parse_config_file(system_client_ifs, client_options), vm);

1433

po::store(parse_config_file(system_client_ifs, client_options), vm);

1492

1434

}

1493

1435

1494

1436

po::notify(vm);

1495

1437

1496

#ifdef DRIZZLE_ADMIN_TOOL

1497

default_prompt= strdup(getenv("DRIZZLE_PS1") ?

1498

getenv("DRIZZLE_PS1") :

1499

"drizzleadmin> ");

1500

#else

1501

1438

default_prompt= strdup(getenv("DRIZZLE_PS1") ?

1502

1439

getenv("DRIZZLE_PS1") :

1503

1440

"drizzle> ");

1504

#endif

1505

1441

if (default_prompt == NULL)

1506

1442

{

1507

1443

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

1508

1444

"prompt. Aborting.\n"));

1509

1445

exit(ENOMEM);

1510

1446

}

1511

1512

if (current_prompt.empty())

1513

current_prompt= strdup(default_prompt);

1514

1447

current_prompt= strdup(default_prompt);

1515

1448

if (current_prompt.empty())

1516

1449

{

1517

1450

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

1536

1469

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

1537

1470

{

1538

1471

status.setBatch(1); opt_silent=1;

1472

ignore_errors=0;

1539

1473

}

1540

1474

else

1541

1475

status.setAddToHistory(1);

1562

1496

opt_rehash= (vm.count("disable-auto-rehash")) ? false : true;

1563

1497

opt_reconnect= (vm.count("disable-reconnect")) ? false : true;

1564

1498

1565

/* Don't rehash with --shutdown */

1566

if (vm.count("shutdown"))

1567

{

1568

opt_rehash= false;

1569

opt_shutdown= true;

1570

}

1571

1572

1499

if (vm.count("delimiter"))

1573

1500

{

1574

1501

/* Check that delimiter does not contain a backslash */

1712

1639

}

1713

1640

if (vm.count("silent"))

1714

1641

{

1715

opt_silent= 2;

1642

opt_silent++;

1716

1643

}

1717

1644

1718

1645

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

1728

1655

"This is free software,\n"

1729

1656

"and you are welcome to modify and redistribute it "

1730

1657

"under the GPL license\n"));

1731

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

1658

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

1732

1659

cout << long_options;

1733

1660

exit(0);

1734

1661

}

1740

1667

}

1741

1668

1742

1669

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

1743

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

1670

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

1744

1671

{

1745

1672

quick= 1; // Avoid history

1746

1673

status.setExitStatus(1);

1868

1795

1869

1796

if (sig >= 0)

1870

1797

put_info(sig ? _("Aborted") : _("Bye"), INFO_RESULT,0,0);

1871

delete glob_buffer;

1872

delete processed_prompt;

1798

if (glob_buffer)

1799

delete glob_buffer;

1800

if (processed_prompt)

1801

delete processed_prompt;

1873

1802

opt_password.erase();

1874

1803

free(histfile);

1875

1804

free(histfile_tmp);

1893

1822

void handle_sigint(int sig)

1894

1823

{

1895

1824

char kill_buffer[40];

1896

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

1825

drizzle_con_st kill_drizzle;

1897

1826

drizzle_result_st res;

1898

1827

drizzle_return_t ret;

1899

1828

1902

1831

goto err;

1903

1832

}

1904

1833

1905

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

1834

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

1906

1835

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

1907

1836

use_drizzle_protocol ? DRIZZLE_CON_EXPERIMENTAL : DRIZZLE_CON_MYSQL) == NULL)

1908

1837

{

1913

1842

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

1914

1843

drizzle_con_thread_id(&con));

1915

1844

1916

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

1845

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

1917

1846

drizzle_result_free(&res);

1918

1847

1919

drizzle_con_free(kill_drizzle.get());

1848

drizzle_con_free(&kill_drizzle);

1920

1849

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

1921

1850

1922

1851

interrupted_query= 1;

2387

2316

{

2388

2317

*out++='\n';

2389

2318

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

2319

if ((!*ml_comment || preserve_comments))

2397

2320

buffer->append(line, length);

2398

2321

}

2582

2505

drizzle_return_t ret;

2583

2506

drizzle_result_st databases,tables,fields;

2584

2507

drizzle_row_t database_row,table_row;

2508

drizzle_column_st *sql_field;

2585

2509

string tmp_str, tmp_str_lower;

2586

std::string query;

2587

2510

2588

2511

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

2589

2512

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

2603

2526

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

2604

2527

2605

2528

/* hash all database names */

2606

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

2529

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

2607

2530

{

2608

2531

if (ret == DRIZZLE_RETURN_OK)

2609

2532

{

2623

2546

drizzle_result_free(&databases);

2624

2547

}

2625

2548

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)

2549

/* hash all table names */

2550

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

2632

2551

{

2633

if (ret == DRIZZLE_RETURN_OK &&

2634

drizzle_result_buffer(&fields) == DRIZZLE_RETURN_OK)

2552

if (ret != DRIZZLE_RETURN_OK)

2553

{

2554

drizzle_result_free(&tables);

2555

return;

2556

}

2557

2558

if (drizzle_result_buffer(&tables) != DRIZZLE_RETURN_OK)

2559

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

2560

else

2635

2561

{

2636

2562

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

2637

2563

{

2641

2567

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

2642

2568

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

2643

2569

}

2644

2645

std::string table_name;

2646

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

2570

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

2647

2571

{

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

2572

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);

2573

tmp_str_lower= lower_string(tmp_str);

2574

completion_map[tmp_str_lower]= tmp_str;

2575

}

2576

}

2577

}

2578

else

2579

return;

2580

2581

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

2582

if (drizzle_result_row_count(&tables) == 0)

2583

{

2584

drizzle_result_free(&tables);

2585

return;

2586

}

2587

2588

drizzle_row_seek(&tables, 0);

2589

2590

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

2591

{

2592

string query;

2593

2594

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

2595

query.append(table_row[0]);

2596

query.append("'");

2597

2598

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

2599

&ret) != NULL)

2600

{

2601

if (ret == DRIZZLE_RETURN_OK &&

2602

drizzle_result_buffer(&fields) == DRIZZLE_RETURN_OK)

2603

{

2604

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

2605

{

2606

tmp_str=table_row[0];

2607

tmp_str.append(".");

2608

tmp_str.append(drizzle_column_name(sql_field));

2609

tmp_str_lower= lower_string(tmp_str);

2610

completion_map[tmp_str_lower]= tmp_str;

2611

2612

tmp_str=drizzle_column_name(sql_field);

2613

tmp_str_lower= lower_string(tmp_str);

2614

completion_map[tmp_str_lower]= tmp_str;

2615

}

2616

}

2617

drizzle_result_free(&fields);

2618

}

2619

}

2620

drizzle_result_free(&tables);

2668

2621

completion_iter= completion_map.begin();

2669

2622

}

2670

2623

2710

2663

The different commands

2711

2664

***************************************************************************/

2712

2665

2713

int drizzleclient_real_query_for_lazy(const char *buf, size_t length,

2666

int drizzleclient_real_query_for_lazy(const char *buf, int length,

2714

2667

drizzle_result_st *result,

2715

2668

uint32_t *error_code)

2716

2669

{

2809

2762

com_go(string *buffer, const char *)

2810

2763

{

2811

2764

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

2765

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

2812

2766

drizzle_result_st result;

2813

2767

drizzle_return_t ret;

2814

uint32_t warnings= 0;

2815

boost::posix_time::ptime timer;

2768

uint32_t timer, warnings= 0;

2816

2769

uint32_t error= 0;

2817

2770

uint32_t error_code= 0;

2818

2771

int err= 0;

2881

2834

goto end;

2882

2835

}

2883

2836

2884

string time_buff("");

2885

2837

if (verbose >= 3 || !opt_silent)

2886

2838

drizzle_end_timer(timer,time_buff);

2839

else

2840

time_buff[0]= '\0';

2887

2841

2888

2842

/* Every branch must truncate buff . */

2889

2843

if (drizzle_result_column_count(&result) > 0)

2934

2888

if (warnings != 1)

2935

2889

*pos++= 's';

2936

2890

}

2937

strcpy(pos, time_buff.c_str());

2891

strcpy(pos, time_buff);

2938

2892

put_info(buff,INFO_RESULT,0,0);

2939

2893

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

2940

2894

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

3100

3054

{

3101

3055

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

3102

3056

"Catalog: `%s`\n"

3103

"Schema: `%s`\n"

3057

"Database: `%s`\n"

3104

3058

"Table: `%s`\n"

3105

3059

"Org_table: `%s`\n"

3106

3060

"Type: UTF-8\n"

3626

3580

/* Skip the spaces between the command and the argument */

3627

3581

while (param && isspace(*param))

3628

3582

param++;

3629

if (!param || (*param == '\0')) // if pager was not given, use the default

3583

if (!param || !strlen(param)) // if pager was not given, use the default

3630

3584

{

3631

3585

if (!default_pager_set)

3632

3586

{

3739

3693

}

3740

3694

else

3741

3695

opt_rehash= 0;

3742

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

3696

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

3743

3697

opt_rehash= save_rehash;

3744

3698

3745

3699

if (connected)

3746

3700

{

3747

3701

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

3748

3702

put_info(buff,INFO_INFO,0,0);

3749

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

3703

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

3750

3704

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

3751

3705

put_info(buff,INFO_INFO,0,0);

3752

3706

}

3859

3813

tmp= get_arg(buff, 0);

3860

3814

if (!tmp || !*tmp)

3861

3815

{

3862

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

3816

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

3863

3817

return 0;

3864

3818

}

3865

3819

3927

3881

build_completion_hash(opt_rehash, 1);

3928

3882

}

3929

3883

3930

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

3884

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

3931

3885

return 0;

3932

3886

}

3933

3887

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

3888

static int

3973

3889

com_warnings(string *, const char *)

3974

3890

{

4048

3964

4049

3965

4050

3966

static int

4051

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

3967

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

3968

uint32_t silent)

4052

3969

{

4053

3970

drizzle_return_t ret;

4054

3971

if (connected)

4058

3975

drizzle_free(&drizzle);

4059

3976

}

4060

3977

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

3978

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

4069

3979

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

4070

3980

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

4071

options) == NULL)

3981

use_drizzle_protocol ? DRIZZLE_CON_EXPERIMENTAL : DRIZZLE_CON_MYSQL) == NULL)

4072

3982

{

4073

3983

(void) put_error(&con, NULL);

4074

3984

(void) fflush(stdout);

4097

4007

4098

4008

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

4099

4009

{

4100

4101

if (opt_silent < 2)

4010

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

4011

ret != DRIZZLE_RETURN_COULD_NOT_CONNECT))

4102

4012

{

4103

4013

(void) put_error(&con, NULL);

4104

4014

(void) fflush(stdout);

4143

4053

drizzle_row_t cur=drizzle_row_next(&result);

4144

4054

if (cur)

4145

4055

{

4146

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

4056

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

4147

4057

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

4148

4058

}

4149

4059

drizzle_result_free(&result);

4162

4072

if (skip_updates)

4163

4073

{

4164

4074

vidattr(A_BOLD);

4165

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

4075

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

4166

4076

vidattr(A_NORMAL);

4167

4077

}

4168

4078

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

4388

4298

}

4389

4299

4390

4300

#include <sys/times.h>

4301

#ifdef _SC_CLK_TCK // For mit-pthreads

4302

#undef CLOCKS_PER_SEC

4303

#define CLOCKS_PER_SEC (sysconf(_SC_CLK_TCK))

4304

#endif

4391

4305

4392

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

4306

static uint32_t start_timer(void)

4393

4307

{

4394

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

4308

struct tms tms_tmp;

4309

return times(&tms_tmp);

4395

4310

}

4396

4311

4397

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

4312

4313

/**

4314

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

4315

duration of time.

4316

4317

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

4318

4319

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

4398

4320

{

4321

uint32_t tmp;

4399

4322

ostringstream tmp_buff_str;

4400

4323

4401

if (duration.hours() > 0)

4402

{

4403

tmp_buff_str << duration.hours();

4404

if (duration.hours() > 1)

4324

if (sec >= 3600.0*24)

4325

{

4326

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

4327

sec-= 3600.0*24*tmp;

4328

tmp_buff_str << tmp;

4329

4330

if (tmp > 1)

4331

tmp_buff_str << " days ";

4332

else

4333

tmp_buff_str << " day ";

4334

4335

}

4336

if (sec >= 3600.0)

4337

{

4338

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

4339

sec-=3600.0*tmp;

4340

tmp_buff_str << tmp;

4341

4342

if (tmp > 1)

4405

4343

tmp_buff_str << _(" hours ");

4406

4344

else

4407

4345

tmp_buff_str << _(" hour ");

4408

4346

}

4409

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

4347

if (sec >= 60.0)

4410

4348

{

4411

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

4349

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

4350

sec-=60.0*tmp;

4351

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

4412

4352

}

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(")");

4353

if (part_second)

4354

tmp_buff_str.precision(2);

4355

else

4356

tmp_buff_str.precision(0);

4357

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

4358

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

4359

}

4360

4361

4362

static void end_timer(uint32_t start_time,char *buff)

4363

{

4364

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

4365

CLOCKS_PER_SEC,buff,1);

4366

}

4367

4368

4369

static void drizzle_end_timer(uint32_t start_time,char *buff)

4370

{

4371

buff[0]=' ';

4372

buff[1]='(';

4373

end_timer(start_time,buff+2);

4374

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

4440

4375

}

4441

4376

4442

4377

static const char * construct_prompt()

4575

4510

add_int_to_prompt(t->tm_sec);

4576

4511

break;

4577

4512

case 'w':

4578

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

4513

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

4579

4514

break;

4580

4515

case 'P':

4581

4516

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

4584

4519

add_int_to_prompt(t->tm_mon+1);

4585

4520

break;

4586

4521

case 'O':

4587

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

4522

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

4588

4523

break;

4589

4524

case '\'':

4590

4525

processed_prompt->append("'");

Older »