ndb_basic.test
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:12k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. -- source include/have_ndb.inc
  2. -- source include/not_embedded.inc
  3. --disable_warnings
  4. DROP TABLE IF EXISTS t1,t2,t3,t4,t5,t6,t7;
  5. drop database if exists mysqltest;
  6. --enable_warnings
  7. #
  8. # Basic test to show that the NDB 
  9. # table handler is working
  10. #
  11. #
  12. # Create a normal table with primary key
  13. #
  14. CREATE TABLE t1 (
  15.   pk1 INT NOT NULL PRIMARY KEY,
  16.   attr1 INT NOT NULL,
  17.   attr2 INT,
  18.   attr3 VARCHAR(10)
  19. ) ENGINE=ndbcluster;
  20. SHOW INDEX FROM t1;  
  21. INSERT INTO t1 VALUES (9410,9412, NULL, '9412'), (9411,9413, 17, '9413');
  22. SHOW INDEX FROM t1;  
  23. SELECT pk1 FROM t1 ORDER BY pk1;
  24. SELECT * FROM t1 ORDER BY pk1;
  25. SELECT t1.* FROM t1 ORDER BY pk1;
  26. # Update on record by primary key
  27. UPDATE t1 SET attr1=1 WHERE pk1=9410;
  28. SELECT * FROM t1 ORDER BY pk1;
  29. # Update primary key
  30. UPDATE t1 SET pk1=2 WHERE attr1=1;
  31. SELECT * FROM t1 ORDER BY pk1;
  32. UPDATE t1 SET pk1=pk1 + 1;
  33. SELECT * FROM t1 ORDER BY pk1;
  34. UPDATE t1 SET pk1=4 WHERE pk1 = 3;
  35. SELECT * FROM t1 ORDER BY pk1;
  36. # Delete the record
  37. DELETE FROM t1;
  38. SELECT * FROM t1;
  39. # Insert more records and update them all at once
  40. INSERT INTO t1 VALUES (9410,9412, NULL, '9412'), (9408, 8765, NULL, '8765'),
  41. (7,8, NULL, NULL), (8,9, NULL, NULL), (9,10, NULL, NULL), (10,11, NULL, NULL), (11,12, NULL, NULL), (12,13, NULL, NULL), (13,14, NULL, NULL);
  42. UPDATE t1 SET attr1 = 9999;
  43. SELECT * FROM t1 ORDER BY pk1;
  44. UPDATE t1 SET attr1 = 9998 WHERE pk1 < 1000;
  45. SELECT * FROM t1 ORDER BY pk1;
  46. UPDATE t1 SET attr1 = 9997 WHERE attr1 = 9999;
  47. SELECT * FROM t1 ORDER BY pk1;
  48. # Delete one record by specifying pk
  49. DELETE FROM t1 WHERE pk1 = 9410;
  50. SELECT * FROM t1 ORDER BY pk1;
  51. # Delete all from table
  52. DELETE FROM t1;
  53. SELECT * FROM t1;
  54. # Insert three records with attr1=4 and two with attr1=5
  55. # Delete all with attr1=4
  56. INSERT INTO t1 values (1, 4, NULL, NULL), (2, 4, NULL, NULL), (3, 5, NULL, NULL), (4, 4, NULL, NULL), (5, 5, NULL, NULL);
  57. DELETE FROM t1 WHERE attr1=4;
  58. SELECT * FROM t1 order by pk1;
  59. DELETE FROM t1;
  60. # Insert two records and delete one
  61. INSERT INTO t1 VALUES (9410,9412, NULL, NULL), (9411, 9413, NULL, NULL);
  62. DELETE FROM t1 WHERE pk1 = 9410;
  63. SELECT * FROM t1;
  64. DROP TABLE t1;
  65. #
  66. # Create table without primary key
  67. # a hidden primary key column is created by handler
  68. #
  69. CREATE TABLE t1 (id INT, id2 int) engine=ndbcluster;
  70. INSERT INTO t1 values(3456, 7890);
  71. SELECT * FROM t1;
  72. UPDATE t1 SET id=2 WHERE id2=12;
  73. SELECT * FROM t1;
  74. UPDATE t1 SET id=1234 WHERE id2=7890;
  75. SELECT * FROM t1;
  76. DELETE FROM t1;
  77. INSERT INTO t1 values(3456, 7890), (3456, 7890), (3456, 7890), (3454, 7890);
  78. SELECT * FROM t1 ORDER BY id;
  79. DELETE FROM t1 WHERE id = 3456;
  80. SELECT * FROM t1 ORDER BY id;
  81. DROP TABLE t1;
  82. # test create with the keyword "engine=NDBCLUSTER"
  83. CREATE TABLE t1 (
  84.   pk1 INT NOT NULL PRIMARY KEY,
  85.   attr1 INT NOT NULL
  86. ) ENGINE=NDBCLUSTER;
  87. INSERT INTO t1 values(1, 9999);
  88. DROP TABLE t1;
  89. # test create with the keyword "engine=NDB"
  90. CREATE TABLE t1 (
  91.   pk1 INT NOT NULL PRIMARY KEY,
  92.   attr1 INT NOT NULL
  93. ) ENGINE=NDB;
  94. INSERT INTO t1 values(1, 9999);
  95. DROP TABLE t1;
  96. #
  97. # A more extensive test with a lot more records
  98. #
  99. CREATE TABLE t2 (
  100.   a bigint unsigned NOT NULL PRIMARY KEY,
  101.   b int unsigned not null,
  102.   c int unsigned
  103. ) engine=ndbcluster;
  104. CREATE TABLE t3 (
  105.   a bigint unsigned NOT NULL,
  106.   b bigint unsigned not null,
  107.   c bigint unsigned,
  108.   PRIMARY KEY(a)
  109. ) engine=ndbcluster;
  110. CREATE TABLE t4 (
  111.   a bigint unsigned NOT NULL,
  112.   b bigint unsigned not null,
  113.   c bigint unsigned NOT NULL,
  114.   d int unsigned,
  115.   PRIMARY KEY(a, b, c)
  116. ) engine=ndbcluster;
  117. #
  118. # insert more records into tables
  119. #
  120. let $1=1000;
  121. disable_query_log;
  122. while ($1)
  123. {
  124.  eval insert into t2 values($1, $1+9, 5);
  125.  eval insert into t3 values($1, $1+9, 5);
  126.  eval insert into t4 values($1, $1+9, 5, $1+26000);
  127.  dec $1;
  128. }
  129. enable_query_log;
  130. #
  131. # delete every other record in the tables
  132. #
  133. let $1=1000;
  134. disable_query_log;
  135. while ($1)
  136. {
  137.  eval delete from t2 where a=$1;
  138.  eval delete from t3 where a=$1;
  139.  eval delete from t4 where a=$1 and b=$1+9 and c=5;
  140.  dec $1;
  141.  dec $1;
  142. }
  143. enable_query_log;
  144. select * from t2 where a = 7 order by b;
  145. select * from t2 where a = 7 order by a;
  146. select * from t2 where a = 7 order by 2;
  147. select * from t2 where a = 7 order by c;
  148. select * from t2 where a = 7 and b = 16 order by b;
  149. select * from t2 where a = 7 and b = 16 order by a;
  150. select * from t2 where a = 7 and b = 17 order by a;
  151. select * from t2 where a = 7 and b != 16 order by b;
  152. select * from t2 where a = 7 and b = 16 and c = 5 order by b;
  153. select * from t2 where a = 7 and b = 16 and c = 5 order by a;
  154. select * from t2 where a = 7 and b = 16 and c = 6 order by a;
  155. select * from t2 where a = 7 and b != 16 and c = 5 order by b;
  156. select * from t3 where a = 7 order by b;
  157. select * from t3 where a = 7 order by a;
  158. select * from t3 where a = 7 order by 2;
  159. select * from t3 where a = 7 order by c;
  160. select * from t3 where a = 7 and b = 16 order by b;
  161. select * from t3 where a = 7 and b = 16 order by a;
  162. select * from t3 where a = 7 and b = 17 order by a;
  163. select * from t3 where a = 7 and b != 16 order by b;
  164. select * from t4 where a = 7 order by b;
  165. select * from t4 where a = 7 order by a;
  166. select * from t4 where a = 7 order by 2;
  167. select * from t4 where a = 7 order by c;
  168. select * from t4 where a = 7 and b = 16 order by b;
  169. select * from t4 where a = 7 and b = 16 order by a;
  170. select * from t4 where a = 7 and b = 17 order by a;
  171. select * from t4 where a = 7 and b != 16 order by b;
  172. #
  173. # update records
  174. #
  175. let $1=1000;
  176. disable_query_log;
  177. while ($1)
  178. {
  179.  eval update t2 set c=$1 where a=$1;
  180.  eval update t3 set c=7 where a=$1 and b=$1+9 and c=5;
  181.  eval update t4 set d=$1+21987 where a=$1 and b=$1+9 and c=5;
  182.  dec $1;
  183.  dec $1;
  184. }
  185. enable_query_log;
  186. delete from t2 where a > 5;
  187. select x1.a, x1.b from t2 x1, t2 x2 where x1.b = x2.b order by x1.a;
  188. select a, b FROM t2 outer_table where
  189. a = (select a from t2 where b = outer_table.b ) order by a;
  190. delete from t2;
  191. delete from t3;
  192. delete from t4;
  193. drop table t2;
  194. drop table t3;
  195. drop table t4;
  196. #
  197. # Test delete and update from table with 3 keys
  198. #
  199. CREATE TABLE t5 (
  200.   a bigint unsigned NOT NULL,
  201.   b bigint unsigned not null,
  202.   c bigint unsigned NOT NULL,
  203.   d int unsigned,
  204.   PRIMARY KEY(a, b, c)
  205. ) engine=ndbcluster;
  206. insert into t5 values(10, 19, 5, 26010);
  207. delete from t5 where a=10 and b=19 and c=5;
  208. select * from t5;
  209. insert into t5 values(10, 19, 5, 26010);
  210. update t5 set d=21997 where a=10 and b=19 and c=5;
  211. select * from t5;
  212. delete from t5;
  213. drop table t5;
  214. #
  215. # Test using table with a char(255) column first in table
  216. #
  217. CREATE TABLE t6 (
  218.   adress char(255),
  219.   a int NOT NULL PRIMARY KEY,
  220.   b int
  221. ) engine = NDB;
  222. insert into t6 values
  223.  ("Nice road 3456", 1, 23),
  224.  ("Street Road 78", 3, 92),
  225.  ("Road street 89C", 5, 71),
  226.  (NULL, 7, NULL);
  227. select * from t6 order by a;
  228. select a, b from t6 order by a;
  229. update t6 set adress="End of road 09" where a=3;
  230. update t6 set b=181, adress="Street 76" where a=7;
  231. select * from t6 order by a;
  232. select * from t6 where a=1;
  233. delete from t6 where a=1;
  234. select * from t6 order by a;
  235. delete from t6 where b=71;
  236. select * from t6 order by a;
  237. drop table t6;
  238. #
  239. # Test using table with a char(255) column first in table and a 
  240. # primary key consisting of two columns
  241. #
  242. CREATE TABLE t7 (
  243.   adress char(255),
  244.   a int NOT NULL,
  245.   b int,
  246.   c int NOT NULL,
  247.   PRIMARY KEY(a, c)
  248. ) engine = NDB;
  249. insert into t7 values
  250.  ("Highway 3456", 1, 23, 2),
  251.  ("Street Road 78", 3, 92, 3),
  252.  ("Main street 89C", 5, 71, 4),
  253.  (NULL, 8, NULL, 12);
  254. select * from t7 order by a;
  255. select a, b from t7 order by a;
  256. update t7 set adress="End of road 09" where a=3;
  257. update t7 set adress="Gatuvägen 90C" where a=5 and c=4;
  258. update t7 set adress="No adress" where adress is NULL;
  259. select * from t7 order by a;
  260. select * from t7 where a=1 and c=2;
  261. delete from t7 where a=1;
  262. delete from t7 where a=3 and c=3;
  263. delete from t7 where a=5 and c=4;
  264. select * from t7;
  265. delete from t7 where b=23;
  266. select * from t7;
  267. drop table t7;
  268. #
  269. # Test multiple databases in one statement
  270. #
  271. CREATE TABLE t1 (
  272.   pk1 INT NOT NULL PRIMARY KEY,
  273.   attr1 INT NOT NULL,
  274.   attr2 INT,
  275.   attr3 VARCHAR(10)
  276. ) ENGINE=ndbcluster;
  277. INSERT INTO t1 VALUES (9410,9412, NULL, '9412'), (9411,9413, 17, '9413');
  278. create database mysqltest;
  279. use mysqltest;
  280. CREATE TABLE t2 (
  281.   a bigint unsigned NOT NULL PRIMARY KEY,
  282.   b int unsigned not null,
  283.   c int unsigned
  284. ) engine=ndbcluster;
  285. insert into t2 select pk1,attr1,attr2 from test.t1;
  286. select * from t2 order by a;
  287. select b from test.t1, t2 where c = test.t1.attr2;
  288. select b,test.t1.attr1 from test.t1, t2 where test.t1.pk1 < a;
  289.  
  290. drop table test.t1, t2;
  291. drop database mysqltest;
  292. #
  293. # BUG#6031 - DROP DATABASE doesn't drop database on first try
  294. #
  295. --disable_warnings
  296. drop database if exists ndbtest1;
  297. --enable_warnings
  298. create database ndbtest1;
  299. use ndbtest1;
  300. create table t1(id int) engine=ndbcluster;
  301. drop database ndbtest1;
  302. --error 1008
  303. drop database ndbtest1;
  304. #
  305. # test support of char(0)
  306. #
  307. use test;
  308. create table t1 (a int primary key, b char(0));
  309. insert into t1 values (1,"");
  310. insert into t1 values (2,NULL);
  311. select * from t1 order by a;
  312. select * from t1 order by b;
  313. select * from t1 where b IS NULL;
  314. select * from t1 where b IS NOT NULL;
  315. drop table t1;
  316. #
  317. # test the limit of no of attributes in one table
  318. #
  319. create table t1 (
  320. c1 int,
  321. c2 int,
  322. c3 int,
  323. c4 int,
  324. c5 int,
  325. c6 int,
  326. c7 int,
  327. c8 int,
  328. c9 int,
  329. c10 int,
  330. c11 int,
  331. c12 int,
  332. c13 int,
  333. c14 int,
  334. c15 int,
  335. c16 int,
  336. c17 int,
  337. c18 int,
  338. c19 int,
  339. c20 int,
  340. c21 int,
  341. c22 int,
  342. c23 int,
  343. c24 int,
  344. c25 int,
  345. c26 int,
  346. c27 int,
  347. c28 int,
  348. c29 int,
  349. c30 int,
  350. c31 int,
  351. c32 int,
  352. c33 int,
  353. c34 int,
  354. c35 int,
  355. c36 int,
  356. c37 int,
  357. c38 int,
  358. c39 int,
  359. c40 int,
  360. c41 int,
  361. c42 int,
  362. c43 int,
  363. c44 int,
  364. c45 int,
  365. c46 int,
  366. c47 int,
  367. c48 int,
  368. c49 int,
  369. c50 int,
  370. c51 int,
  371. c52 int,
  372. c53 int,
  373. c54 int,
  374. c55 int,
  375. c56 int,
  376. c57 int,
  377. c58 int,
  378. c59 int,
  379. c60 int,
  380. c61 int,
  381. c62 int,
  382. c63 int,
  383. c64 int,
  384. c65 int,
  385. c66 int,
  386. c67 int,
  387. c68 int,
  388. c69 int,
  389. c70 int,
  390. c71 int,
  391. c72 int,
  392. c73 int,
  393. c74 int,
  394. c75 int,
  395. c76 int,
  396. c77 int,
  397. c78 int,
  398. c79 int,
  399. c80 int,
  400. c81 int,
  401. c82 int,
  402. c83 int,
  403. c84 int,
  404. c85 int,
  405. c86 int,
  406. c87 int,
  407. c88 int,
  408. c89 int,
  409. c90 int,
  410. c91 int,
  411. c92 int,
  412. c93 int,
  413. c94 int,
  414. c95 int,
  415. c96 int,
  416. c97 int,
  417. c98 int,
  418. c99 int,
  419. c100 int,
  420. c101 int,
  421. c102 int,
  422. c103 int,
  423. c104 int,
  424. c105 int,
  425. c106 int,
  426. c107 int,
  427. c108 int,
  428. c109 int,
  429. c110 int,
  430. c111 int,
  431. c112 int,
  432. c113 int,
  433. c114 int,
  434. c115 int,
  435. c116 int,
  436. c117 int,
  437. c118 int,
  438. c119 int,
  439. c120 int,
  440. c121 int,
  441. c122 int,
  442. c123 int,
  443. c124 int,
  444. c125 int,
  445. c126 int,
  446. c127 int,
  447. c128 int,
  448. primary key(c1)) engine=ndb;
  449. drop table t1;
  450. #
  451. # test max size of attribute name and truncation
  452. #
  453. create table t1 (
  454. a1234567890123456789012345678901234567890 int primary key,
  455. a12345678901234567890123456789a1234567890 int,
  456. index(a12345678901234567890123456789a1234567890)
  457. ) engine=ndb;
  458. show tables;
  459. insert into t1 values (1,1),(2,1),(3,1),(4,1),(5,2),(6,1),(7,1);
  460. explain select * from t1 where a12345678901234567890123456789a1234567890=2;
  461. select * from t1 where a12345678901234567890123456789a1234567890=2;
  462. drop table t1;
  463. #
  464. # test fragment creation
  465. #
  466. # first a table with _many_ fragments per node group
  467. # then a table with just one fragment per node group
  468. #
  469. create table t1
  470.   (a bigint, b bigint, c bigint, d bigint, 
  471.    primary key (a,b,c,d)) 
  472.   engine=ndb
  473.   max_rows=200000000;
  474. insert into t1 values
  475.   (1,2,3,4),(2,3,4,5),(3,4,5,6),
  476.   (3,2,3,4),(1,3,4,5),(2,4,5,6),
  477.   (1,2,3,5),(2,3,4,8),(3,4,5,9),
  478.   (3,2,3,5),(1,3,4,8),(2,4,5,9),
  479.   (1,2,3,6),(2,3,4,6),(3,4,5,7),
  480.   (3,2,3,6),(1,3,4,6),(2,4,5,7),
  481.   (1,2,3,7),(2,3,4,7),(3,4,5,8),
  482.   (3,2,3,7),(1,3,4,7),(2,4,5,8),
  483.   (1,3,3,4),(2,4,4,5),(3,5,5,6),
  484.   (3,3,3,4),(1,4,4,5),(2,5,5,6),
  485.   (1,3,3,5),(2,4,4,8),(3,5,5,9),
  486.   (3,3,3,5),(1,4,4,8),(2,5,5,9),
  487.   (1,3,3,6),(2,4,4,6),(3,5,5,7),
  488.   (3,3,3,6),(1,4,4,6),(2,5,5,7),
  489.   (1,3,3,7),(2,4,4,7),(3,5,5,8),
  490.   (3,3,3,7),(1,4,4,7),(2,5,5,8);
  491. select count(*) from t1;
  492. drop table t1;
  493. create table t1
  494.   (a bigint, b bigint, c bigint, d bigint, 
  495.    primary key (a)) 
  496.   engine=ndb
  497.   max_rows=1;
  498. drop table t1;
  499. #
  500. # Test auto_increment
  501. #
  502. connect (con1,localhost,,,test);
  503. connect (con2,localhost,,,test);
  504. create table t1
  505. (counter int(64) NOT NULL auto_increment,
  506.  datavalue char(40) default 'XXXX',
  507.  primary key (counter)
  508. ) ENGINE=ndbcluster;
  509. connection con1;
  510. insert into t1 (datavalue) values ('newval');
  511. insert into t1 (datavalue) values ('newval');
  512. select * from t1 order by counter;
  513. insert into t1 (datavalue) select datavalue from t1 where counter < 100;
  514. insert into t1 (datavalue) select datavalue from t1 where counter < 100;
  515. select * from t1 order by counter;
  516. connection con2;
  517. insert into t1 (datavalue) select datavalue from t1 where counter < 100;
  518. insert into t1 (datavalue) select datavalue from t1 where counter < 100;
  519. select * from t1 order by counter;
  520. drop table t1;
  521. #
  522. # BUG#14514 Creating table with packed key fails silently
  523. #
  524. CREATE TABLE t1 ( b INT ) PACK_KEYS = 0 ENGINE = ndb;
  525. select * from t1;
  526. drop table t1;
  527. # End of 4.1 tests