Merge pull request #24 from MyMedia/new-features

Extended by new methods insertUpdateRelationalTable and deleteRelationalTableData

Author: tholder

src/Silverpop/EngagePod.php

@@ -598,6 +598,84 @@ public function purgeTable($tableName, $isPrivate = true) {
         }
 
     }
+    
+    /**
+	 * This interface inserts or updates relational data
+	 *
+	 * For each Row that is passed in:
+	 * - If a row is found having the same key as the passed in row, update the record.
+	 * - If no matching row is found, insert a new row setting the column values to those passed in the request.
+	 *
+	 * Only one hundred rows may be passed in a single insertUpdateRelationalTable call!
+	 */
+    public function insertUpdateRelationalTable($tableId, $rows) {
+	    $processedRows = array();
+        $attribs = array();
+	    foreach($rows as $row) {
+		    $columns = array();
+		    foreach($row as $name => $value)
+		    {
+			    $columns['COLUMN'][] = $value;
+			    $attribs[5]['COLUMN'][] = array('name' => $name);
+		    }
+		    
+		    $processedRows['ROW'][] = $columns;
+	    }
+	    
+	    $data["Envelope"] = array(
+            "Body" => array(
+                "InsertUpdateRelationalTable" => array(
+                    "TABLE_ID" => $tableId,
+                    "ROWS" => $processedRows,
+                ),
+            ),
+        );
+
+        $response = $this->_request($data, array(), $attribs);
+        $result = $response["Envelope"]["Body"]["RESULT"];
+
+        if ($this->_isSuccess($result)) {
+            return true;
+        } else {
+            throw new \Exception("insertUpdateRelationalTable Error: ".$this->_getErrorFromResponse($response));
+        }
+    }
+    
+    /**
+	 * This interface deletes records from a relational table.
+	 */
+    public function deleteRelationalTableData($tableId, $rows) {
+	    $processedRows = array();
+        $attribs = array();
+	    foreach($rows as $row) {
+		    $columns = array();
+		    foreach($row as $name => $value)
+		    {
+			    $columns['KEY_COLUMN'][] = $value;
+			    $attribs[5]['KEY_COLUMN'][] = array('name' => $name);
+		    }
+		    
+		    $processedRows['ROW'][] = $columns;
+	    }
+	    
+	    $data["Envelope"] = array(
+            "Body" => array(
+                "DeleteRelationalTableData" => array(
+                    "TABLE_ID" => $tableId,
+                    "ROWS" => $processedRows,
+                ),
+            ),
+        );
+        
+        $response = $this->_request($data, array(), $attribs);
+        $result = $response["Envelope"]["Body"]["RESULT"];
+
+        if ($this->_isSuccess($result)) {
+            return true;
+        } else {
+            throw new \Exception("deleteRelationalTableData Error: ".$this->_getErrorFromResponse($response));
+        }
+    }
 
     /**
      * Import a list/database

src/Silverpop/Util/ArrayToXml.php

@@ -51,7 +51,6 @@ function _processArray( &$array, $level = 0, $parent = '' ) {
 
 			if ( isset( $this->_attribs[$tlevel][$name][$this->_rep[$name] - 1] ) && is_array( $this->_attribs[$tlevel][$name][$this->_rep[$name] - 1] ) ) {
 				foreach ( (array) $this->_attribs[$tlevel][$name][$this->_rep[$name] - 1] as $aname => $avalue ) {
-					unset( $value[$aname] );
 					$attrs .= " $aname=\"$avalue\"";
 				}
 			}