Select id and randomnumber to match rules requirements (#6072)

* Select id and randomnumber to match rules requirements

* Update db

* more fixes

frameworks/C++/cpoll_cppsp/www/db

@@ -23,7 +23,7 @@ public:
 	myStatement() {
 		db=doConnect(NULL);
 		stmt=mysql_stmt_init(db);
-		const char* sql="SELECT randomNumber FROM World WHERE id = ?";
+		const char* sql="SELECT randomNumber, id FROM World WHERE id = ?";
 		mysql_stmt_prepare(stmt,sql,strlen(sql));
 		memset(param, 0, sizeof(param));
 		memset(results, 0, sizeof(results));
@@ -107,7 +107,7 @@ void doInit() override {
 	if(queries<1)queries=1;
 	if(queries>500)queries=500;
 	int i;
-	
+
 	items=(world*)sp->alloc(sizeof(world)*queries);
 	stmt=stmtPool.get();
 	poll->add(efd);

frameworks/C++/cpoll_cppsp/www/db_old

@@ -26,7 +26,7 @@ char query[256];
 if(db==NULL) {
 	db=doConnect(NULL);
 	stmt=mysql_stmt_init(db);
-	const char* sql="SELECT randomNumber FROM World WHERE id = ?";
+	const char* sql="SELECT randomNumber, id FROM World WHERE id = ?";
 	mysql_stmt_prepare(stmt,sql,strlen(sql));
 	memset(param, 0, sizeof(param));
 	memset(results, 0, sizeof(results));

frameworks/C++/cpoll_cppsp/www/db_pg_async

@@ -27,7 +27,7 @@ public:
 		db=doConnect_pg(NULL);
 		Oid oid=INT4OID;
 		PGresult* res;
-		if((res=PQprepare(db, "zxcvb", "SELECT randomnumber FROM World where id=$1", 1, &oid))==NULL)
+		if((res=PQprepare(db, "zxcvb", "SELECT randomnumber, id FROM World where id=$1", 1, &oid))==NULL)
 			goto fail;
 		PQclear(res);
 		paramLengths[0] = sizeof(int);

frameworks/C++/cpoll_cppsp/www/db_pg_threadpool

@@ -23,7 +23,7 @@ public:
 		db=doConnect_pg(NULL);
 		Oid oid=INT4OID;
 		PGresult* res;
-		if((res=PQprepare(db, "zxcvb", "SELECT randomnumber FROM World where id=$1", 1, &oid))==NULL)
+		if((res=PQprepare(db, "zxcvb", "SELECT id, randomnumber FROM World where id=$1", 1, &oid))==NULL)
 			goto fail;
 		PQclear(res);
 		paramLengths[0] = sizeof(int);

frameworks/C++/cpoll_cppsp/www/update

@@ -26,10 +26,10 @@ public:
 	MYSQL_BIND param_update[2];
 	myStatement() {
 		db=doConnect(NULL);
-		
+
 		//select statement
 		stmt=mysql_stmt_init(db);
-		const char* sql="SELECT randomNumber FROM World WHERE id = ?";
+		const char* sql="SELECT randomNumber, id FROM World WHERE id = ?";
 		if(mysql_stmt_prepare(stmt,sql,strlen(sql)))
 			throw runtime_error(mysql_stmt_error(stmt));
 		memset(param, 0, sizeof(param));
@@ -46,7 +46,7 @@ public:
 		results[0].length = &len1;
 		if(mysql_stmt_bind_param(stmt,param)) throw runtime_error(mysql_stmt_error(stmt));
 		if(mysql_stmt_bind_result(stmt, results)) throw runtime_error(mysql_stmt_error(stmt));
-		
+
 		//update statement
 		stmt_update=mysql_stmt_init(db);
 		sql="update World set randomNumber=? WHERE id = ?";
@@ -146,7 +146,7 @@ void doInit() override {
 	if(queries<1)queries=1;
 	if(queries>500)queries=500;
 	int i;
-	
+
 	items=(world*)sp->alloc(sizeof(world)*queries);
 	stmt=stmtPool.get();
 	poll->add(efd);

frameworks/C++/cutelyst/src/databaseupdatestest.cpp

@@ -61,7 +61,7 @@ void DatabaseUpdatesTest::updatep(Context *c)
 void DatabaseUpdatesTest::updates_postgres(Context *c)
 {
     QSqlQuery query = CPreparedSqlQueryThreadForDB(
-                QLatin1String("SELECT randomNumber FROM world WHERE id = :id"),
+                QLatin1String("SELECT id, randomNumber FROM world WHERE id = :id"),
                 QStringLiteral("postgres"));
     QSqlQuery updateQuery = CPreparedSqlQueryThreadForDB(
                 QLatin1String("UPDATE world SET randomNumber = :randomNumber WHERE id = :id"),
@@ -72,7 +72,7 @@ void DatabaseUpdatesTest::updates_postgres(Context *c)
 void DatabaseUpdatesTest::updates_mysql(Context *c)
 {
     QSqlQuery query = CPreparedSqlQueryThreadForDB(
-                QLatin1String("SELECT randomNumber FROM world WHERE id = :id"),
+                QLatin1String("SELECT randomNumber, id FROM world WHERE id = :id"),
                 QStringLiteral("mysql"));
     QSqlQuery updateQuery = CPreparedSqlQueryThreadForDB(
                 QLatin1String("UPDATE world SET randomNumber = :randomNumber WHERE id = :id"),

frameworks/C++/ulib/src/world.h

@@ -334,7 +334,7 @@ public:
 				return;
 				}
 
-			U_NEW(UOrmStatement, pstmt_query, UOrmStatement(*psql_query, U_CONSTANT_TO_PARAM("SELECT randomNumber FROM World WHERE id = ?")));
+			U_NEW(UOrmStatement, pstmt_query, UOrmStatement(*psql_query, U_CONSTANT_TO_PARAM("SELECT randomNumber, id FROM World WHERE id = ?")));
 
 			U_NEW(World, pworld_query, World);
 

frameworks/Crystal/crystal/server.cr

@@ -12,7 +12,7 @@ server = HTTP::Server.new do |context|
 
   response.headers["Server"] = "Crystal"
   response.headers["Date"] = HTTP.format_time(Time.now)
-  
+
   case request.path
   when "/json"
     response.status_code = 200
@@ -58,7 +58,7 @@ server = HTTP::Server.new do |context|
     JSON.build(response) do |json|
       json.array do
         sanitized_query_count(request).times do
-          world = set_world({id: random_world[:id], randomNumber: rand(1..ID_MAXIMUM)})          
+          world = set_world({id: random_world[:id], randomNumber: rand(1..ID_MAXIMUM)})
           world.to_json(json)
         end
       end
@@ -70,7 +70,7 @@ end
 
 private def random_world
   id = rand(1..ID_MAXIMUM)
-  random_number = APPDB.query_one("SELECT randomNumber FROM world WHERE id = $1", id, as: Int32)
+  random_number = APPDB.query_one("SELECT id, randomNumber FROM world WHERE id = $1", id, as: Int32)
   {id: id, randomNumber: random_number}
 end
 

frameworks/Crystal/crystal/server_radix.cr

@@ -109,7 +109,7 @@ end
 
 private def random_world
   id = rand(1..ID_MAXIMUM)
-  random_number = APPDB.query_one("SELECT randomNumber FROM world WHERE id = $1", id, as: Int32)
+  random_number = APPDB.query_one("SELECT id, randomNumber FROM world WHERE id = $1", id, as: Int32)
   {id: id, randomNumber: random_number}
 end
 

frameworks/Crystal/raze/raze.cr

@@ -12,7 +12,7 @@ end
 
 private def get_world
   id = Random.rand(CONTENT::ID_MAX).succ
-  random_number = BENCH_DB.query_one("SELECT randomNumber FROM world WHERE id = $1", id, as: Int32)
+  random_number = BENCH_DB.query_one("SELECT id, randomNumber FROM world WHERE id = $1", id, as: Int32)
   { id: id, randomNumber: random_number }
 end
 

frameworks/D/hunt/http/http/DemoProcessor.d

@@ -151,7 +151,7 @@ class DemoProcessor : HttpProcessor {
 
         private void respondSingleQuery() {
             int id = uniform(1, 10001);
-            string query = "SELECT randomNumber FROM world WHERE id = " ~ id.to!string;
+            string query = "SELECT id, randomNumber FROM world WHERE id = " ~ id.to!string;
             ResultSet rs = dbConnection.query(query);
 
             JSONValue js = JSONValue(["id" : JSONValue(id), "randomNumber"
@@ -169,7 +169,7 @@ class DemoProcessor : HttpProcessor {
             JSONValue[] arr = new JSONValue[queries];
             for (int i = 0; i < queries; i++) {
                 immutable id = uniform(1, 10001);
-                immutable query = "SELECT randomNumber FROM world WHERE id = " ~ id.to!string;
+                immutable query = "SELECT id, randomNumber FROM world WHERE id = " ~ id.to!string;
                 ResultSet rs = dbConnection.query(query);
 
                 arr[i] = JSONValue(["id" : JSONValue(id), "randomNumber"
@@ -226,7 +226,7 @@ class DemoProcessor : HttpProcessor {
             for (int i = 0; i < queries; i++) {
                 immutable id = uniform(1, 10001);
                 immutable idString = id.to!string;
-                immutable query = "SELECT randomNumber FROM world WHERE id = " ~ idString;
+                immutable query = "SELECT id, randomNumber FROM world WHERE id = " ~ idString;
                 ResultSet rs = dbConnection.query(query);
                 int randomNumber = to!int(rs.front()[0]);
                 debug tracef("id=%d, randomNumber=%d", id, randomNumber);

frameworks/D/hunt/mmap/DemoProcessor.d

@@ -76,7 +76,7 @@ class DemoProcessor : HttpProcessor {
         } else {
             respondWith404();
         }
-        }    
+        }
     }
 
 
@@ -92,7 +92,7 @@ class DemoProcessor : HttpProcessor {
     version (POSTGRESQL) {
         private void handleDbUpdate(string url) {
             uri.parse(url);
-            
+
             switch(uri.getPath()) {
             case "/queries":
                 UrlEncoded queriesMap = new UrlEncoded();
@@ -166,7 +166,7 @@ class DemoProcessor : HttpProcessor {
 
         private void respondSingleQuery() {
             int id = uniform(1, 10001);
-            string query = "SELECT randomNumber FROM world WHERE id = " ~ id.to!string;
+            string query = "SELECT id, randomNumber FROM world WHERE id = " ~ id.to!string;
             ResultSet rs = dbConnection.query(query);
 
             JSONValue js = JSONValue(["id" : JSONValue(id), "randomNumber"
@@ -184,7 +184,7 @@ class DemoProcessor : HttpProcessor {
             JSONValue[] arr = new JSONValue[queries];
             for (int i = 0; i < queries; i++) {
                 immutable id = uniform(1, 10001);
-                immutable query = "SELECT randomNumber FROM world WHERE id = " ~ id.to!string;
+                immutable query = "SELECT id, randomNumber FROM world WHERE id = " ~ id.to!string;
                 ResultSet rs = dbConnection.query(query);
 
                 arr[i] = JSONValue(["id" : JSONValue(id), "randomNumber"
@@ -241,7 +241,7 @@ class DemoProcessor : HttpProcessor {
             for (int i = 0; i < queries; i++) {
                 immutable id = uniform(1, 10001);
                 immutable idString = id.to!string;
-                immutable query = "SELECT randomNumber FROM world WHERE id = " ~ idString;
+                immutable query = "SELECT id, randomNumber FROM world WHERE id = " ~ idString;
                 ResultSet rs = dbConnection.query(query);
                 int randomNumber = to!int(rs.front()[0]);
                 debug tracef("id=%d, randomNumber=%d", id, randomNumber);

frameworks/D/vibed/source/postgresql.d

@@ -113,7 +113,7 @@ class WebInterface {
 		foreach (ref w; data) {
 			int id = _uniformVariable(_gen);
 			qp.argsVariadic(id);
-			immutable query = "SELECT randomNumber FROM world WHERE id = " ~  id.to!string;
+			immutable query = "SELECT randomNumber, id FROM world WHERE id = " ~  id.to!string;
 			immutable result = conn.execPrepared(qp).rangify.front;
 			w = WorldResponse(id, result[0].as!PGinteger);
 		}
@@ -168,7 +168,7 @@ class WebInterface {
 		foreach (ref w; data) {
 			int id = _uniformVariable(_gen);
 			qp.argsVariadic(id);
-			immutable query = "SELECT randomNumber FROM world WHERE id = " ~  id.to!string;
+			immutable query = "SELECT id, randomNumber FROM world WHERE id = " ~  id.to!string;
 			immutable result = conn.execPrepared(qp).rangify.front;
 			w = WorldResponse(id, result[0].as!PGinteger);
 
@@ -211,7 +211,7 @@ static this()
 						~ "dbname=hello_world  user=benchmarkdbuser password=benchmarkdbpass";
 	client = new PostgresClient(connectionInfo, poolSize, (Connection cn){
 		cn.prepare("fortune_prpq", "SELECT id, message::text FROM Fortune");
-		cn.prepare("db_prpq", "SELECT randomNumber FROM world WHERE id = $1");
+		cn.prepare("db_prpq", "SELECT randomNumber, id FROM world WHERE id = $1");
 		cn.prepare("db_update_prpq", "UPDATE world SET randomNumber = $1  WHERE id = $2");
 	} );
 }

frameworks/PHP/comet/src/ORM.php

@@ -16,7 +16,7 @@ class ORM
         self::$pdo = new \PDO(
             'pgsql:host=tfb-database;dbname=hello_world',
 //	    	'pgsql:host=192.168.99.1;dbname=hello_world',
-            'benchmarkdbuser', 
+            'benchmarkdbuser',
             'benchmarkdbpass',
             [
 //              \PDO::ATTR_CASE => \PDO::CASE_NATURAL,
@@ -27,7 +27,7 @@ class ORM
 
         self::$statement = self::$pdo->prepare('SELECT id, randomNumber FROM World WHERE id=?');
         self::$fortune   = self::$pdo->prepare('SELECT id, message FROM Fortune');
-        self::$random    = self::$pdo->prepare('SELECT randomNumber FROM World WHERE id=?');
+        self::$random    = self::$pdo->prepare('SELECT randomNumber, id FROM World WHERE id=?');
         self::$update    = self::$pdo->prepare('UPDATE World SET randomNumber=? WHERE id=?');
     }
 }

frameworks/PHP/fat-free/index.php

@@ -172,7 +172,7 @@ $f3->route(array(
         $id = mt_rand(1, 10000);
         $row = array(
             'id' => $id,
-            'randomNumber' => $db->exec('SELECT randomNumber FROM World WHERE id = ?', $id, 0, false)
+            'randomNumber' => $db->exec('SELECT id, randomNumber FROM World WHERE id = ?', $id, 0, false)
         );
         $rnu = mt_rand(1, 10000);
         $row['randomNumber'] = $rnu;

frameworks/PHP/hhvm/once.php.inc

@@ -31,7 +31,7 @@ class Benchmark {
         $id = mt_rand(1, 10000);
 
         // Define query
-        $statement = $this->pdo->prepare('SELECT randomNumber FROM World WHERE id = :id');
+        $statement = $this->pdo->prepare('SELECT id, randomNumber FROM World WHERE id = :id');
         $statement->bindParam(':id', $id, PDO::PARAM_INT);
         $statement->execute();
 
@@ -52,7 +52,7 @@ class Benchmark {
         $id = mt_rand(1, 10000);
 
         // Define query
-        $statement = $this->pdo->prepare('SELECT randomNumber FROM World WHERE id = :id');
+        $statement = $this->pdo->prepare('SELECT id, randomNumber FROM World WHERE id = :id');
         $statement->bindParam(':id', $id, PDO::PARAM_INT);
 
         // For each query, store the result set values in the response array
@@ -79,7 +79,7 @@ class Benchmark {
         $randomNumber = mt_rand(1, 1000);
 
         // Define query
-        $statement = $this->pdo->prepare('SELECT randomNumber FROM World WHERE id = :id');
+        $statement = $this->pdo->prepare('SELECT id, randomNumber FROM World WHERE id = :id');
         $statement->bindParam(':id', $id, PDO::PARAM_INT);
 
         $updateStatement = $this->pdo->prepare('UPDATE World SET randomNumber = :randomNumber WHERE id = :id');

frameworks/PHP/kumbiaphp/bench/app/controllers/ra_controller.php

@@ -35,11 +35,11 @@ class RaController extends AppController
     public function update($count = 1)
     {
         $count = min(max($count, 1), 500);
-        
+
         $this->pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);
-        $sth = $this->pdo->prepare('SELECT randomNumber FROM World WHERE id=?');
+        $sth = $this->pdo->prepare('SELECT id, randomNumber FROM World WHERE id=?');
         $updateStatement = $this->pdo->prepare('UPDATE World SET randomNumber=? WHERE id=?');
-        
+
         while ($count--) {
             $id = mt_rand(1, 10000);
 
@@ -54,4 +54,4 @@ class RaController extends AppController
 
         echo json_encode($worlds);
     }
-}
+}

frameworks/PHP/kumbiaphp/bench/app/libs/ku_raw.php

@@ -26,7 +26,7 @@ class KuRaw
 
         self::$db        = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id = ?');
         self::$fortune   = $pdo->prepare('SELECT id,message FROM Fortune');
-        self::$random    = $pdo->prepare('SELECT randomNumber FROM World WHERE id = ?');
+        self::$random    = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id = ?');
         self::$instance  = $pdo;
     }
 

frameworks/PHP/peachpie/Website/updateraw.php

@@ -13,24 +13,24 @@ function updateraw(int $query_count) {
 
   // Create an array with the response string.
   $arr = [];
-  
+
   // Ensure the number of queries to run from URL parameter
   $query_count = max(min($query_count, 500), 1);
-  
+
   // For each query, store the result set values in the response array
   while ($query_count--) {
 
     $id = mt_rand(1, 10000);
     $randomNumber = mt_rand(1, 10000);
 
-    $result = mysql_query("SELECT randomNumber FROM World WHERE id = $id", $link);
-    
+    $result = mysql_query("SELECT id, randomNumber FROM World WHERE id = $id", $link);
+
     // Store result in array.
     $world = ['id' => $id, 'randomNumber' => mysql_result($result, 0)];
     $world['randomNumber'] = $randomNumber;
 
     mysql_query("UPDATE World SET randomNumber = $randomNumber WHERE id = $id", $link);
-    
+
     $arr[] = $world;
   }
 

frameworks/PHP/php-ngx/app.php

@@ -7,7 +7,7 @@ $pdo = new PDO('mysql:host=tfb-database;dbname=hello_world', 'benchmarkdbuser',
 
 $statement = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id=?');
 $fortune   = $pdo->prepare('SELECT id,message FROM Fortune');
-$random    = $pdo->prepare('SELECT randomNumber FROM World WHERE id=?');
+$random    = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id=?');
 $update    = $pdo->prepare('UPDATE World SET randomNumber=? WHERE id=?');
 
 function db()

frameworks/PHP/php/updateraw.php

@@ -2,7 +2,7 @@
 header('Content-Type: application/json');
 // Database connection
 // http://www.php.net/manual/en/ref.pdo-mysql.php
-$pdo = new PDO('mysql:host=tfb-database;dbname=hello_world', 'benchmarkdbuser', 'benchmarkdbpass', 
+$pdo = new PDO('mysql:host=tfb-database;dbname=hello_world', 'benchmarkdbuser', 'benchmarkdbpass',
     [PDO::ATTR_PERSISTENT => true,
     PDO::ATTR_EMULATE_PREPARES => false]
 );
@@ -14,7 +14,7 @@ if ($_GET['queries'] > 1) {
 }
 
 // Define query
-$statement = $pdo->prepare('SELECT randomNumber FROM World WHERE id=?');
+$statement = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id=?');
 $updateStatement = $pdo->prepare('UPDATE World SET randomNumber=? WHERE id=?');
 
 // For each query, store the result set values in the response array

frameworks/PHP/swoole/db-no-async.php

@@ -21,7 +21,7 @@ class Db
 
         self::$db        = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id = ?');
         self::$fortune   = $pdo->prepare('SELECT id,message FROM Fortune');
-        self::$random    = $pdo->prepare('SELECT randomNumber FROM World WHERE id = ?');
+        self::$random    = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id = ?');
         self::$update    = $pdo->prepare('UPDATE World SET randomNumber = ? WHERE id = ?');
     }
 }

frameworks/PHP/swoole/swoole-server.php

@@ -113,7 +113,7 @@ $updates_postgres = function (int $queries = 0) use ($pool): string {
 
     $arr = [];
 
-    $db->us ??= $db->prepare('us', 'SELECT randomnumber FROM World WHERE id = $1');
+    $db->us ??= $db->prepare('us', 'SELECT id,randomnumber FROM World WHERE id = $1');
     $db->uu ??= $db->prepare('uu', 'UPDATE World SET randomnumber = $1 WHERE id = $2');
 
     while ($query_count--) {
@@ -186,7 +186,7 @@ $fortunes_mysql = function () use ($pool): string {
     $db = $pool->get();
 
     $fortune = [];
-    
+
     $db->fortune_test ??= $db->prepare('SELECT id, message FROM Fortune');
     $arr = $db->fortune_test->execute();
 
@@ -226,7 +226,7 @@ $updates_mysql = function (int $queries = 0) use ($pool): string {
     }
 
     $arr = [];
-    $db->updates_test_select ??= $db->prepare('SELECT randomNumber FROM World WHERE id = ?');
+    $db->updates_test_select ??= $db->prepare('SELECT id,randomNumber FROM World WHERE id = ?');
     $db->updates_test_update ??= $db->prepare('UPDATE World SET randomNumber = ? WHERE id = ?');
 
     while ($query_count--) {
@@ -318,7 +318,7 @@ class DatabasePool
     ];
 
     private $pool;
-    
+
     private $type;
 
     public function __construct($type)
@@ -326,7 +326,7 @@ class DatabasePool
         $this->server['host'] = \gethostbyname('tfb-database');
         $this->type = $type;
     }
-    
+
     public function init($capacity)
     {
         $this->pool=new \Swoole\Coroutine\Channel($capacity);
@@ -352,7 +352,7 @@ class DatabasePool
                 return $db;
             }
         }
-        
+
         return false;
     }
 

frameworks/PHP/webman/support/bootstrap/db/Raw.php

@@ -63,7 +63,7 @@ class Raw implements Bootstrap
         );
         self::$statement = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id=?');
         self::$fortune   = $pdo->prepare('SELECT id,message FROM Fortune');
-        self::$random    = $pdo->prepare('SELECT randomNumber FROM World WHERE id=?');
+        self::$random    = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id=?');
         self::$update    = $pdo->prepare('UPDATE World SET randomNumber=? WHERE id=?');
         self::$pdo = $pdo;
     }

frameworks/PHP/workerman/app.php

@@ -12,7 +12,7 @@ function init()
     );
     $statement = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id=?');
     $fortune   = $pdo->prepare('SELECT id,message FROM Fortune');
-    $random    = $pdo->prepare('SELECT randomNumber FROM World WHERE id=?');
+    $random    = $pdo->prepare('SELECT id,randomNumber FROM World WHERE id=?');
     $update    = $pdo->prepare('UPDATE World SET randomNumber=? WHERE id=?');
 }
 

frameworks/PHP/yii2/app/controllers/RawController.php

@@ -63,7 +63,7 @@ class RawController extends Controller
     {
         $queries = Query::clamp($queries);
 
-        $selectCommand = Yii::$app->db->createCommand('SELECT randomNumber FROM World WHERE id = :id');
+        $selectCommand = Yii::$app->db->createCommand('SELECT id,randomNumber FROM World WHERE id = :id');
         $updateCommand = Yii::$app->db->createCommand('UPDATE World SET randomNumber = :num WHERE id = :id');
 
         $worlds = [];

frameworks/Perl/mojolicious/app.pl

@@ -80,23 +80,23 @@ helper 'render_query' => sub {
   foreach (1 .. $q) {
     my $id = 1 + int rand 10_000;
 
-    push @queries, $self->helpers->pg->db->query_p('SELECT randomnumber FROM World WHERE id=?', $id)
+    push @queries, $self->helpers->pg->db->query_p('SELECT id,randomnumber FROM World WHERE id=?', $id)
     ->then(sub{
 	my $randomNumber = $_[0]->array->[0];
-		
+
 	return Mojo::Promise->new->resolve($id, $randomNumber)
         ->then(sub{
 	   if($update) {
 		$randomNumber = 1 + int rand 10_000;
 		return Mojo::Promise->all(
-		    Mojo::Promise->new->resolve($_[0], $randomNumber), 
+		    Mojo::Promise->new->resolve($_[0], $randomNumber),
 		    $self->helpers->pg->db->query_p('UPDATE World SET randomnumber=? WHERE id=?', $randomNumber, $id)
 		)
 		->then(sub {
 	            return $_[0];
 	        })
 	    }
-            return [shift, shift];   
+            return [shift, shift];
         })
     });
   }

frameworks/Perl/plack/app-async.psgi

@@ -6,7 +6,7 @@ use Unix::Processors;
 use List::Util qw'min max';
 
 my @dsn = ('dbi:mysql:database=hello_world;host=tfb-database;port=3306', 'benchmarkdbuser', 'benchmarkdbpass');
-my $query = 'select randomNumber from World where id = ?';
+my $query = 'select randomNumber, id from World where id = ?';
 
 sub {
     my $env = shift;

frameworks/Perl/plack/app.psgi

@@ -9,7 +9,7 @@ sub {
 	'benchmarkdbuser', 'benchmarkdbpass',
 	+{ qw'RaiseError 0 PrintError 0 mysql_enable_utf8 1' }
     ) || die $!;
-    state $sth = $dbh->prepare('select randomnumber from world where id = ?');
+    state $sth = $dbh->prepare('select id,randomnumber from world where id = ?');
     my $env = shift;
     my $path = $env->{PATH_INFO};
     return [200, [qw(Content-Type application/json)], [encode_json(+{ message => 'Hello, World!' })]] if $path eq '/json';

frameworks/Python/aiohttp/app/views.py

@@ -52,7 +52,7 @@ async def single_database_query_raw(request):
     id_ = randint(1, 10000)
 
     async with request.app['pg'].acquire() as conn:
-        r = await conn.fetchval('SELECT randomnumber FROM world WHERE id = $1', id_)
+        r = await conn.fetchval('SELECT id,randomnumber FROM world WHERE id = $1', id_)
     return json_response({'id': id_, 'randomNumber': r})
 
 
@@ -85,7 +85,7 @@ async def multiple_database_queries_raw(request):
 
     result = []
     async with request.app['pg'].acquire() as conn:
-        stmt = await conn.prepare('SELECT randomnumber FROM world WHERE id = $1')
+        stmt = await conn.prepare('SELECT id,randomnumber FROM world WHERE id = $1')
         for id_ in ids:
             result.append({
                 'id': id_,
@@ -158,7 +158,7 @@ async def updates_raw(request):
     result = []
     updates = []
     async with request.app['pg'].acquire() as conn:
-        stmt = await conn.prepare('SELECT randomnumber FROM world WHERE id = $1')
+        stmt = await conn.prepare('SELECT id,randomnumber FROM world WHERE id = $1')
         for id_ in ids:
             # the result of this is the int previous random number which we don't actually use
             await stmt.fetchval(id_)

frameworks/Python/apidaora/app.py

@@ -12,7 +12,7 @@ from typing import TypedDict, Optional
 logger = getLogger(__name__)
 
 
-READ_ROW_SQL = 'SELECT "randomnumber" FROM "world" WHERE id = $1'
+READ_ROW_SQL = 'SELECT "randomnumber", "id" FROM "world" WHERE id = $1'
 READ_ROW_SQL_TO_UPDATE = 'SELECT "id", "randomnumber" FROM "world" WHERE id = $1'
 WRITE_ROW_SQL = 'UPDATE "world" SET "randomnumber"=$1 WHERE id=$2'
 ADDITIONAL_ROW = [0, 'Additional fortune added at request time.']

frameworks/Python/apidaora/coreapp.py

@@ -17,7 +17,7 @@ from apidaora.method import MethodType
 logger = getLogger(__name__)
 
 
-READ_ROW_SQL = 'SELECT "randomnumber" FROM "world" WHERE id = $1'
+READ_ROW_SQL = 'SELECT "randomnumber", "id" FROM "world" WHERE id = $1'
 READ_ROW_SQL_TO_UPDATE = 'SELECT "id", "randomnumber" FROM "world" WHERE id = $1'
 WRITE_ROW_SQL = 'UPDATE "world" SET "randomnumber"=$1 WHERE id=$2'
 ADDITIONAL_ROW = [0, 'Additional fortune added at request time.']

frameworks/Python/blacksheep/app.py

@@ -66,7 +66,7 @@ async def single_db_query_test(request):
     row_id = randint(1, 10000)
     connection = await db_pool.acquire()
     try:
-        number = await connection.fetchval('SELECT "randomnumber" FROM "world" WHERE id = $1', row_id)
+        number = await connection.fetchval('SELECT "randomnumber", "id" FROM "world" WHERE id = $1', row_id)
         world = {'id': row_id, 'randomNumber': number}
     finally:
         await db_pool.release(connection)
@@ -86,13 +86,13 @@ async def multiple_db_queries_test(request):
 
     connection = await db_pool.acquire()
     try:
-        statement = await connection.prepare('SELECT "randomnumber" FROM "world" WHERE id = $1')
+        statement = await connection.prepare('SELECT "randomnumber", "id" FROM "world" WHERE id = $1')
         for row_id in row_ids:
             number = await statement.fetchval(row_id)
             worlds.append({'id': row_id, 'randomNumber': number})
     finally:
         await db_pool.release(connection)
-    
+
     return Response(200, content=Content(b'application/json; charset=utf-8',
                                          json_dumps(worlds).encode('utf-8')))
 
@@ -127,7 +127,7 @@ async def db_updates_test(request):
 
     connection = await db_pool.acquire()
     try:
-        statement = await connection.prepare('SELECT "randomnumber" FROM "world" WHERE id = $1')
+        statement = await connection.prepare('SELECT "randomnumber", "id" FROM "world" WHERE id = $1')
         for row_id, _ in updates:
             await statement.fetchval(row_id)
         await connection.executemany('UPDATE "world" SET "randomnumber"=$1 WHERE id=$2', updates)

frameworks/Python/fastapi/app.py

@@ -9,7 +9,7 @@ from operator import itemgetter
 from urllib.parse import parse_qs
 
 
-READ_ROW_SQL = 'SELECT "randomnumber" FROM "world" WHERE id = $1'
+READ_ROW_SQL = 'SELECT "randomnumber", "id" FROM "world" WHERE id = $1'
 WRITE_ROW_SQL = 'UPDATE "world" SET "randomnumber"=$1 WHERE id=$2'
 ADDITIONAL_ROW = [0, 'Additional fortune added at request time.']
 

frameworks/Python/quart/app.py

@@ -7,7 +7,7 @@ from quart import Quart, jsonify, make_response, request, render_template
 
 app = Quart(__name__)
 
-GET_WORLD = "select randomnumber from world where id = $1"
+GET_WORLD = "select id,randomnumber from world where id = $1"
 UPDATE_WORLD = "update world set randomNumber = $2 where id = $1"
 
 

frameworks/Python/responder/app.py

@@ -7,7 +7,7 @@ from random import randint
 from operator import itemgetter
 
 
-READ_ROW_SQL = 'SELECT "randomnumber" FROM "world" WHERE id = $1'
+READ_ROW_SQL = 'SELECT "randomnumber", "id" FROM "world" WHERE id = $1'
 WRITE_ROW_SQL = 'UPDATE "world" SET "randomnumber"=$1 WHERE id=$2'
 ADDITIONAL_ROW = [0, 'Additional fortune added at request time.']
 
@@ -119,4 +119,4 @@ def plaintext(req, resp):
 """
 if __name__ == '__main__':
     app.run()
-"""
+"""

frameworks/Python/sanic/app.py

@@ -15,7 +15,7 @@ from sanic import response
 logger = getLogger(__name__)
 
 
-READ_ROW_SQL = 'SELECT "randomnumber" FROM "world" WHERE id = $1'
+READ_ROW_SQL = 'SELECT "randomnumber", "id" FROM "world" WHERE id = $1'
 READ_ROW_SQL_TO_UPDATE = 'SELECT "id", "randomnumber" FROM "world" WHERE id = $1'
 WRITE_ROW_SQL = 'UPDATE "world" SET "randomnumber"=$1 WHERE id=$2'
 ADDITIONAL_ROW = [0, 'Additional fortune added at request time.']

frameworks/Python/starlette/app.py

@@ -10,7 +10,7 @@ from operator import itemgetter
 from urllib.parse import parse_qs
 
 
-READ_ROW_SQL = 'SELECT "randomnumber" FROM "world" WHERE id = $1'
+READ_ROW_SQL = 'SELECT "randomnumber", "id" FROM "world" WHERE id = $1'
 WRITE_ROW_SQL = 'UPDATE "world" SET "randomnumber"=$1 WHERE id=$2'
 ADDITIONAL_ROW = [0, 'Additional fortune added at request time.']
 

frameworks/Python/tornado/server_py3_uvloop.py

@@ -15,7 +15,7 @@ from tornado.options import options
 
 options.define('port', default=8080, type=int, help="Server port")
 
-READ_ROW_SQL = 'SELECT "randomnumber" FROM "world" WHERE id = $1'
+READ_ROW_SQL = 'SELECT "randomnumber", "id" FROM "world" WHERE id = $1'
 WRITE_ROW_SQL = 'UPDATE "world" SET "randomnumber"=$1 WHERE id=$2'
 ADDITIONAL_ROW = [0, 'Additional fortune added at request time.']
 

frameworks/Python/uvicorn/app.py

@@ -19,7 +19,7 @@ async def setup():
     )
 
 
-READ_ROW_SQL = 'SELECT "randomnumber" FROM "world" WHERE id = $1'
+READ_ROW_SQL = 'SELECT "randomnumber", "id" FROM "world" WHERE id = $1'
 WRITE_ROW_SQL = 'UPDATE "world" SET "randomnumber"=$1 WHERE id=$2'
 ADDITIONAL_ROW = [0, 'Additional fortune added at request time.']