PHP: Как я могу проверить ошибки во время фиксации mysqli? - PullRequest
Новая
       7

PHP: Как я могу проверить ошибки во время фиксации mysqli?

4 голосов
/ 28 февраля 2010

Я вставляю много записей, используя оператор фиксации mysqli, используя этот код из http://www.php.net/manual/en/mysqli.commit.php#88857. Затем я проверяю затронутые строки, используя: $ Mysqli-> affected_rows но даже если все записи были вставлены, я получаю ноль затронутых строк.

Как я могу проверить, когда произошел сбой фиксации, и получить ошибку? Спасибо

Ответы [ 2 ]

9 голосов
/ 28 февраля 2010

Вы можете сделать что-то вроде этого: 

mysqli_autocommit($dbconn, FALSE);

$errors = array();

if (!$mysqli->query(/* some SQL query */)) {
    $errors[] = $mysqli->error;
}
// ... more queries like the above
if(count($errors) === 0) {
    $mysqli->commit()
} else {
    $mysqli->rollback();
    print_r($errors);
}

Когда запрос идет не так, он добавляет ошибку в массив $ errors, чтобы вы знали, что пошло не так. Вы также можете добавить ключи с идентификаторами для запросов, чтобы вы знали, какой запрос пошел не так.

Для лучшей обработки вы можете написать UnitOfWork класс для этого: 

class UnitOfWork
{
    protected $_db;
    protected $_errors;
    protected $_queries;
    public function __construct($db) {
        $this->_db = $db;
        $this->_errors = array();
        $this->_queries = array();
    }
    public function addQuery($id, $sql) {
        $this->_queries[$id] = $sql;
        return $this;
    }
    public function getErrors() {
        return $this->_errors;
    }    
    public function try() {
        $this->_db->autocommit($this->_db, FALSE);
        foreach($this->_queries as $id => $query) {
            if ($this->_db->query($query) === FALSE) {
                $this->_errors[$id] = $this->_db->error;
            }
        }
        $hasErrors = count($this->_errors);
        ($hasErrors) ? $this->_db->rollback() : $this->_db->commit();
        $this->_db->autocommit($this->_db, TRUE);
        return !$hasErrors; // return true on success
    }
}

и вы можете использовать его как 

$unit = new UnitOfWork($mysqli);
$unit->addQuery('foo', 'SELECT foo FROM somewhere')
     ->addQuery('bar', 'SELECT bar FROM somewhereElse')
     ->addQuery('baz', 'SELECT baz WITH brokenQuery');

if($unit->try() === FALSE) {
    print_r($unit->getErrors());
}
4 голосов
/ 28 февраля 2010

mysqli::affected_rows вернет количество строк, затронутых последней операцией MySQL.

Если вы делаете что-то вроде этого (псевдокод): 

$db->query("insert ...");
$db->query("insert ...");
$db->query("insert ...");
$db->commit();
$num = $db->affected_rows();

Вы не получите количество вставленных строк: инструкция commit является последней выполненной и не «влияет» ни на одну строку.


Если вы хотите узнать, будет ли mysqli::commit успешным или нет, вы должны проверить, что это возвращаемое значение (цитирование) :

Возвращает TRUE в случае успеха или FALSE в случае отказ.

Если он вернул true, то все ваши предыдущие вставки, начиная с начала текущей транзакции, будут зафиксированы.


И если произошла ошибка, вы можете использовать mysqli::errno и / или mysqli::error, чтобы получить информацию о ней.

...