| 0,0 → 1,183 |
|---|
| <?php |
| /** |
| * Helper functions to convert between ADODB recordset objects and XMLRPC values. |
| * Uses John Lim's AdoDB and Edd Dumbill's phpxmlrpc libs |
| * |
| * @author Daniele Baroncelli |
| * @author Gaetano Giunta |
| * @copyright (c) 2003-2004 Giunta/Baroncelli. All rights reserved. |
| * |
| * @todo some more error checking here and there |
| * @todo document the xmlrpc-struct used to encode recordset info |
| * @todo verify if using xmlrpc_encode($rs->GetArray()) would work with: |
| * - ADODB_FETCH_BOTH |
| * - null values |
| */ |
| |
| /** |
| * Include the main libraries |
| */ |
| require_once('xmlrpc.inc'); |
| if (!defined('ADODB_DIR')) require_once('adodb.inc.php'); |
| |
| /** |
| * Builds an xmlrpc struct value out of an AdoDB recordset |
| */ |
| function rs2xmlrpcval(&$adodbrs) { |
| |
| $header =& rs2xmlrpcval_header($adodbrs); |
| $body =& rs2xmlrpcval_body($adodbrs); |
| |
| // put it all together and build final xmlrpc struct |
| $xmlrpcrs =& new xmlrpcval ( array( |
| "header" => $header, |
| "body" => $body, |
| ), "struct"); |
| |
| return $xmlrpcrs; |
| |
| } |
| |
| /** |
| * Builds an xmlrpc struct value describing an AdoDB recordset |
| */ |
| function rs2xmlrpcval_header($adodbrs) |
| { |
| $numfields = $adodbrs->FieldCount(); |
| $numrecords = $adodbrs->RecordCount(); |
| |
| // build structure holding recordset information |
| $fieldstruct = array(); |
| for ($i = 0; $i < $numfields; $i++) { |
| $fld = $adodbrs->FetchField($i); |
| $fieldarray = array(); |
| if (isset($fld->name)) |
| $fieldarray["name"] =& new xmlrpcval ($fld->name); |
| if (isset($fld->type)) |
| $fieldarray["type"] =& new xmlrpcval ($fld->type); |
| if (isset($fld->max_length)) |
| $fieldarray["max_length"] =& new xmlrpcval ($fld->max_length, "int"); |
| if (isset($fld->not_null)) |
| $fieldarray["not_null"] =& new xmlrpcval ($fld->not_null, "boolean"); |
| if (isset($fld->has_default)) |
| $fieldarray["has_default"] =& new xmlrpcval ($fld->has_default, "boolean"); |
| if (isset($fld->default_value)) |
| $fieldarray["default_value"] =& new xmlrpcval ($fld->default_value); |
| $fieldstruct[$i] =& new xmlrpcval ($fieldarray, "struct"); |
| } |
| $fieldcount =& new xmlrpcval ($numfields, "int"); |
| $recordcount =& new xmlrpcval ($numrecords, "int"); |
| $sql =& new xmlrpcval ($adodbrs->sql); |
| $fieldinfo =& new xmlrpcval ($fieldstruct, "array"); |
| |
| $header =& new xmlrpcval ( array( |
| "fieldcount" => $fieldcount, |
| "recordcount" => $recordcount, |
| "sql" => $sql, |
| "fieldinfo" => $fieldinfo |
| ), "struct"); |
| |
| return $header; |
| } |
| |
| /** |
| * Builds an xmlrpc struct value out of an AdoDB recordset |
| * (data values only, no data definition) |
| */ |
| function rs2xmlrpcval_body($adodbrs) |
| { |
| $numfields = $adodbrs->FieldCount(); |
| |
| // build structure containing recordset data |
| $adodbrs->MoveFirst(); |
| $rows = array(); |
| while (!$adodbrs->EOF) { |
| $columns = array(); |
| // This should work on all cases of fetch mode: assoc, num, both or default |
| if ($adodbrs->fetchMode == 'ADODB_FETCH_BOTH' || count($adodbrs->fields) == 2 * $adodbrs->FieldCount()) |
| for ($i = 0; $i < $numfields; $i++) |
| if ($adodbrs->fields[$i] === null) |
| $columns[$i] =& new xmlrpcval (''); |
| else |
| $columns[$i] =& xmlrpc_encode ($adodbrs->fields[$i]); |
| else |
| foreach ($adodbrs->fields as $val) |
| if ($val === null) |
| $columns[] =& new xmlrpcval (''); |
| else |
| $columns[] =& xmlrpc_encode ($val); |
| |
| $rows[] =& new xmlrpcval ($columns, "array"); |
| |
| $adodbrs->MoveNext(); |
| } |
| $body =& new xmlrpcval ($rows, "array"); |
| |
| return $body; |
| } |
| |
| /** |
| * Returns an xmlrpc struct value as string out of an AdoDB recordset |
| */ |
| function rs2xmlrpcstring (&$adodbrs) { |
| $xmlrpc = rs2xmlrpcval ($adodbrs); |
| if ($xmlrpc) |
| return $xmlrpc->serialize(); |
| else |
| return null; |
| } |
| |
| /** |
| * Given a well-formed xmlrpc struct object returns an AdoDB object |
| * |
| * @todo add some error checking on the input value |
| */ |
| function xmlrpcval2rs (&$xmlrpcval) { |
| |
| $fields_array = array(); |
| $data_array = array(); |
| |
| // rebuild column information |
| $header =& $xmlrpcval->structmem('header'); |
| |
| $numfields = $header->structmem('fieldcount'); |
| $numfields = $numfields->scalarval(); |
| $numrecords = $header->structmem('recordcount'); |
| $numrecords = $numrecords->scalarval(); |
| $sqlstring = $header->structmem('sql'); |
| $sqlstring = $sqlstring->scalarval(); |
| |
| $fieldinfo =& $header->structmem('fieldinfo'); |
| for ($i = 0; $i < $numfields; $i++) { |
| $temp =& $fieldinfo->arraymem($i); |
| $fld =& new ADOFieldObject(); |
| while (list($key,$value) = $temp->structeach()) { |
| if ($key == "name") $fld->name = $value->scalarval(); |
| if ($key == "type") $fld->type = $value->scalarval(); |
| if ($key == "max_length") $fld->max_length = $value->scalarval(); |
| if ($key == "not_null") $fld->not_null = $value->scalarval(); |
| if ($key == "has_default") $fld->has_default = $value->scalarval(); |
| if ($key == "default_value") $fld->default_value = $value->scalarval(); |
| } // while |
| $fields_array[] = $fld; |
| } // for |
| |
| // fetch recordset information into php array |
| $body =& $xmlrpcval->structmem('body'); |
| for ($i = 0; $i < $numrecords; $i++) { |
| $data_array[$i]= array(); |
| $xmlrpcrs_row =& $body->arraymem($i); |
| for ($j = 0; $j < $numfields; $j++) { |
| $temp =& $xmlrpcrs_row->arraymem($j); |
| $data_array[$i][$j] = $temp->scalarval(); |
| } // for j |
| } // for i |
| |
| // finally build in-memory recordset object and return it |
| $rs =& new ADORecordSet_array(); |
| $rs->InitArrayFields($data_array,$fields_array); |
| return $rs; |
| |
| } |
| |
| ?> |