Filter non-IO methods

Author: twose

src/core/Database/MysqliProxy.php

@@ -49,8 +49,13 @@ public function __construct(callable $constructor)
     public function __call(string $name, array $arguments)
     {
         for ($n = 3; $n--;) {
+            $this->__object->errno = 0;
             $ret = @$this->__object->{$name}(...$arguments);
             if ($ret === false) {
+                /* no error */
+                if ($this->__object->errno === 0) {
+                    break;
+                }
                 /* no more chances or non-IO failures */
                 if (
                     !in_array($this->__object->errno, static::IO_ERRORS, true) ||

src/core/Database/MysqliStatementProxy.php

@@ -49,8 +49,13 @@ public function __construct(mysqli_stmt $object, ?string $queryString, MysqliPro
     public function __call(string $name, array $arguments)
     {
         for ($n = 3; $n--;) {
+            $this->__object->errno = 0;
             $ret = @$this->__object->{$name}(...$arguments);
             if ($ret === false) {
+                /* no error */
+                if ($this->__object->errno === 0) {
+                    break;
+                }
                 /* no more chances or non-IO failures or in transaction */
                 if (
                     !in_array($this->__object->errno, $this->parent::IO_ERRORS, true) ||

src/core/Database/PDOProxy.php

@@ -17,6 +17,7 @@
 
 class PDOProxy extends ObjectProxy
 {
+    public const IO_METHOD_REGEX = '/^query|prepare|exec|beginTransaction|commit|rollback$/i';
     public const IO_ERRORS = [
         2002, // MYSQLND_CR_CONNECTION_ERROR
         2006, // MYSQLND_CR_SERVER_GONE_ERROR
@@ -47,8 +48,12 @@ public function __call(string $name, array $arguments)
         for ($n = 3; $n--;) {
             $ret = @$this->__object->{$name}(...$arguments);
             if ($ret === false) {
-                /* no more chances or non-IO failures */
+                /* non-IO method */
+                if (!preg_match(static::IO_METHOD_REGEX, $name)) {
+                    break;
+                }
                 $errorInfo = $this->__object->errorInfo();
+                /* no more chances or non-IO failures */
                 if (
                     !in_array($errorInfo[1], static::IO_ERRORS, true) ||
                     $n === 0 ||

src/core/Database/PDOStatementProxy.php

@@ -54,6 +54,10 @@ public function __call(string $name, array $arguments)
         for ($n = 3; $n--;) {
             $ret = @$this->__object->{$name}(...$arguments);
             if ($ret === false) {
+                /* no IO */
+                if (strtolower($name) !== 'execute') {
+                    break;
+                }
                 /* no more chances or non-IO failures or in transaction */
                 if (
                     !in_array($this->__object->errorInfo()[1], $this->parent::IO_ERRORS, true) ||