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

9233

context("thread-sleep-delay",

9234

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

9235

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

9236

context("data-file-path",

9237

po::value<string>(),

9238

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

9239

context("version",

9240

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

9241

"InnoDB version");

9242

context("use-internal-malloc",

9243

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

9244

context("disable-native-aio",

9245

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

9246

context("change-buffering",

9247

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

9248

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

9249

context("read-ahead-threshold",

9250

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

9251

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

9252

context("disable-xa",

9253

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

9254

context("disable-table-locks",

9255

"Disable InnoDB locking in LOCK TABLES");

9256

context("strict-mode",

9257

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

9258

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

9259

context("replication-log",

9260

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

9261

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

9262

context("lock-wait-timeout",

9263

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

9264

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

9265

context("old-blocks-pct",

9266

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

9267

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

9268

context("old-blocks-time",

9269

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

9270

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

9271

" was at least this many milliseconds ago."

9272

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

9273

}

9274

9275

9276

9277

DRIZZLE_DECLARE_PLUGIN

9278

{

9279

DRIZZLE_VERSION_ID,

9280

innobase_engine_name,

9281

INNODB_VERSION_STR,

9282

"Innobase Oy",

9283

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

9284

PLUGIN_LICENSE_GPL,

9285

innobase_init, /* Plugin Init */

9286

NULL, /* depends */

9287

init_options /* reserved */

9288

}

9289

DRIZZLE_DECLARE_PLUGIN_END;

9290

9291

int ha_innobase::read_range_first(const key_range *start_key,

9292

const key_range *end_key,

9293

bool eq_range_arg,

9294

bool sorted)

9295

{

9296

int res;

9297

//if (!eq_range_arg)

9298

//in_range_read= TRUE;

9299

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

9300

//if (res)

9301

// in_range_read= FALSE;

9302

return res;

9303

}

9304

9305

9306

int ha_innobase::read_range_next()

9307

{

9308

int res= Cursor::read_range_next();

9309

//if (res)

9310

// in_range_read= FALSE;

9311

return res;

9312

}

9313

9314

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

9315

This function checks each index name for a table against reserved

9316

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

9317

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

9318

UNIV_INTERN

9319

bool

9320

innobase_index_name_is_reserved(

9321

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

9322

/* out: true if an index name

9323

matches the reserved name */

9324

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

9325

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

9326

ulint num_of_keys) /* in: Number of indexes to

9327

be created. */

9328

{

9329

const KeyInfo* key;

9330

uint key_num; /* index number */

9331

9332

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

9333

key = &key_info[key_num];

9334

9335

if (innobase_strcasecmp(key->name,

9336

innobase_index_reserve_name) == 0) {

9337

/* Push warning to drizzle */

9338

push_warning_printf(trx->mysql_thd,

9339

DRIZZLE_ERROR::WARN_LEVEL_WARN,

9340

ER_WRONG_NAME_FOR_INDEX,

9341

"Cannot Create Index with name "

9342

"'%s'. The name is reserved "

9343

"for the system default primary "

9344

"index.",

9345

innobase_index_reserve_name);

9346

9347

my_error(ER_WRONG_NAME_FOR_INDEX, MYF(0),

9348

innobase_index_reserve_name);

9349

9350

return(true);

9351

}

9352

}

9353

9354

return(false);

9355

}

9356

9357

#ifdef UNIV_COMPILE_TEST_FUNCS

9358

9359

typedef struct innobase_convert_name_test_struct {

9360

char* buf;

9361

ulint buflen;

9362

const char* id;

9363

ulint idlen;

9364

drizzled::Session *session;

9365

ibool file_id;

9366

9367

const char* expected;

9368

} innobase_convert_name_test_t;

9369

9370

void

9371

test_innobase_convert_name()

9372

{

9373

char buf[1024];

9374

ulint i;

9375

9376

innobase_convert_name_test_t test_input[] = {

9377

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

9378

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

9379

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

9380

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

9381

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

9382

9383

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

9384

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

9385

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

9386

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

9387

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

9388

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

9389

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

9390

9391

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

9392

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

9393

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

9394

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

9395

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

9396

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

9397

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

9398

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

9399

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

9400

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

9401

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

9402

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

9403

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

9404

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

9405

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

9406

"\"#mysql50#\""},

9407

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

9408

"\"#mysql50\""},

9409

9410

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

9411

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

9412

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

9413

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

9414

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

9415

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

9416

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

9417

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

9418

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

9419

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

9420

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

9421

9422

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

9423

};

9424

9425

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

9426

9427

char* end;

9428

ibool ok = TRUE;

9429

size_t res_len;

9430

9431

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

9432

test_input[i].buflen,

9433

test_input[i].id,

9434

test_input[i].idlen,

9435

test_input[i].expected);

9436

9437

end = innobase_convert_name(

9438

test_input[i].buf,

9439

test_input[i].buflen,

9440

test_input[i].id,

9441

test_input[i].idlen,

9442

test_input[i].session,

9443

test_input[i].file_id);

9444

9445

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

9446

9447

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

9448

9449

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

9450

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

9451

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

9452

ok = FALSE;

9453

}

9454

9455

if (memcmp(test_input[i].buf,

9456

test_input[i].expected,

9457

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

9458

|| !ok) {

9459

9460

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

9461

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

9462

test_input[i].buf,

9463

test_input[i].expected);

9464

ok = FALSE;

9465

}

9466

9467

if (ok) {

9468

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

9469

buf);

9470

} else {

9471

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

9472

return;

9473

}

9474

}

9475

}

9476

9477

#endif /* UNIV_COMPILE_TEST_FUNCS */

Older »