include_path = ".;C:\PHPLib\odataphp"

   ;OData SDK for PHP Library Path

   ODataphp_path = "C:\PHPLib\odataphp"         

   yum install php-xml

[Date]
;Defines the default timezone used by the date functions
date.timezone = America/Los_Angeles

php <path of Client Libary>PHPDataSvcUtil.php /uri=<data service Uri> | /metadata=<service metadata file>  [/out=<output file path>] [/auth=windows|acs /u=username /p=password [/sn=servicenamespace /at=applies_to] ] [/ph=proxy-host /pp=proxy-port [/pu=proxy-user /ppwd=proxy-password] [/ups=yes|no] ]

C:\PHPLib\ odataphp>php PHPDataSvcUtil.php /uri=http://localhost:13986/NorthWindDataServices.svc /out=D: \samples\SimpleApplication

C:\PHPLib\ odataphp>php PHPDataSvcUtil.php

/metadata=D: \samples\SimpleApplication\NorthWindMeta.xml /out=D: \samples\SimpleApplication

C:\PHPLib\ odataphp>php PHPDataSvcUtil.php

/uri=http://netflix.cloudapp.net/catalog.svc /out=D: \samples\SimpleApplication /ph=itgproxy.redmond.corp.microsoft.com /pp=80

C:\PHPLib\ odataphp>php PHPDataSvcUtil.php

/uri= http://mflasko-dev/_vti_bin/listdata.svc /out=D: \samples\SimpleApplication /auth=windows /u=redmond\odphp /p=passw0rd!

C:\PHPLib\ odataphp>php PHPDataSvcUtil.php

/uri= http://localhost:13985/ACSNorthWindDataService.svc /out=D: \samples\SimpleApplication /auth=acs /u=infocorp /p=qfimKj6Vm6HKAJryTRno5USPpvz0c8bBzFhlqKex6lQ= /sn=wcfdataservice /at=http://localhost/WCFNorthWindService/ /ups=no /ph=itgproxy.redmond.corp.microsoft.com /pp=80

[Data service Url]

/uri=http://localhost:13985/ACSNorthWindDataService.svc/

 

[Out Directory]

/out= D: \samples\SimpleApplication

 

[ACS Auth Information]

/auth=acs

/u=infocorp

;Note that issuer key should be inside double quotes as it contain '=' symbol

/p="qfimKj6Vm6HKAJryTRno5USPpvz0c8bBzFhlqKex6lQ="

/sn=wcfdataservice

/at=http://localhost/WCFNorthWindService/

 

[Proxy Settings to acess ACS]

/ph=itgproxy.redmond.corp.microsoft.com

/pp=80

 

[Want to use the above proxy for getting metadata]

; No because the service is running locally

/ups=no

C:\PHPLib\ odataphp>php PHPDataSvcUtil.php  /config=D:/myApp/settings.ini

require_once 'MyProxyClass.php';

$proxy = new NorthwindEntities();

$response = $proxy->Execute(“Customers(‘ALFKI’)”);

$customer = $response->Result[0];

echo ($customer->CompanyName);

try

{

   //customer ALFKI with related sales orders

   $query = new DataServiceQuery(‘Customers’, $proxy)

                ->Filter(“CustomerID eq ‘ALFKI’”)

                ->Expand(‘Orders’);

   $response = $query->Execute();

   $customer = $response->Result[0];

   echo count($customer-Orders);

 

   //In the proxy class, for each entity set, there will be one function (with name same as name of entity set) that returns DataServiceQuery object for that particular entity set.

   //customer ALFKI with related sales orders and employee information related to those orders

   $response = $proxy->Customers()

                        ->Filter( “CustomerID eq ‘ALFKI’”)
                        ->Expand(‘Orders/Employees’)
                        ->Execute();

   $customer = $response->Result[0]

   echo count($customer->Orders(10248)->Employees);

 

  //Orders entity with id 10248 with related employees information and related shipper information

  $response = $proxy->Orders()

                       ->Filter( ‘OrderID eq 10248’)

                       ->Expand(‘Employees,Shippers’)->Execute();

  $order = $response->Result[0];

  echo count($order->Employees(5)->Shippers);

  echo count($order->Employees);

}

catch(DataServiceRequestException $exception)

{

  echo $exception->Response->getError(); 

}

$query = new DataServiceQuery(‘Customers’, $proxy)

                ->Filter(“CustomerID eq ‘ALFKI’”)

                ->Expand(‘Orders’);

$response = $query->Execute();

 $response = $proxy->Execute(“Customers(‘ALFKI’)?/$expand=Orders”);

try

{

  //all customers in London

  $response = $proxy->Customers()

                        ->Filter( “City eq ‘London’”)

                        ->Execute();

  $customers = $response->Result;

 

}

catch(DataServiceRequestException $exception)

{

   echo $exception->Response->getError(); 

}

try

{

    $response = $proxy->Customers()->OrderBy(‘City’)->Execute();

    $customers = $response->Result;

    $response = $proxy->Customers()->OrderBy(‘City desc’)->Execute();

    $customers = $response->Result;

    $response = $proxy->Customers()->OrderBy(‘City desc,CompanyName asc’)->Execute();

    $customers = $response->Result;

}

catch(DataServiceRequestException $exception)

{

    echo $exception->Response->getError(); 

}

 

try

{

   //return all customers except the first 10

   $response = $proxy->Customers()->Skip( ‘10’)->Execute();

   $customers = $response->Result;

 

   //return the 4th page, in 10-row pages

   $response = $proxy->Customers()
                         ->Skip(‘30’)
                         ->Top(‘10’)
                         ->Execute();

   $customers = $response->Result;

}

catch(DataServiceRequestException $exception)

{

   echo $exception->Response->getError(); 

}

try

{

   //top 5 sales orders

   $response = $proxy->Orders()->Top(‘5’)->Execute();

   $orders = $response->Result;

 

   //top 5 sales orders with the highest TotalDue

   $response = $proxy->Orders()
                         ->Orderby(‘TotalDue’) 
                         ->Top(‘5’)
                         ->Execute();

   $sorders = $response->Result;

}

catch(DataServiceRequestException $exception)

{

   echo $exception->Response->getError(); 

}

try

{

  //all customers in London

  $response = $proxy->Customers()

                        ->Filter(“City eq ‘London’”)

                        ->IncludeTotalCount()
                        ->Execute();

  $customers = $response->Result;

  echo ‘Total Number of Customers:’. $response->TotalCount();

  echo ‘Number of Customers in London:’ . count($customers);

}

catch(DataServiceRequestException $exception)

{

  echo $exception->Response->getError(); 

}

try

{

  //all customers in London

  $query = $proxy->Customers()

                     ->Filter(“City eq ‘London’”);                       

  echo ‘Number of Customers with Lodon as City:’ . $query->Count();

}

catch(DataServiceRequestException $exception)

{

   echo $exception->Response->getError(); 

}

try

{

     $svc = new NorthwindEntities();

     $query = $svc->Customers()->filter("Country eq 'USA'")

                               ->Select('CustomerID,CompanyName');

     $customersResponse = $query->Execute();

    

     foreach($customersResponse->Result as $customer)

     {

         echo "CustomerID:" . $customer->CustomerID . "<br/>";

         echo "Company Name:" . $customer->CompanyName . "<br/>";

         echo "Country:" .$customer->Country . "(This will be null as we selected only CustomerID and CompanyName)" . "<br/>";

         echo "----------" . "<br/>";

     }

}

catch(DataServiceRequestException $ex)

{

        echo 'Error: while running the query ' . $ex->Response->getQuery();

        echo "<br/>";

        echo $ex->Response->getError();

}

try

{

     $svc = new NorthwindEntities(NORTHWIND_SERVICE_URL);

 

     $query = $svc->Customers()->Filter(”Country eq 'USA'”);

     $customersResponse = $query->Execute();

    

     echo "CustomerID" . "<br/>";

     echo "----------" . "<br/>";

 

     $nextCustomerToken = null;

    

     do

     {

        if($nextCustomerToken != null)

        {

            $customersResponse = $svc->Execute($nextCustomerToken);

        }

 

        foreach($customersResponse->Result as $customer)

        {

             echo $customer->CustomerID . "<br/>";

        }

 

     }while(($nextCustomerToken = $customersResponse->GetContinuation()) != null);

 

}

catch(DataServiceRequestException $exception)

{

    echo $exception->Response->getError(); 

}

try

{

     $svc = new NorthwindEntities(NORTHWIND_SERVICE_URL);

    

     $query = $svc->Customers()

                     ->Filter(”Country eq 'USA'”)

                     ->Expand('Orders');

 

     $customerResponse = $query->Execute();

 

     $nextCustomerToken = null;

     do

     {

 

        if($nextCustomerToken != null)

        {

            $customerResponse = $svc->Execute($nextCustomerToken);

        }

 

        foreach($customerResponse->Result as $customer)

        {

             echo '<br/>CustomerID: ' . $customer->CustomerID . "<br/>";

 

             $nextOrderToken = null;

             $firstTime = true;

             $ordersResponse;

 

             echo "<br/>Associcated Orders <br/>";

             echo "-----------------------<br/>";

             

             do

             {

                $orders = array();

                if(!$firstTime)

                {

                    $ordersResponse = $svc->Execute($nextOrderToken);

                    $orders = $ordersResponse->Result;

                    $nextOrderToken = $ordersResponse->GetContinuation();

                }

 

                if($firstTime)

                {

                    $orders = $customer->Orders;

                    $nextOrderToken = $customerResponse->GetContinuation($customer->Orders);

                    $firstTime = false;

                }

 

                foreach($orders as $order)

                {

                     echo "     " . $order->OrderID . "<br/>";

                }

 

             }while($nextOrderToken != null);

        }

 

     }while(($nextCustomerToken = $customerResponse->GetContinuation()) != null);

 

}

catch(DataServiceRequestException $exception)

{

    echo $exception->Response->getError(); 

}

  try

  {

       $svc = new NorthwindEntities(NORTHWIND_SERVICE_URL);

   

       $query = $svc->Customers()->Filter(”Country eq 'USA'”);

       $customerResponse = $query->Execute();

   

       $nextCustomerToken = null;

     do

     {

        if($nextCustomerToken != null)

        {

            $customerResponse = $svc->Execute($nextCustomerToken);

        }

 

        foreach($customerResponse->Result as $customer)

        {

             echo '<br/>CustomerID: ' . $customer->CustomerID . "<br/>";

             $nextOrderToken = null;

 

             echo "<br/>Assoicated Orders <br/>";

             echo "-----------------------<br/>";

             do

             {

                $ordersResponse = $svc->LoadProperty($customer, 'Orders', $nextOrderToken);

 

                foreach($customer->Orders as $order)

                {

                    echo "     " . $order->OrderID . "<br/>";

                }     

             }while(($nextOrderToken = $ordersResponse->GetContinuation()) != null);            

        }

 

     }while(($nextCustomerToken = $customerResponse->GetContinuation()) != null);

 

}

catch(DataServiceRequestException $exception)

{

    echo $exception->Response->getError(); 

}

 

require_once 'MyProxyClass.php';

try

{

   $proxy = new NorthwindEntities();

 

  //Create a Customer php Object 

   $customer = Customers::CreateCustomers("CHAN9", "channel9");

 

   //inserting Customers object context tracking system 

   $proxy->AddObject(‘Customers’, $customer);

 

   //SaveChange insert the object into data service

   $proxy->SaveChanges();

}

catch(ODataServiceException $exception)

{

   Echo $exception->getError();

}

require_once 'MyProxyClass.php';

try

{

    $proxy = new NorthwindEntities();

    $response = $proxy->Execute (“Customers(‘CHAN9’));

    $customer = $response->Result[0];

 

    //update the CompanyName property

    $customer->CompanyName = "Channel8";

 

    //add the object to the list of objects that needs to be updated in the database

    $proxy->UpdateObject($customer);

 

    //SaveChanges updates the object in the data service

    $proxy->SaveChanges();

}

catch(DataServiceRequestException $e)

{

   echo $exception->Response->getError();

}

catch(ODataServiceException $exception)

{

   echo $exception->getError();

}

 

require_once 'MyProxyClass.php';

 

try

{

    $proxy = new NorthwindEntities();

 

    $response = $proxy->Execute (“Customers(‘CHAN9’));

    $customer = $response->Result[0];

 

    //The object is added to the list of objects to delete in the database

    $proxy->DeleteObject($customer);

 

    //SaveChanges persists the changes in the database 

    $proxy->SaveChanges();

}

catch(DataServiceRequestException $exception)

{

   echo $exception->Response->getError();

}

catch(ODataServiceException $exception)

{

   echo $exception->getError();

}

 

require_once 'MyProxyClass.php';

 

try

{

    $proxy = new NorthwindEntities();

 

   //Create a Customers instance 

   $customer = new Customers();

   $customer ->CustomerID = 'CHAN9';

   $customer ->CompanyName = 'channel9';

   $proxy->AddToCustomers($customer);

 

   //Create an Orders instance

   $Order = new Orders();

 

   //Create link between Customer and Order.

   $proxy->AddLink($cust, "Orders", $Order);

   $proxy->SaveChanges();

}

catch(ODataServiceException $exception)

{

   echo $exception->getError();

}

require_once 'MyProxyClass.php';

 

try

{

    $proxy = new NorthwindEntities();

 

    //Retrive the Customers entity and related orders with key ‘CHAN9’ 

    $response = $proxy->Customers()
                          ->Filter(”CustomerID eq ’CHAN9’”)

                          ->Expand(‘Orders’)

                          ->Execute();

    $customers = $response->Result;

    foreach($customers as $customer)

    {

        foreach($customer->Orders as $o)

        {

            $proxy->DeleteLink($customer, "Orders", $o);

        }

    }

 

    $proxy->SaveChanges();

}

catch(DataServiceRequestException $exception)

{

   echo $exception->Response->getError();

}

catch(ODataServiceException $exception)

{

   echo $exception->getError();

}

require_once 'MyProxyClass.php';

 

try

{

    $proxy = new NorthwindEntities();

 

    //Get the specific product

    $productResponse = $proxy->Products()->Filter('ProductID eq 1')->Execute(); 

  
    //Get the specific Order instance

    $orderResponse = $proxy->Orders() ->Filter('OrderID eq 10248) ->Execute();

    $product = $productResponse->Result[0];
    $order = $orderResponse->Result[0];

   ///Create a new order detail for the specific product.

    $newItem = Order_Details::CreateOrder_Details(0, $order->OrderID, $product->ProductID, 10, 5);

    $proxy->AddToOrder_Details(newItem);

    //Set reference links for the many-to-one relationships.
    $proxy->SetLink(newItem, "Orders", $order);
    $proxy->SaveChanges()

}o:p>

catch(ODataServiceException $exception)

{

   echo $exception->getError();

}

require_once 'TeamSiteDataContext.php';

 

try

    {

        $queryResponse = $context->SharedDocuments()->Execute();

        $sharedDocItem = $queryResponse->Result[0];

        $responseStream = $context->GetReadStream($sharedDocItem);

        $stream = $responseStream->getStream();

 

        if (!$handle = fopen("download.xlsx", 'wb'))

        {

            echo "Cannot open file for writing output";

            exit;

        } 

        if (fwrite($handle, $stream) === FALSE)

        {

            echo "Cannot write to file";

            exit;

        }       

        fclose($handle);

    }

    catch (ODataServiceException $e)

    {       

        echo $e->getDetailedError()

        echo $e->getError();

    }

    catch(DataServiceRequestException $e)

    {

        echo $e->Response->getError();

    }

require_once 'TeamSiteDataContext.php';

 

try

    {       

        $stream = null;

        if (!$handle = fopen("WSR.docx", 'rb'))

        {

            echo "Cannot open file for reading  ";

            exit;

        }                  

       
        if (($stream = fread($handle, filesize("WSR.docx"))) === FALSE)

        {

            echo "Cannot read to file";

            exit;

        }                

       
        $doc = new SharedDocumentsItem();

        //make sure that WSR.docx is present in current working directory

        $doc->Name = "WSR1.docx";

        $doc->ContentType = ContentType::MS_OFFICE_DOCX;

        $context->AddToSharedDocuments($doc);

 

        $context->SetSaveStream($doc,

                                $stream,

                                false,

                                ContentType::MS_OFFICE_DOCX,

                                "/Shared Documents/WSR2.docx");

                           

        $context->SaveChanges(); 

    }

    catch (ODataServiceException $e)

    {      

        echo $e->getDetailedError();

        echo $e->getError();

    }

    catch(DataServiceRequestException $e)

    {

        echo $e->Response->getError();

    }

$proxy->Credential = new AzureTableCredential(account-name, account-key); 

require_once 'Context/ObjectContext.php';

define AZURE_SERVICE_URL(“http://<Account>.table.core.windows.net”);

define AZURE_ACCOUNT_NAME(specify your account name here);

define AZURE_ACCOUNT_KEY(specify your account key here);

 

try

{

    $svc = new ObjectContext(AZURE_SERVICE_URL);

    //specify azure credentials

    $svc->Credential = new AzureTableCredential(AZURE_ACCOUNT_NAME, AZURE_ACCOUNT_KEY);      

    //Create a table entity and add it to the context

    $table = new Tables();

    $table->TableName = ‘Employees’;   

    $svc->AddObject(‘Tables’, $table);

    $svc->SaveChanges();

}

catch(ODataServiceException $e)

{

   echo $e->getError();

}

require_once 'Context/ObjectContext.php';

define AZURE_SERVICE_URL(“http://<Account>.table.core.windows.net”);

define AZURE_ACCOUNT_NAME(specify your account name here);

define AZURE_ACCOUNT_KEY(specify your account key here);

 

/**

 *@Class:Employees

 *@Key:PartitionKey

 *@Key:RowKey

 */

class Employees extends TableEntry

{

    /**

     *@Type:EntityProperty

     */

     Public $Name;

  

    /**

     *@Type:EntityProperty

     */

     Public $Age;

 

   /**

     *@Type:EntityProperty

     */

     Public $Visible;   

}

 

try

{

    $svc = new ObjectContext(AZURE_SERVICE_URL);

    //specify azure credentials

    $svc->Credential = new AzureTableCredential(AZURE_ACCOUNT_NAME, AZURE_ACCOUNT_KEY);

    

    //Create a employees entity and add it to the context

    $tableEntity = new Employees();

    $tableEntity->PartitionKey = ‘Partition1’;

    $tableEntity->RowKey = ‘Row1’;

    $tableEntity->Name = ‘ALKFI’;

    $tableEntity->Age = 26;

    $tableEntity->Visible = true;

    $svc->AddObject(‘Employees’, $tableEntity);

    $svc->SaveChanges();

}

catch(ODataServiceException $e)

{

   echo $e->getError();

}

require_once 'Context/ObjectContext.php';

define AZURE_SERVICE_URL(“http://<Account>.table.core.windows.net”);

define AZURE_ACCOUNT_NAME(specify your account name here);

define AZURE_ACCOUNT_KEY(specify your account key here);

 

/**

 *@Class:Employees

 *@Key:PartitionKey

 *@Key:RowKey

 */

class Employees extends TableEntry

{

    /**

     *@Type:EntityProperty

     */

     Public $Name;

  

    /**

     *@Type:EntityProperty

     */

     Public $Age;

 

   /**

     *@Type:EntityProperty

     */

     Public $Visible;

 

    /**

     *@Type:EntityProperty

     */

     Public $Address;   

  

}

 

try

{

    $svc = new ObjectContext(AZURE_SERVICE_URL);

    //specify azure credentials

    $svc->Credential = new AzureTableCredential(AZURE_ACCOUNT_NAME, AZURE_ACCOUNT_KEY);

    //Create query object to fetch the record

    $query = new DataServiceQuery(‘Employees’, $svc);

    $response = $query-> Filter( “Name eq ’ALFKI’”)->Execute();

    $tableEntity = $response->Result[0];

 

    //Update the table entry by adding Address Property

    $tableEntity->Address = ‘Line No1’;

   

    $svc->UpdateObject($tableEntity);

    $svc->SaveChanges();

}

catch(ODataServiceException $e)

{

   echo $e->getError();

}

catch(DataServiceRequestException $e)

{

   echo $e->Response->getError();

}

require_once 'Context/ObjectContext.php';

define AZURE_SERVICE_URL(“http://<Account>.table.core.windows.net”);

define AZURE_ACCOUNT_NAME(specify your account name here);

define AZURE_ACCOUNT_KEY(specify your account key here);

 

/**

 *@Class:Employees

 *@Key:PartitionKey

 *@Key:RowKey

 */

class Employees extends TableEntry

{

    /**

     *@Type:EntityProperty

     */

     Public $Name;

  

    /**

     *@Type:EntityProperty

     */

     Public $Age;

 

   /**

     *@Type:EntityProperty

     */

     Public $Visible;

  

}

 

try

{

    $svc = new ObjectContext(AZURE_SERVICE_URL);

    //Set ReplaceOnUpdate flag true

    $svc->ReplaceOnUpdate(true);

 

    //specify azure credentials

    $svc->Credential = new AzureTableCredential(AZURE_ACCOUNT_NAME, AZURE_ACCOUNT_KEY);

    //Create query object to fetch the record

    $query = new DataServiceQuery(‘Employees’, $svc);

    $response = $query->Filter(“Name eq ’ALFKI’”)->Execute();

    $tableEntity = $response->Result[0];

 

    //Update the table entry    

    $svc->UpdateObject($tableEntity);

    $svc->SaveChanges();

}

catch(ODataServiceException $e)

{

   echo $e->getError();

}

catch(DataServiceRequestException $e)

{

   echo $e->Response->getError();

}

require_once 'Context/ObjectContext.php';

define AZURE_SERVICE_URL(“http://<Account>.table.core.windows.net”);

define AZURE_ACCOUNT_NAME(specify your account name here);

define AZURE_ACCOUNT_KEY(specify your account key here);

 

/**

 *@Class:Employees

 *@Key:PartitionKey

 *@Key:RowKey

 */

class Employees extends TableEntry

{

    /**

     *@Type:EntityProperty

     */

     Public $Name;

  

    /**

     *@Type:EntityProperty

     */

     Public $Age;

 

   /**

     *@Type:EntityProperty

     */

     Public $Visible;

  

}

 

try

{

    $svc = new ObjectContext(AZURE_SERVICE_URL);

   

    //specify azure credentials

    $svc->Credential = new AzureTableCredential(AZURE_ACCOUNT_NAME, AZURE_ACCOUNT_KEY);

    //Create query object to fetch the record

    $query = new DataServiceQuery(‘Employees’, $svc);

    $response = $query->Filter(“Name eq ’ALFKI’”)->Execute();

    $tableEntity = $response->Result[0];

 

    //mark the table entry as deleted   

    $svc->DeleteObject($tableEntity);

    $svc->SaveChanges();

 

    $query = new DataServiceQuery(‘Tables’, $svc);

    $response = $query->Filter(“TableName eq ’Employees’”)->Execute();

    $table= $response->Result[0];

 

    //mark the table as deleted   

    $svc->DeleteObject($table);

    $svc->SaveChanges();

 

}

catch(ODataServiceException $e)

{

   echo $e->getError();

}

catch(DataServiceRequestException $e)

{

   echo $e->Response->getError();

}

define("ACS_NORTHWIND_SERVICE_URL", "http://localhost:13985/ACSNorthWindDataService.svc");

define("SERVICE_NAMESPACE", 'wcfdataservice');

define("ACS_USER", 'infocorp');

define("ACS_PWD", 'qfimKj6Vm6HKAJryTRno5USPpvz0c8bBzFhlqKex6lQ=');

define("ACS_APPLIESTO", 'http://localhost/WCFNorthWindService/');

 

/**

 * CallBack function, this will be invoked before making request to

 * OData service.

 */

function OnBeforeCallBack($httpRequest)

{

    $proxy = new HttpProxy(PROXY_HOST, PROXY_PORT);

    //Use the ACSUtil helper class of toolkit

    $acsutil = new ACSUtil(SERVICE_NAMESPACE,

                               ACS_USER,

                               ACS_PWD,

                               ACS_APPLIESTO,

                               array(),

                               $proxy);

    try

    {       

        //Get the ACS Token

        $token = $acsutil->GetACSToken();

        //Format the token in the way DataService Expects

        $authHeaderValue = 'WRAP access_token="' . urldecode($token) . '"';

        //Add the acs auth header

        $httpRequest->Headers->Add('authorization', $authHeaderValue);

    }

    catch(ACSUtilException $ex)

    {

        echo 'Failed to get the ACS token' . "<br/>";

        echo $ex->getError();

        exit;

    }

}

 

try

{

     $svc = new NorthwindEntities1(ACS_NORTHWIND_SERVICE_URL);

     //Regitser the call-back

     $svc->OnBeforeRequest('OnBeforeCallBack', null);

    

     $query = $svc->Customers()->filter("CustomerID eq 'ALFKI'");

     $customersResponse = $query->Execute();

 

     if(count($customersResponse->Result))

     {

        echo "<br/><br/>Customer Information <br/><br/>";

        $customer = $customersResponse->Result[0];

        echo 'CustomerID: ' . $customer->CustomerID . "<br/>";

        echo 'CompanyName: ' . $customer->CompanyName . "<br/>";

     }

     else

     {

         echo "Failed to retrieve the Customer with ID 'ALFKI'";

     }

 

}

catch(DataServiceRequestException $ex)

{

        echo 'Error: while running the query ' . $ex->Response->getQuery();

        echo "<br/>";

        echo $ex->Response->getError();

}

catch (ODataServiceException $e)

{

    echo "Error:" . $e->getError() . "<br>" . "Detailed Error:" . $e->getDetailedError();

}

function OnBeforeCallBack($httpRequest)

{

    $proxy = new HttpProxy(PROXY_HOST, PROXY_PORT);

     $acsCredential = new ACSCredential(SERVICE_NAMESPACE,

                                         ACS_USER,

                                         ACS_PWD,

                                         ACS_APPLIESTO,

                                         array(), /*additional claims*/

                                         $proxy   /*proxy required to access ACS

                                                    note that we will not set $svc->HttpProxy

                                                    because the service is running locally

                                                  */

                                         );

 

    $httpRequest->setCredential($acsCredential);

}

 

function OnAfterCallBack($httpResponse)

{

    echo '<h1>The HTML Friendly Response body</h1>'  . "<br/>";

    echo $httpResponse->getHTMLFriendlyBody();

    exit;

}

 

$svc = new NorthwindEntities();

 

try

{  

    $svc = new NorthwindEntities();         

    $svc->OnAfterResponse('OnAfterCallBack', null);       

    $query = $svc->Customers()->filter("Country eq 'USA'")

    $customersResponse = $query->Execute();

}

catch(DataServiceRequestException $exception)

{

    echo 'Error during running the query:';

    echo "<br/>";

    echo $exception->Response->getError();

    exit;

}

$proxy->Credential = new WindowsCredential(domain\user-name, password);

 

$proxy->Credential = new AzureTableCredential(account-name, account-key);

 

$proxy->Credential = new ACSCredential(service_namespace, wrap_name, wrap_password, wrap_scope, claims /*array of claims*/, proxy /*HttpProxy instance*/);

 

$proxy->HttpProxy = new HttpProxy(proxy-server-name, proxy-server-port, proxy-user-name, proxy-password);