~drizzle-trunk/drizzle/jenkins-Drizzle-Builder-213

$dbh->do("create table $firsttable (id int(7) not null, thread tinyint not null, info varchar(32), marker char(1), primary key(id,thread))") or die $DBI::errstr;

$dbh->do("create table $secondtable (id int(7) not null, thread tinyint not null, row int(3) not null,value double, primary key(id,thread,row)) delay_key_write=1") or die $DBI::errstr;

$dbh->disconnect; $dbh=0; # Close handler

}

$|= 1; # Autoflush

####

#### Start the tests

####

insert_in_bench1() if (($pid=fork()) == 0); $work{$pid}="insert in bench1";

insert_in_bench2() if (($pid=fork()) == 0); $work{$pid}="insert in bench2";

repair_and_check() if (($pid=fork()) == 0); $work{$pid}="repair/check";

$errors=0;

while (($pid=wait()) != -1)

{

$ret=$?/256;

print "thread '" . $work{$pid} . "' finished with exit code $ret\n";

$errors++ if ($ret != 0);

}

if (!$opt_skip_delete && !$errors)

{

$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",

$opt_user, $opt_password,

{ PrintError => 0}) || die $DBI::errstr;

$dbh->do("drop table $firsttable,$secondtable");

}

print ($errors ? "Test failed\n" :"Test ok\n");

$end_time=new Benchmark;

print "Total time: " .

timestr(timediff($end_time, $start_time),"noc") . "\n";

exit(0);

# Insert records in the two tables

sub insert_in_bench1

{

my ($dbh,$rows,$found,$i);

$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",

$opt_user, $opt_password,

{ PrintError => 0}) || die $DBI::errstr;

$rows=$found=0;

for ($i=0 ; $i < $opt_loop_count; $i++)

{

$sth=$dbh->do("insert into $firsttable values ($i,0,'This is entry $i','')") || die "Got error on insert: $DBI::errstr\n";

$row_count=($i % 7)+1;

$rows+=1+$row_count;

for ($j=0 ; $j < $row_count; $j++)

{

$sth=$dbh->do("insert into $secondtable values ($i,0,$j,0)") || die "Got error on insert: $DBI::errstr\n";

}

100

$dbh->disconnect; $dbh=0;

101

print "insert_in_bench1: Inserted $rows rows\n";

102

exit(0);

103

}

104

105

sub insert_in_bench2

106

{

107

my ($dbh,$rows,$found,$i);

108

109

$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",

110

$opt_user, $opt_password,

111

{ PrintError => 0}) || die $DBI::errstr;

112

$rows=$found=0;

113

for ($i=0 ; $i < $opt_loop_count; $i++)

114

{

115

$sth=$dbh->do("insert into $firsttable values ($i,1,'This is entry $i','')") || die "Got error on insert: $DBI::errstr\n";

116

$row_count=((7-$i) % 7)+1;

117

$rows+=1+$row_count;

118

for ($j=0 ; $j < $row_count; $j++)

119

{

120

$sth=$dbh->do("insert into $secondtable values ($i,1,$j,0)") || die "Got error on insert: $DBI::errstr\n";

121

}

122

}

123

$dbh->disconnect; $dbh=0;

124

print "insert_in_bench2: Inserted $rows rows\n";

125

exit(0);

126

}

127

128

129

sub repair_and_check

130

{

131

my ($dbh,$row,@row,$found1,$found2,$last_found1,$last_found2,$i,$type,

132

$table);

133

$found1=$found2=0; $last_found1=$last_found2= -1;

134

135

$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",

136

$opt_user, $opt_password,

137

{ PrintError => 0}) || die $DBI::errstr;

138

139

for ($i=0; $found1 != $last_found1 && $found2 != $last_found1 ; $i++)

140

{

141

$type=($i & 2) ? "repair" : "check";

142

if ($i & 1)

143

{

144

$table=$firsttable;

145

$last_found1=$found1;

146

}

147

else

148

{

149

$table=$secondtable;

150

$last_found2=$found2;

151

}

152

$sth=$dbh->prepare("$type table $table") || die "Got error on prepare: $dbh->errstr\n";

153

$sth->execute || die $dbh->errstr;

154

155

while (($row=$sth->fetchrow_arrayref))

156

{

157

if ($row->[3] ne "OK")

158

{

159

print "Got error " . $row->[3] . " when doing $type on $table\n";

160

exit(1);

161

}

162

}

163

$sth=$dbh->prepare("select count(*) from $table") || die "Got error on prepare: $dbh->errstr\n";

164

$sth->execute || die $dbh->errstr;

165

@row = $sth->fetchrow_array();

166

if ($i & 1)

167

{

168

$found1= $row[0];

169

}

170

else

171

{

172

$found2= $row[0];

173

}

174

$sth->finish;

175

sleep(2);

176

}

177

$dbh->disconnect; $dbh=0;

178

print "check/repair: Did $i repair/checks\n";

179

exit(0);

180

}

Older »