Unbuffered queries in PDO

git-svn-id: https://adminer.svn.sourceforge.net/svnroot/adminer/trunk@1184 7c3ca157-0c34-0410-bff1-cbf682f78f5c

diff --git a/adminer/include/mysql.inc.php b/adminer/include/mysql.inc.php
index ac78e6f64b8390f37fdd244d65f0f4e74beb0e56..eaf985121048ea3cfe8081c6e6141942f0e49550 100644 (file)
--- a/adminer/include/mysql.inc.php
+++ b/adminer/include/mysql.inc.php
@@ -132,6 +132,11 @@ if (extension_loaded("mysqli")) {
                        $this->server_info = $this->result($this->query("SELECT VERSION()"));
                        return true;
                }
+               
+               function query($query, $unbuffered = false) {
+                       $this->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, !$unbuffered);
+                       return parent::query($query, $unbuffered);
+               }
        }
        
 } else {

diff --git a/adminer/include/pdo.inc.php b/adminer/include/pdo.inc.php
index 2b6e451e179964eac0a20f40940d1a10f52d0608..f62c7cd2c68f71990f7fd4b7016163c9d8adea15 100644 (file)
--- a/adminer/include/pdo.inc.php
+++ b/adminer/include/pdo.inc.php
@@ -19,7 +19,7 @@ if (extension_loaded('pdo')) {
                        return $this->query("USE " . idf_escape($database));
                }
                
-               function query($query) { // $unbuffered is not supported
+               function query($query, $unbuffered = false) {
                        $result = parent::query($query);
                        if (!$result) {
                                $errorInfo = $this->errorInfo();