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', $html, '
idmessage
'; 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); }