#!/usr/local/bin/php
<?

$host = "";
$database = "";
$mysql_username = "";
$mysql_password = "";


#################################################

set_time_limit(0);

function problem() {
	echo mysql_error() . "\n";
	exit(1);
}


### Connect to MySQL server
$conn = mysql_connect($host, $mysql_username, $mysql_password);
if (!$conn) problem();
if (!mysql_select_db($database, $conn)) problem();

### Create test_table
if (!mysql_query("drop table if exists test_table", $conn)) problem();
if (!mysql_query("create table test_table (keyid int unsigned not null primary key, value bigint not null)", $conn)) problem();

### Create and populate test_table2
if (!mysql_query("drop table if exists test_table2", $conn)) problem();
if (!mysql_query("create table test_table2 (keyid int unsigned not null primary key, value int not null)", $conn)) problem();
for ($i = 0; $i < 500000; $i += 1000) {
	$arr = array();
	for ($j = $i; $j < ($i + 1000); $j++) {
		$val = mt_rand(0, 2000000000);
		$arr[] = "($j, $val)";
	}
	mysql_query("insert into test_table2 values " . implode(", ", $arr), $conn);
}

### Start second process
echo "Start second process now!\n";
echo "5\n";
sleep(1);
echo "4\n";
sleep(1);
echo "3\n";
sleep(1);
echo "2\n";
sleep(1);
echo "1\n";
sleep(1);
echo "Running inserts...\n";

### Do inserts
for ($i = 0; $i < 1000; $i++) {
	echo ".";
	$start = mt_rand(0, 4000000);
	$end = $start + 1000000;
	if (!mysql_query("insert into test_table select $i, sum(value) from (select value from test_table2 order by rand()) as tt2", $conn)) problem();
	echo "|";
	
	do {
		usleep(10000);
		$result = mysql_query("select keyid from test_table", $conn);
		if (!$result) problem();
		$num = mysql_num_rows($result);
		mysql_free_result($result);
	} while ($num > 0);
}

?>