mirror/processwire
1
0
Fork 0
mirror of https://github.com/processwire/processwire.git synced 2025-08-11 17:24:46 +02:00
Code Issues Releases Wiki Activity

Update WireDatabasePDO::pdoType() to fix issue in reader/writer detection when query had leading whitespace or newlines in unexpected locations

Browse Source
This commit is contained in:
Ryan Cramer
2021-09-10 08:57:09 -04:00
parent d78276e2c2
commit 70ff49dfc4
1 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
wire/core/WireDatabasePDO.php
View File

@@ -526,31 +526,36 @@ class WireDatabasePDO extends Wire implements WireDatabase {
/**
* Return correct PDO instance type (reader or writer) based on given statement
*
* @param string|\PDOStatement $statement
* @param string|\PDOStatement $query
* @param bool $getName Get name of PDO type rather than instance? (default=false)
* @return \PDO|string
*
*/
protected function pdoType(&$statement, $getName = false) {
protected function pdoType(&$query, $getName = false) {
$reader = 'reader';
$writer = 'writer';
if(!$this->reader['has']) return $getName ? $writer : $this->pdoWriter();
if(!$this->reader['has'] || !is_string($query)) {
// no reader available or query is PDOStatement, or other: always return writer
// todo support for inspecting PDOStatement?
return $getName ? $writer : $this->pdoWriter();
}
// statement is just first 40 characters of query
$statement = trim(str_replace(array("\n", "\t", "\r"), " ", substr($query, 0, 40)));
if($statement === $writer || $statement === $reader) {
// reader or writer requested by name
$type = $statement;
} else if(!$this->reader['has']) {
$type = $writer;
} else if(!is_string($statement)) {
// PDOStatement or other, always return write
// @todo add support for inspection of PDOStatement
$type = $writer;
} else if(stripos($statement, 'select') === 0) {
// select query is always reader
$type = $reader;
} else if(stripos($statement, 'insert') === 0) {
// insert query is always writer
$type = $writer;
} else {
// other query to inspect further
$pos = strpos($statement, ' ');
$word = strtolower(($pos ? substr($statement, 0, $pos) : $statement));
if($word === 'set') {