Set affected_rows for queries

Author: givanz

system/db/pgsql.php

@@ -201,6 +201,10 @@ public function query($sql, $parameters = []) {
 				throw new \Exception($errorMessage);
 			}
 
+			if ($result) {
+				$this->affected_rows = @pg_affected_rows($this->last_res);
+			}
+
 			return $this->last_res;
 		} catch (\Exception $e) {
 			$message = $e->getMessage() . "\n$sql\n";
@@ -297,6 +301,10 @@ public function execute($sql, $params = [], $paramTypes = []) {
 			//$this->last_res = pg_get_result(self :: $link);
 		}
 
+		if ($this->last_res) {
+			$this->affected_rows = @pg_affected_rows($this->last_res);
+		}
+
 		if ($this->last_res == false) {
 			error_log('pgsql error: ' . pg_result_error($this->last_res) . pg_last_error(self :: $link));
 			error_log($this->debugSql($origSql, $params, $paramTypes));