ndb_transaction.test 5.84 KB
Newer Older
1
-- source include/have_ndb.inc
2
-- source include/have_binlog_format_row.inc
3
-- source include/not_embedded.inc
4 5 6

--disable_warnings
DROP TABLE IF EXISTS t1,t2,t3,t4,t5,t6,t7;
7
drop database if exists mysqltest;
8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258
--enable_warnings

#
# Transactionc test to show that the NDB 
# table handler is working properly with
# transactions
#

#
# Create a normal table with primary key
#
CREATE TABLE t1 (
  pk1 INT NOT NULL PRIMARY KEY,
  attr1 INT NOT NULL
) ENGINE=ndbcluster;
	
# insert
begin;
insert into t1 values(1,1);
insert into t1 values(2,2);
select count(*) from t1;
select * from t1 where pk1 = 1;
select t1.attr1 from t1, t1 as t1x where t1.pk1 = t1x.pk1 + 1;
rollback;

select count(*) from t1;
select * from t1 where pk1 = 1;
select t1.attr1 from t1, t1 as t1x where t1.pk1 = t1x.pk1 + 1;

begin;
insert into t1 values(1,1);
insert into t1 values(2,2);
commit;

select count(*) from t1;
select * from t1 where pk1 = 1;
select t1.attr1 from t1, t1 as t1x where t1.pk1 = t1x.pk1 + 1;

# update
begin;
update t1 set attr1 = attr1 * 2;
select count(*) from t1;
select * from t1 where pk1 = 1;
select * from t1, t1 as t1x where t1x.attr1 = t1.attr1 - 2;
rollback;

select count(*) from t1;
select * from t1 where pk1 = 1;
select * from t1, t1 as t1x where t1x.attr1 = t1.attr1 - 2;

begin;
update t1 set attr1 = attr1 * 2;
commit;

select count(*) from t1;
select * from t1 where pk1 = 1;
select * from t1, t1 as t1x where t1x.attr1 = t1.attr1 - 2;

# delete
begin;
delete from t1 where attr1 = 2;
select count(*) from t1;
select * from t1 where pk1 = 1;
select * from t1, t1 as t1x where t1x.attr1 = t1.attr1 - 2;
rollback;

select count(*) from t1;
select * from t1 where pk1 = 1;
select * from t1, t1 as t1x where t1x.attr1 = t1.attr1 - 2;

begin;
delete from t1 where attr1 = 2;
commit;

select count(*) from t1;
select * from t1 where pk1 = 1;
select * from t1, t1 as t1x where t1x.attr1 = t1.attr1 - 2;

DROP TABLE t1;

#
# Create table without primary key
# a hidden primary key column is created by handler
#
CREATE TABLE t1 (id INT, id2 int) engine=ndbcluster;

# insert
begin;
insert into t1 values(1,1);
insert into t1 values(2,2);
select sum(id) from t1;
select * from t1 where id = 1;
select t1.id from t1, t1 as t1x where t1.id2 = t1x.id2 + 1;
rollback;

select sum(id) from t1;
select * from t1 where id = 1;
select t1.id from t1, t1 as t1x where t1.id2 = t1x.id2 + 1;

begin;
insert into t1 values(1,1);
insert into t1 values(2,2);
commit;

select sum(id) from t1;
select * from t1 where id = 1;
select t1.id from t1, t1 as t1x where t1.id2 = t1x.id2 + 1;

# update
begin;
update t1 set id = id * 2;
select sum(id) from t1;
select * from t1 where id = 2;
select * from t1, t1 as t1x where t1x.id = t1.id - 2;
rollback;

select sum(id) from t1;
select * from t1 where id = 2;
select * from t1, t1 as t1x where t1x.id = t1.id - 2;

begin;
update t1 set id = id * 2;
commit;

select sum(id) from t1;
select * from t1 where id = 2;
select * from t1, t1 as t1x where t1x.id = t1.id - 2;

# delete

DROP TABLE t1;

#
# A more extensive test with a lot more records
#

CREATE TABLE t2 (
  a bigint unsigned NOT NULL PRIMARY KEY,
  b int unsigned not null,
  c int unsigned
) engine=ndbcluster;

CREATE TABLE t3 (
  a bigint unsigned NOT NULL,
  b bigint unsigned not null,
  c bigint unsigned,
  PRIMARY KEY(a)
) engine=ndbcluster;

CREATE TABLE t4 (
  a bigint unsigned NOT NULL,
  b bigint unsigned not null,
  c bigint unsigned NOT NULL,
  d int unsigned,
  PRIMARY KEY(a, b, c)
) engine=ndbcluster;


#
# insert records into tables and rollback
#
let $1=100;
disable_query_log;
begin;
while ($1)
{
 eval insert into t2 values($1, $1+9, 5);
 eval insert into t3 values($1, $1+9, 5);
 eval insert into t4 values($1, $1+9, 5, $1+26000);
 dec $1;
}
rollback;
enable_query_log;

select count(*) from t2;
select count(*) from t3;
select count(*) from t4;

#
# insert records into tables and commit;
#
let $1=100;
disable_query_log;
begin;
while ($1)
{
 eval insert into t2 values($1, $1+9, 5);
 eval insert into t3 values($1, $1+9, 5);
 eval insert into t4 values($1, $1+9, 5, $1+26000);
 dec $1;
}
commit;
enable_query_log;

select count(*) from t2;
select count(*) from t3;
select count(*) from t4;

#
# delete every other record in the tables
#
let $1=100;
disable_query_log;
while ($1)
{
 eval delete from t2 where a=$1;
 eval delete from t3 where a=$1;
 eval delete from t4 where a=$1 and b=$1+9 and c=5;
 dec $1;
 dec $1;
}
enable_query_log;

#
# update records and rollback
#
begin;
let $1=100;
disable_query_log;
while ($1)
{
 eval update t2 set c=$1 where a=$1;
 eval update t3 set c=7 where a=$1 and b=$1+9 and c=5;
 eval update t4 set d=$1+21987 where a=$1 and b=$1+9 and c=5;
 dec $1;
 dec $1;
}
rollback;
enable_query_log;

#
# update records and commit
#
begin;
let $1=100;
disable_query_log;
while ($1)
{
 eval update t2 set c=$1 where a=$1;
 eval update t3 set c=7 where a=$1 and b=$1+9 and c=5;
 eval update t4 set d=$1+21987 where a=$1 and b=$1+9 and c=5;
 dec $1;
 dec $1;
}
rollback;
enable_query_log;

drop table t2;
drop table t3;
drop table t4;

259 260 261 262 263 264 265 266 267
#
# Test multiple databases in one transaction
#

CREATE TABLE t1 (
  pk1 INT NOT NULL PRIMARY KEY,
  attr1 INT NOT NULL
) ENGINE=ndbcluster;

268 269
create database mysqltest;
use mysqltest;
270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296

CREATE TABLE t2 (
  a bigint unsigned NOT NULL PRIMARY KEY,
  b int unsigned not null,
  c int unsigned
) engine=ndbcluster;

begin;
insert into test.t1 values(1,1);
insert into t2 values(1,1,1);
insert into test.t1 values(2,2);
insert into t2 values(2,2,2);
select count(*) from test.t1;
select count(*) from t2;
select * from test.t1 where pk1 = 1;
select * from t2 where a = 1;
select test.t1.attr1 
from test.t1, test.t1 as t1x where test.t1.pk1 = t1x.pk1 + 1;
select t2.a 
from t2, t2 as t2x where t2.a = t2x.a + 1;
select test.t1.pk1, a from test.t1,t2 where b > test.t1.attr1;
rollback;

select count(*) from test.t1;
select count(*) from t2;

drop table test.t1, t2;
297
drop database mysqltest;
298

299
# End of 4.1 tests