~drizzle-trunk/drizzle/development

"Helps in performance tuning in heavily concurrent environments. Sets the maximum number of threads allowed inside InnoDB. Value 0 will disable the thread throttling.");

9438

context("thread-sleep-delay",

9439

po::value<uint32_constraint>(&innodb_thread_sleep_delay)->default_value(10000L),

9440

"Time of innodb thread sleeping before joining InnoDB queue (usec). Value 0 disable a sleep");

9441

context("data-file-path",

9442

po::value<string>(),

9443

"Path to individual files and their sizes.");

9444

context("version",

9445

po::value<string>()->default_value(INNODB_VERSION_STR),

9446

"InnoDB version");

9447

context("use-internal-malloc",

9448

"Use InnoDB's internal memory allocator instal of the OS memory allocator.");

9449

context("disable-native-aio",

9450

_("Do not use Native AIO library for IO, even if available"));

9451

context("change-buffering",

9452

po::value<string>(&innobase_change_buffering),

9453

"Buffer changes to reduce random access: OFF, ON, inserting, deleting, changing, or purging.");

9454

context("read-ahead-threshold",

9455

po::value<read_ahead_threshold_constraint>(&innodb_read_ahead_threshold)->default_value(56),

9456

"Number of pages that must be accessed sequentially for InnoDB to trigger a readahead.");

9457

context("auto-lru-dump",

9458

po::value<uint32_constraint>(&buffer_pool_restore_at_startup)->default_value(0),

9459

"Time in seconds between automatic buffer pool dumps. "

9460

"0 (the default) disables automatic dumps.");

9461

context("ibuf-max-size",

9462

po::value<uint64_constraint>(&ibuf_max_size)->default_value(UINT64_MAX),

9463

"The maximum size of the insert buffer (in bytes).");

9464

context("ibuf-active-contract",

9465

po::value<binary_constraint>(&ibuf_active_contract)->default_value(1),

9466

"Enable/Disable active_contract of insert buffer. 0:disable 1:enable");

9467

context("ibuf-accel-rate",

9468

po::value<ibuf_accel_rate_constraint>(&ibuf_accel_rate)->default_value(100),

9469

"Tunes amount of insert buffer processing of background, in addition to innodb_io_capacity. (in percentage)");

9470

context("checkpoint-age-target",

9471

po::value<uint32_constraint>(&checkpoint_age_target)->default_value(0),

9472

"Control soft limit of checkpoint age. (0 : not control)");

9473

context("flush-neighbor-pages",

9474

po::value<binary_constraint>(&flush_neighbor_pages)->default_value(1),

9475

"Enable/Disable flushing also neighbor pages. 0:disable 1:enable");

9476

context("read-ahead",

9477

po::value<string>(&read_ahead)->default_value("linear"),

9478

"Control read ahead activity (none, random, [linear], both). [from 1.0.5: random read ahead is ignored]");

9479

context("adaptive-flushing-method",

9480

po::value<string>(&adaptive_flushing_method)->default_value("estimate"),

9481

"Choose method of innodb_adaptive_flushing. (native, [estimate], keep_average)");

9482

context("disable-xa",

9483

"Disable InnoDB support for the XA two-phase commit");

9484

context("disable-table-locks",

9485

"Disable InnoDB locking in LOCK TABLES");

9486

context("strict-mode",

9487

po::value<bool>(&strict_mode)->default_value(false)->zero_tokens(),

9488

"Use strict mode when evaluating create options.");

9489

context("replication-log",

9490

po::value<bool>(&innobase_use_replication_log)->default_value(false)->zero_tokens(),

9491

_("Enable internal replication log."));

9492

context("lock-wait-timeout",

9493

po::value<lock_wait_constraint>(&lock_wait_timeout)->default_value(50),

9494

_("Timeout in seconds an InnoDB transaction may wait for a lock before being rolled back. Values above 100000000 disable the timeout."));

9495

context("old-blocks-pct",

9496

po::value<old_blocks_constraint>(&innobase_old_blocks_pct)->default_value(100 * 3 / 8),

9497

_("Percentage of the buffer pool to reserve for 'old' blocks."));

9498

context("old-blocks-time",

9499

po::value<uint32_t>(&buf_LRU_old_threshold_ms)->default_value(0),

9500

_("ove blocks to the 'new' end of the buffer pool if the first access"

9501

" was at least this many milliseconds ago."

9502

" The timeout is disabled if 0 (the default)."));

9503

}

9504

9505

9506

9507

DRIZZLE_DECLARE_PLUGIN

9508

{

9509

DRIZZLE_VERSION_ID,

9510

innobase_engine_name,

9511

INNODB_VERSION_STR,

9512

"Innobase Oy",

9513

"Supports transactions, row-level locking, and foreign keys",

9514

PLUGIN_LICENSE_GPL,

9515

innobase_init, /* Plugin Init */

9516

NULL, /* depends */

9517

init_options /* reserved */

9518

}

9519

DRIZZLE_DECLARE_PLUGIN_END;

9520

9521

int ha_innobase::read_range_first(const key_range *start_key,

9522

const key_range *end_key,

9523

bool eq_range_arg,

9524

bool sorted)

9525

{

9526

int res;

9527

//if (!eq_range_arg)

9528

//in_range_read= TRUE;

9529

res= Cursor::read_range_first(start_key, end_key, eq_range_arg, sorted);

9530

//if (res)

9531

// in_range_read= FALSE;

9532

return res;

9533

}

9534

9535

9536

int ha_innobase::read_range_next()

9537

{

9538

int res= Cursor::read_range_next();

9539

//if (res)

9540

// in_range_read= FALSE;

9541

return res;

9542

}

9543

9544

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

9545

This function checks each index name for a table against reserved

9546

system default primary index name 'GEN_CLUST_INDEX'. If a name matches,

9547

this function pushes an warning message to the client, and returns true. */

9548

UNIV_INTERN

9549

bool

9550

innobase_index_name_is_reserved(

9551

/*============================*/

9552

/* out: true if an index name

9553

matches the reserved name */

9554

const trx_t* trx, /* in: InnoDB transaction handle */

9555

const KeyInfo* key_info, /* in: Indexes to be created */

9556

ulint num_of_keys) /* in: Number of indexes to

9557

be created. */

9558

{

9559

const KeyInfo* key;

9560

uint key_num; /* index number */

9561

9562

for (key_num = 0; key_num < num_of_keys; key_num++) {

9563

key = &key_info[key_num];

9564

9565

if (innobase_strcasecmp(key->name,

9566

innobase_index_reserve_name) == 0) {

9567

/* Push warning to drizzle */

9568

push_warning_printf(trx->mysql_thd,

9569

DRIZZLE_ERROR::WARN_LEVEL_WARN,

9570

ER_WRONG_NAME_FOR_INDEX,

9571

"Cannot Create Index with name "

9572

"'%s'. The name is reserved "

9573

"for the system default primary "

9574

"index.",

9575

innobase_index_reserve_name);

9576

9577

my_error(ER_WRONG_NAME_FOR_INDEX, MYF(0),

9578

innobase_index_reserve_name);

9579

9580

return(true);

9581

}

9582

}

9583

9584

return(false);

9585

}

9586

9587

#ifdef UNIV_COMPILE_TEST_FUNCS

9588

9589

typedef struct innobase_convert_name_test_struct {

9590

char* buf;

9591

ulint buflen;

9592

const char* id;

9593

ulint idlen;

9594

drizzled::Session *session;

9595

ibool file_id;

9596

9597

const char* expected;

9598

} innobase_convert_name_test_t;

9599

9600

void

9601

test_innobase_convert_name()

9602

{

9603

char buf[1024];

9604

ulint i;

9605

9606

innobase_convert_name_test_t test_input[] = {

9607

{buf, sizeof(buf), "abcd", 4, NULL, TRUE, "\"abcd\""},

9608

{buf, 7, "abcd", 4, NULL, TRUE, "\"abcd\""},

9609

{buf, 6, "abcd", 4, NULL, TRUE, "\"abcd\""},

9610

{buf, 5, "abcd", 4, NULL, TRUE, "\"abc\""},

9611

{buf, 4, "abcd", 4, NULL, TRUE, "\"ab\""},

9612

9613

{buf, sizeof(buf), "ab@0060cd", 9, NULL, TRUE, "\"ab`cd\""},

9614

{buf, 9, "ab@0060cd", 9, NULL, TRUE, "\"ab`cd\""},

9615

{buf, 8, "ab@0060cd", 9, NULL, TRUE, "\"ab`cd\""},

9616

{buf, 7, "ab@0060cd", 9, NULL, TRUE, "\"ab`cd\""},

9617

{buf, 6, "ab@0060cd", 9, NULL, TRUE, "\"ab`c\""},

9618

{buf, 5, "ab@0060cd", 9, NULL, TRUE, "\"ab`\""},

9619

{buf, 4, "ab@0060cd", 9, NULL, TRUE, "\"ab\""},

9620

9621

{buf, sizeof(buf), "ab\"cd", 5, NULL, TRUE,

9622

"\"#mysql50#ab\"\"cd\""},

9623

{buf, 17, "ab\"cd", 5, NULL, TRUE,

9624

"\"#mysql50#ab\"\"cd\""},

9625

{buf, 16, "ab\"cd", 5, NULL, TRUE,

9626

"\"#mysql50#ab\"\"c\""},

9627

{buf, 15, "ab\"cd", 5, NULL, TRUE,

9628

"\"#mysql50#ab\"\"\""},

9629

{buf, 14, "ab\"cd", 5, NULL, TRUE,

9630

"\"#mysql50#ab\""},

9631

{buf, 13, "ab\"cd", 5, NULL, TRUE,

9632

"\"#mysql50#ab\""},

9633

{buf, 12, "ab\"cd", 5, NULL, TRUE,

9634

"\"#mysql50#a\""},

9635

{buf, 11, "ab\"cd", 5, NULL, TRUE,

9636

"\"#mysql50#\""},

9637

{buf, 10, "ab\"cd", 5, NULL, TRUE,

9638

"\"#mysql50\""},

9639

9640

{buf, sizeof(buf), "ab/cd", 5, NULL, TRUE, "\"ab\".\"cd\""},

9641

{buf, 9, "ab/cd", 5, NULL, TRUE, "\"ab\".\"cd\""},

9642

{buf, 8, "ab/cd", 5, NULL, TRUE, "\"ab\".\"c\""},

9643

{buf, 7, "ab/cd", 5, NULL, TRUE, "\"ab\".\"\""},

9644

{buf, 6, "ab/cd", 5, NULL, TRUE, "\"ab\"."},

9645

{buf, 5, "ab/cd", 5, NULL, TRUE, "\"ab\"."},

9646

{buf, 4, "ab/cd", 5, NULL, TRUE, "\"ab\""},

9647

{buf, 3, "ab/cd", 5, NULL, TRUE, "\"a\""},

9648

{buf, 2, "ab/cd", 5, NULL, TRUE, "\"\""},

9649

/* XXX probably "" is a better result in this case

9650

{buf, 1, "ab/cd", 5, NULL, TRUE, "."},

9651

9652

{buf, 0, "ab/cd", 5, NULL, TRUE, ""},

9653

};

9654

9655

for (i = 0; i < sizeof(test_input) / sizeof(test_input[0]); i++) {

9656

9657

char* end;

9658

ibool ok = TRUE;

9659

size_t res_len;

9660

9661

fprintf(stderr, "TESTING %lu, %s, %lu, %s\n",

9662

test_input[i].buflen,

9663

test_input[i].id,

9664

test_input[i].idlen,

9665

test_input[i].expected);

9666

9667

end = innobase_convert_name(

9668

test_input[i].buf,

9669

test_input[i].buflen,

9670

test_input[i].id,

9671

test_input[i].idlen,

9672

test_input[i].session,

9673

test_input[i].file_id);

9674

9675

res_len = (size_t) (end - test_input[i].buf);

9676

9677

if (res_len != strlen(test_input[i].expected)) {

9678

9679

fprintf(stderr, "unexpected len of the result: %u, "

9680

"expected: %u\n", (unsigned) res_len,

9681

(unsigned) strlen(test_input[i].expected));

9682

ok = FALSE;

9683

}

9684

9685

if (memcmp(test_input[i].buf,

9686

test_input[i].expected,

9687

strlen(test_input[i].expected)) != 0

9688

|| !ok) {

9689

9690

fprintf(stderr, "unexpected result: %.*s, "

9691

"expected: %s\n", (int) res_len,

9692

test_input[i].buf,

9693

test_input[i].expected);

9694

ok = FALSE;

9695

}

9696

9697

if (ok) {

9698

fprintf(stderr, "OK: res: %.*s\n\n", (int) res_len,

9699

buf);

9700

} else {

9701

fprintf(stderr, "FAILED\n\n");

9702

return;

9703

}

9704

}

9705

}

9706

9707

#endif /* UNIV_COMPILE_TEST_FUNCS */

Older »