classes/phing/tasks/ext/pdo/PDOSQLExecTask.php
protected function execSQL($sql)
    {
        // Check and ignore empty statements
        if (trim($sql) == "") {
            return;
        }

        try {
            $this->totalSql++;

            $this->statement = $this->conn->query($sql);
            $this->log($this->statement->rowCount() . " rows affected", Project::MSG_VERBOSE);

            // only call processResults() for statements that return actual data (such as 'select')
            if ($this->statement->columnCount() > 0) {
                $this->processResults();
            }

            $this->statement->closeCursor();
            $this->statement = null;

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

        try {
            $this->totalSql++;

            $this->statement = $this->conn->query($sql);
            $this->log($this->statement->rowCount() . " rows affected", Project::MSG_VERBOSE);

            // only call processResults() for statements that return actual data (such as 'select')
            if ($this->statement->columnCount() > 0) {
                $this->processResults();
            }

            $this->statement->closeCursor();
            $this->statement = null;

            $this->goodSql++;
        } catch (PDOException $e) {
            $this->log("Failed to execute: " . $sql, Project::MSG_ERR);
            if ($this->onError != "continue") {
                throw new BuildException("Failed to execute SQL", $e);
            }
            $this->log($e->getMessage(), Project::MSG_ERR);
        }
    }
protected function execSQL ( $ sql ) { // Check and ignore empty statements if ( trim ( $ sql ) == "" ) { return ; } try { $ this -> totalSql ++ ; $ this -> statement = $ this -> conn -> query ( $ sql ) ; $ this -> log ( $ this -> statement -> rowCount ( ) . " rows affected" , Project :: MSG_VERBOSE ) ; // only call processResults() for statements that return actual data (such as 'select') if ( $ this -> statement -> columnCount ( ) > 0 ) { $ this -> processResults ( ) ; } $ this -> statement -> closeCursor ( ) ; $ this -> statement = null ; $ this -> goodSql ++ ; } catch ( PDOException $ e ) { $ this -> log ( "Failed to execute: " . $ sql , Project :: MSG_ERR ) ; if ( $ this -> onError != "continue" ) { throw new BuildException ( "Failed to execute SQL" , $ e ) ; } $ this -> log ( $ e -> getMessage ( ) , Project :: MSG_ERR ) ; } }
Exec the sql statement.

@param $sql

@throws BuildException
@throws Exception
Exec the sql statement .