protected function execSQL($sql)
    {
        // Check and ignore empty statements
        if (trim($sql) == "") {
            return;
        }

        try {
            $this->totalSql++;

            if (!$this->autocommit) {
                $this->conn->beginTransaction();
            }

            $stmt = $this->conn->prepare($sql);
            $this->log(sprintf('    Executing statement "%s"', $sql), Project::MSG_VERBOSE);
            $stmt->execute();
            $this->log(sprintf('    %d rows affected', $stmt->rowCount()), Project::MSG_VERBOSE);

            if (!$this->autocommit) {
                $this->conn->commit();
            }

            $this->goodSql++;
        } catch (PDOException $e) {
            $this->log("Failed to execute: " . $sql, Project::MSG_ERR);
            if ($this->onError != "continue") {
                throw $e;
            }
            $this->log($e->getMessage(), Project::MSG_ERR);
        }
    }
protected function execSQL($sql)
    {
        // Check and ignore empty statements
        if (trim($sql) == "") {
            return;
        }

        try {
            $this->totalSql++;

            if (!$this->autocommit) {
                $this->conn->beginTransaction();
            }

            $stmt = $this->conn->prepare($sql);
            $this->log(sprintf('    Executing statement "%s"', $sql), Project::MSG_VERBOSE);
            $stmt->execute();
            $this->log(sprintf('    %d rows affected', $stmt->rowCount()), Project::MSG_VERBOSE);

            if (!$this->autocommit) {
                $this->conn->commit();
            }

            $this->goodSql++;
        } catch (PDOException $e) {
            $this->log("Failed to execute: " . $sql, Project::MSG_ERR);
            if ($this->onError != "continue") {
                throw $e;
            }
            $this->log($e->getMessage(), Project::MSG_ERR);
        }
    }
protected function execSQL ( $ sql ) { // Check and ignore empty statements if ( trim ( $ sql ) == "" ) { return ; } try { $ this -> totalSql ++ ; if ( ! $ this -> autocommit ) { $ this -> conn -> beginTransaction ( ) ; } $ stmt = $ this -> conn -> prepare ( $ sql ) ; $ this -> log ( sprintf ( '    Executing statement "%s"' , $ sql ) , Project :: MSG_VERBOSE ) ; $ stmt -> execute ( ) ; $ this -> log ( sprintf ( '    %d rows affected' , $ stmt -> rowCount ( ) ) , Project :: MSG_VERBOSE ) ; if ( ! $ this -> autocommit ) { $ this -> conn -> commit ( ) ; } $ this -> goodSql ++ ; } catch ( PDOException $ e ) { $ this -> log ( "Failed to execute: " . $ sql , Project :: MSG_ERR ) ; if ( $ this -> onError != "continue" ) { throw $ e ; } $ this -> log ( $ e -> getMessage ( ) , Project :: MSG_ERR ) ; } }
Execute a SQL statement using the current connection property.

@param string $sql SQL statement to execute

@throws PDOException
Execute a SQL statement using the current connection property .