|
|
@@ -1,35 +1,89 @@
|
|
|
<?php
|
|
|
-// Future app to use Mysql async pool
|
|
|
+require_once '/ngx_php7/t/lib/mysql.php';
|
|
|
+define('DBIP', gethostbyname('localhost'));
|
|
|
+define('DB_HOST', gethostbyname('tfb-database'));
|
|
|
+define('DB_PORT', '3306');
|
|
|
+define('DB_USER', 'benchmarkdbuser');
|
|
|
+define('DB_PASS', 'benchmarkdbpass');
|
|
|
+define('DB_NAME', 'hello_world');
|
|
|
|
|
|
-require_once "/ngx_php7/t/lib/mysql.php";
|
|
|
-define("DB_HOST", gethostbyname("tfb-database"));
|
|
|
-define("DB_PORT", "3306");
|
|
|
-define("DB_USER", "benchmarkdbuser");
|
|
|
-define("DB_PASS", "benchmarkdbpass");
|
|
|
-define("DB_NAME", "hello_world");
|
|
|
|
|
|
function fortune()
|
|
|
{
|
|
|
+ ngx_header_set('Content-Type', 'text/html;charset=UTF-8');
|
|
|
$my = new php\ngx\mysql();
|
|
|
yield from $my->connect(DB_HOST, DB_PORT, DB_USER, DB_PASS, DB_NAME);
|
|
|
- $ret = yield from $my->query("SELECT id, message FROM Fortune");
|
|
|
-
|
|
|
+ $ret = yield from $my->query('SELECT id, message FROM Fortune');
|
|
|
+
|
|
|
$arr = [];
|
|
|
foreach ($ret as $row) {
|
|
|
- $arr[$row["id"]] = $row["message"];
|
|
|
+ $arr[$row['id']] = $row['message'];
|
|
|
}
|
|
|
- $arr[0] = "Additional fortune added at request time.";
|
|
|
+ $arr[0] = 'Additional fortune added at request time.';
|
|
|
asort($arr);
|
|
|
-
|
|
|
- $html = "";
|
|
|
+
|
|
|
+ $html = '';
|
|
|
foreach ($arr as $id => $message) {
|
|
|
- $message = htmlspecialchars($message, ENT_QUOTES, "UTF-8");
|
|
|
+ $message = htmlspecialchars($message, ENT_QUOTES, 'UTF-8');
|
|
|
$html .= "<tr><td>$id</td><td>$message</td></tr>";
|
|
|
}
|
|
|
+ echo '<!DOCTYPE html><html><head><title>Fortunes</title></head><body><table><tr><th>id</th><th>message</th></tr>',
|
|
|
+ $html,
|
|
|
+ '</table></body></html>';
|
|
|
+
|
|
|
+ unset($my);
|
|
|
+}
|
|
|
|
|
|
- echo "<!DOCTYPE html><html><head><title>Fortunes</title></head><body><table><tr><th>id</th><th>message</th></tr>",
|
|
|
- $html,
|
|
|
- "</table></body></html>";
|
|
|
+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');
|
|
|
|
|
|
- yield from $my->close();
|
|
|
-}
|
|
|
+ $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);
|
|
|
+}
|
Joan Miquel