PHP5でSOAPを用いたブックマークサービスを作成する

''';'''extension=soap.so

extension=soap.so

CREATE TABLE soap_bookmarks (
    ID INTEGER NOT NULL auto_increment,
    TITLE VARCHAR(255) NOT NULL,
    URL VARCHAR(255) NOT NULL,
    MEMO TEXT,
    PRIMARY KEY(ID,TITLE)
);

<?xml version ="1.0" encoding ="utf-8"?>
<definitions name="SoapBookmarks"
   targetNamespace=
"http://php.xole.net/soap_bookmarks/soap_bookmarks.wsdl"
   xmlns:typens=
"http://php.xole.net/soap_bookmarks/soap_bookmarks.wsdl"
   xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"
   xmlns:xsd="http://www.w3.org/2001/XMLSchema"
   xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/"
   xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"
   xmlns="http://schemas.xmlsoap.org/wsdl/">

<types>
  <xsd:schema targetNamespace="urn:SoapBookmarks">
    <!--
    SoapBookmarksElementという名の集合体を定義しています。
    また、この集合体は以下の要素から成り立ちます。
    -->
    <xsd:complexType name="SoapBookmarksElement">
      <xsd:all>
        <!-- id要素はint型であることを定義しています。 -->
        <xsd:element name="id" type="xsd:int" />
        <!-- title要素はstring型ということを定義しています。 -->
        <xsd:element name="title" type="xsd:string" />
        <xsd:element name="url" type="xsd:string" />
        <xsd:element name="memo" type="xsd:string" />
      </xsd:all>
    </xsd:complexType>
    <!-- 配列を扱う集合体を定義します -->
    <xsd:complexType name="SoapBookmarksElementArray">
      <xsd:complexContent>
        <!-- 集合体の配列を定義します -->
        <xsd:restriction base="soapenc:Array">
          <!--
          SoapBookmarksElementの配列であると定義します。
          -->
          <xsd:attribute ref="soapenc:arrayType"
          wsdl:arrayType="typens:SoapBookmarksElement[]" />
        </xsd:restriction>
      </xsd:complexContent>
    </xsd:complexType>
  </xsd:schema>
</types>

<!-- getPageというメッセージは、idという名で
int型でやり取りできることを定義しています。 -->
<message name="getPage">
  <part name="id" type="xsd:int" />
</message>
<!--
getPageResponseというメッセージは、
ResultSetという名でSoapBookmarksElement型で
やり取りできることを定義しています。
-->
<message name="getPageResponse">
  <part name="ResultSet" type="typens:SoapBookmarksElement" />
</message>
<!--
getPageListResponseというメッセージは、
ResultSetsという名でSoapBookmarksElementArray型で
やり取りできることを定義しています 
-->
<message name="getPageListResponse">
  <part name="ResultSets" type="typens:SoapBookmarksElementArray" />
</message>
<!-- 他にも定義を複数記述することもできます。 -->
<message name="addPage">
  <part name="title" type="xsd:string" />
  <part name="url" type="xsd:string" />
  <part name="memo" type="xsd:string" />
</message>
<!-- 真偽を表すboolean型も用いることができます。 -->
<message name="addPageResponse">
  <part name="bool" type="xsd:boolean" />
</message>

<portType name="SoapBookmarksPortType">
  <!-- getPageという受付の定義です。 -->
  <operation name="getPage">
    <!-- 上の<message>で定義したgetPageメッセージを
入力することを定義しています。 -->
    <input message="typens:getPage" />
    <!-- 入力後<message>で定義したgetPageResponseが
返されることを定義しています。 -->
    <output message="typens:getPageResponse" />
  </operation>
</portType>

<binding name="SoapBookmarksBinding"
         type="typens:SoapBookmarksPortType">
  <soap:binding style="rpc"
  transport="http://schemas.xmlsoap.org/soap/http" />
  <operation name="getPage">
    <soap:operation soapAction="typens:SoapBookmarksGetAction" />
    <input>
      <soap:body use="encoded" 
      namespace="typens:SoapBookmarks"
      encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" />
    </input>
    <output>
      <soap:body use="encoded"
      namespace="typens:SoapBookmarks"
      encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" />
    </output>
  </operation>
</binding>

<service name="SoapBookmarksService">
  <port name="SoapBookmarksPort"
        binding="typens:SoapBookmarksBinding">
    <soap:address
        location="http://php.xole.net/soap_bookmarks/server.php" />
  </port>
</service>

<?php
class bookmarks_server {

    const MySQL_HOST = "localhost";
    const MySQL_USER = "username";
    const MySQL_PASSWD = "password";
    const MySQL_DB = "testdb";

    private static $strval = array("TITLE","URL","MEMO");
    private static $intval = array("ID", "COUNT");

    private static $db = null;

    public function __construct(){
        self::$db = new mysqli(self::MySQL_HOST,self::MySQL_USER,
                               self::MySQL_PASSWD, self::MySQL_DB);
    }

    public function __destruct(){
        self::$db->close();
    }

    public function getPage($id){
        :
    }

    public function getPageList(){
        :
    }

    public function addPage($title, $url, $memo = null){
        :
    }

    // 省略します。
    :
    :
}

$server = new bookmarks_server()

public function getPage($id){
    $id = $this->escape(intval($id));
    $sql = "SELECT ID, TITLE, URL, MEMO FROM soap_bookmarks
            WHERE ID = ${id}";
    $row = self::$db->query($sql)->fetch_assoc();
    foreach($row as $key => $value){
        $result[$key] = $this->convertResponse($value,$key);
    }
    return $result;
}

private function convertResponse($value, $key = null){
    $key = key($value);
    if( in_array($key, self::$intval) ){
        return intval($value[$key]);
    } else if( in_array($key, self::$strval) ){
        return strval($value[$key]);
    } else {
        return $value[$key];
    }
}

require "bookmarks_server.class.php";
$options = array(
                "encoding" => "UTF-8",
                "soap_version" => SOAP_1_2,
            );

$server = new SoapServer("soap_bookmarks.wsdl", $options);
$server->setClass("bookmarks_server");
$server->handle();

$server = new SoapServer("soap_bookmarks.wsdl", $options);

$server->setClass("bookmarks_server");

<?php
require "bookmarks_client.class.php";

try{
    $client = new bookmarks_client(
                  new SoapClient("soap_bookmarks.wsdl"));
    $client->operation();
} catch (Exception $e){
    var_dump( $e->getMessage() );
}
?>

<?php
class bookmarks_client {

    private static $soap = null;

    public function __construct(SoapClient $soap){
        self::$soap = $soap;
    }

    public function operation(){
        $operation = "";
        $list = array("getOne", "getAll", "add", "update", "delete");
        foreach( $list as $key => $value ){
            $operation .= $key . "-" . $value . PHP_EOL;
        }
        $select = readline($operation . "choose Operation [0 - "
                               . (count($list) - 1) . "]:");
        $op = $list[$select];
        $this->$op();
    }

    public function __call($name, $params){
        throw new Exception("Undefined method: '" . $name . "'");
    }

    private function getOne(){
        $id = readline("Get Page ID? [integer] :");
        $rows = self::$soap->getPage($id);
        if( count($rows) > 0 ){
            echo $this->table($rows);
        } else {
            echo "ID(${id}) page does not exists" . PHP_EOL;
        }
    }

    private function getAll(){
        $rows = self::$soap->getPageList();
        foreach( $rows as $value ){
            echo $this->table($value);
        }
    }

    private function add(){
        $title = readline("Add Page Title? [string] :");
        $url = readline("Page URL? [string] :");
        $memo = readline("Page Memo(option) [string] :");
        $res = self::$soap->addPage($title, $url, $memo);
        echo $this->table($res);
    }
}

__construct(SoapClient $soap)

$op = $list[$select];
$this->$op();

self::$soap->addPage($title,$url,$memo);

/home/workspace/php/soap> php client.php
0-getOne
1-getAll
2-add
3-update
4-delete
choose Operation [0 - 4]:2
Add Page Title? [string] :CodeZine
Page URL? [string] :http://codezine.jp/
Page Memo(option) [string] :開発者のための実装系Webマガジン
----------
Response: true
----------

/home/workspace/php/soap> php client.php
0-getOne
1-getAll
2-add
3-update
4-delete
choose Operation [0 - 4]:1
----------
ID: 1
TITLE: CodeZine
URL: http://codezine.jp/
MEMO: 開発者のための実装系Webマガジン
----------
----------
ID: 2
TITLE: blog.xole.net
URL: http://blog.xole.net/
MEMO: 自分のWeblog
----------