connect(DB_HOST, DB_PORT, DB_USER, DB_PASS, DB_NAME);
$ret = yield from $my->query('SELECT id, message FROM Fortune');
$arr = [];
foreach ($ret as $row) {
$arr[$row['id']] = $row['message'];
}
$arr[0] = 'Additional fortune added at request time.';
asort($arr);
$html = '';
foreach ($arr as $id => $message) {
$message = htmlspecialchars($message, ENT_QUOTES, 'UTF-8');
$html .= "
$id | $message |
";
}
echo 'Fortunes';
unset($my);
}
function query()
{
ngx_header_set('Content-Type', 'application/json');
$my = new php\ngx\mysql();
yield from $my->connect(DB_HOST, DB_PORT, DB_USER, DB_PASS, DB_NAME);
$query_count = 1;
$params = ngx_query_args();
if ($params['queries'] > 1) {
$query_count = $params['queries'] > 500 ? 500 : $params['queries'];
}
$arr = [];
while ($query_count--) {
$rand = mt_rand(1, 10000);
$arr[] = (yield from $my->query("SELECT id,randomNumber FROM World WHERE id = {$rand}"))[0];
}
unset($my);
echo json_encode($arr);
}
function db()
{
ngx_header_set('Content-Type', 'application/json');
$my = new php\ngx\mysql();
yield from $my->connect(DB_HOST, DB_PORT, DB_USER, DB_PASS, DB_NAME);
$data = (yield from $my->query('SELECT id,randomNumber FROM World WHERE id = '.mt_rand(1, 10000)))[0];
unset($my);
echo json_encode($data);
}
function update()
{
ngx_header_set('Content-Type', 'application/json');
$my = new php\ngx\mysql();
yield from $my->connect(DB_HOST, DB_PORT, DB_USER, DB_PASS, DB_NAME);
$query_count = 1;
$params = ngx_query_args();
if ($params['queries'] > 1) {
$query_count = $params['queries'] > 500 ? 500 : $params['queries'];
}
$arr = [];
while ($query_count--) {
$id = mt_rand(1, 10000);
$world = (yield from $my->query("SELECT id, randomNumber FROM World WHERE id = {$id}"))[0];
$world['id'] = $id;
$world['randomNumber'] = mt_rand(1, 10000);
yield from $my->query("UPDATE World SET randomNumber = {$world['randomNumber']} WHERE id = {$world['id']}");
$arr[] = $world;
}
unset($my);
echo json_encode($arr);
}