Forum PHP.pl > [XML][MySQL][PHP]Pobierz dane xml i wklej do mysql (skrypt PHP)

Pomoc - Szukaj - Użytkownicy - Kalendarz

Pełna wersja: [XML][MySQL][PHP]Pobierz dane xml i wklej do mysql (skrypt PHP)

pela222

11.03.2014, 14:14:00

Hej,
mam problem z uruchomieniem skryptu php który łączy się z moim CRM (Zoho CRM) i pobiera dane (kilka rekordów) w formacie XML. Następnie chodzi o "wsadzenie" tych rekordów do bazy mysql.
Jak narazie jedyn co midziała to tego typu zapytanie:
https://crm.zoho.com/crm/private/xml/Leads/...mp;scope=crmapi
i zwraca mi coś takiego w postaci xml:

[XML] pobierz, plaintext 
This XML file does not appear to have any style information associated with it. The document tree is shown below.
<response uri="/crm/private/xml/Leads/getMyRecords">
<result>
<Leads>
<row no="1">
	<FL val="LEADID">624745000000615068</FL>
	<FL val="SMOWNERID">624745000000053003</FL>
	<FL val="Lead Owner">
	<![CDATA[ Moje Imię ]]>
	</FL>
	<FL val="Company">
	<![CDATA[ Peplos Wine Restaurant ]]>
	</FL>
	<FL val="FirstName">
	<![CDATA[ Grzegorz ]]>
	</FL>
	<FL val="Last Name">
	<![CDATA[ Kowalski ]]>
	</FL>>
	<FL val="Created Time">
	<![CDATA[ 2014-02-28 12:41:17 ]]>
	</FL>
	</row>
</Leads>
</result>
</response>
[XML] pobierz, plaintext

Plik php który miał by przetowrzyć to o co mi chodzi już niestety nie dziąła. Nie wiem dlaczego. Wydaje mi się że ten skrypt php wogóle nie pobiera danych z mojego CRM. Jak sprawdzić zanim włoże dane do mysql czy coś zostało pobrane? print_r

echo

Plik php wyglada tak:

[PHP] pobierz, plaintext 
<?php
 
/* NOTE: Define your mysql database parameters in moduleDependant class */
 
/* Constant Declarations */
define("TARGETURL", "https://crm.zoho.com/crm/private/xml/Leads/getMyRecords");
 
/* user related parameter */
define("AUTHTOKEN", "moj_token_autoryzacyjny");
define("SCOPE", "crmapi");
 
/* create a object */
$utilObj = new Utilities();
 
 
/* set parameters */
$parameter = "";
$parameter = $utilObj->setParameter("scope", SCOPE, $parameter);
$parameter = $utilObj->setParameter("authtoken", AUTHTOKEN, $parameter);
$parameter = $utilObj->setParameter("selectColumns", "Leads(LEADID,First Name,Last Name,Company)", $parameter);
 
/* Call API */
$response = $utilObj->sendCurlRequest(TARGETURL, $parameter);
 
$utilObj->parseXMLandInsertInDB($response);
 
 
 
class Utilities {
 
 
    public function setParameter($key, $value, $parameter) {
        if ($parameter === "" || strlen($parameter) == 0) {
            $parameter = $key . '=' . $value;
        } else {
            $parameter .= '&' . $key . '=' . $value;
        }
        return $parameter;
    }
 
    public function parseXMLandInsertInDB($xmldata) {
        $xmlString = <<<XML
$xmldata 
XML;
        $xml = simplexml_load_string($xmlString);
        if (isset($xml->result)) {
            $modeuleDependantObj = new moduleDependant();
            $output = $modeuleDependantObj->insertInDB($xml);
        } else if (isset($xml->error)) {
            echo "Error code: " . $xml->error->code . "<br/>";
            echo "Error message: " . $xml->error->message;
        }
    }
 
    public function sendCurlRequest($url, $parameter) {
        try {
            /* initialize curl handle */
            $ch = curl_init();
            /* set url to send post request */
            curl_setopt($ch, CURLOPT_URL, $url);
            /* allow redirects */
            curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
            /* return a response into a variable */
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            /* times out after 30s */
            curl_setopt($ch, CURLOPT_TIMEOUT, 30);
            /* set POST method */
            curl_setopt($ch, CURLOPT_POST, 1);
            /* add POST fields parameters */
            curl_setopt($ch, CURLOPT_POSTFIELDS, $parameter);
            /* execute the cURL */
            $result = curl_exec($ch);
            curl_close($ch);
            return $result;
        } catch (Exception $exception) {
            echo 'Exception Message: ' . $exception->getMessage() . '<br/>';
            echo 'Exception Trace: ' . $exception->getTraceAsString();
        }
    }
 
 
}
 
class moduleDependant {
    /* Define your mysql database parameters */
 
    private $host = "localhost";
    private $username = "root";
    private $password = "";
 
    public function insertInDB($xml) {
        $numberOfRecords = count($xml->result->Leads->row);
        /* $records[row value][field value] */
        $records[][] = array();
        for ($i = 0; $i < $numberOfRecords; $i++) {
            $numberOfValues = count($xml->result->Leads->row[$i]->FL);
            for ($j = 0; $j < $numberOfValues; $j++) {
                switch ((string) $xml->result->Leads->row[$i]->FL[$j]['val']) {
                    /* Get attributes as element indices */
                    case 'LEADID':
                        $records[$i]['LEADID'] = (string) $xml->result->Leads->row[$i]->FL[$j];
                        break;
                    case 'First Name':
                        $records[$i]['First Name'] = (string) $xml->result->Leads->row[$i]->FL[$j];
                        break;
                    case 'Last Name':
                        $records[$i]['Last Name'] = (string) $xml->result->Leads->row[$i]->FL[$j];
                        break;
                    case 'Company':
                        $records[$i]['Company'] = (string) $xml->result->Leads->row[$i]->FL[$j];
                        break;
                }
            }
        }
        /* Inserting in database */
        $connection = mysql_connect($this->host, $this->username, $this->password) or die(mysql_error());
        $query = "Insert into crm.leads (id, firstname, lastname, company) value ";
        for ($k = 0; $k < count($records); $k++) {
            if ($k == 0) {
                $query .= "('" . $records[$k]['LEADID'] . "','" . $records[$k]['First Name'] . "','" . $records[$k]['Last Name'] . "','" . $records[$k]['Company'] . "')";
            }
            if ($k > 0) {
                $query .= ", ('" . $records[$k]['LEADID'] . "','" . $records[$k]['First Name'] . "','" . $records[$k]['Last Name'] . "','" . $records[$k]['Company'] . "')";
            }
        }
        $result = mysql_query($query, $connection) or die(mysql_error());
        if (isset($result) && mysql_affected_rows($connection) == count($records)) {
            echo "Data's are inserted in database successfully.<br/><br/> ";
 
            /* Table structure of inserted data, you can check inserted data by uncommenting a below section */
            /*
              $insertedTable = "<table cellspacing=0 cellpadding='4px' border=1>";
              $insertedTable .= "<tr><td>Lead ID</td><td>First Name</td><td>Last Name</td><td>Company</td></tr>";
              for ($k = 0; $k < count($records); $k++) {
              $insertedTable .= "<tr><td>" . $records[$k]['LEADID'] . "</td><td>" . $records[$k]['First Name'] . "</td><td>" . $records[$k]['Last Name'] . "</td><td>" . $records[$k]['Company'] . "</td></tr>";
              }
              $insertedTable .= "</table>";
              echo $insertedTable;
             */
        } else {
            echo 'Some error while inserting in database';
        }
    }
 
}
?>
[PHP] pobierz, plaintext

Update...
Jak narazie to moge powiedzić że:
1) echo "Params: " . $parameter; zwraca paramery:

Params: scope=crmapi&authtoken=mojtokenautoruzacujnu&selectColumns=Leads(LEADID,First Name,Last Name,Company)
wiec ta część jast ok

2) pierwszy sposób który mi pozwala pobrać dane z CRM to metoda GET, natomiast użyte w skrypcie php curl to metoda POST. Raczej wątpie że to jest przyczyną bo skryp żywcem wzięty ze strony Zoho CRM....no ale może tu jest przyczyna?

z powodu braku zrozumienia składni:

[PHP] pobierz, plaintext 
public function sendCurlRequest($url, $parameter) {
        try {
            /* initialize curl handle */
            $ch = curl_init();
            /* set url to send post request */
            curl_setopt($ch, CURLOPT_URL, $url);
            /* allow redirects */
            curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
            /* return a response into a variable */
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            /* times out after 30s */
            curl_setopt($ch, CURLOPT_TIMEOUT, 30);
            /* set POST method */
            curl_setopt($ch, CURLOPT_POST, 1);
            /* add POST fields parameters */
            curl_setopt($ch, CURLOPT_POSTFIELDS, $parameter);
            /* execute the cURL */
            $result = curl_exec($ch);
            curl_close($ch);
            return $result;
        }
[PHP] pobierz, plaintext

nie potrafię togo przerobić na curl metodą GET. Jak ktoś jest chętny to pomocy to sprawdzę. Moze tu jest przyczyna.
Dzieki.

lukasz_os

11.03.2014, 14:27:26

1. Parametry połącz & i dodaj do url.
2. Wywołaj ten url w curl_setopt($ch, CURLOPT_URL, $url);
3. Wykasuj odwołanie POSTA czyli: curl_setopt($ch, CURLOPT_POST, 1); oraz curl_setopt($ch, CURLOPT_POSTFIELDS, $parameter);

To wszystko

pela222

14.03.2014, 11:27:11

Rozwiązaniem okazało się wyłączenie SSL

[PHP] pobierz, plaintext 
public function sendCurlRequest($url, $parameter) {
        try {
            /* initialize curl handle */
            $ch = curl_init();
            /* set url to send post request */
            curl_setopt($ch, CURLOPT_URL, $url);
            /* allow redirects */
            curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
            /* return a response into a variable */
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
			curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);// Turn off the server and peer verification 
			curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
            /* times out after 30s */
            curl_setopt($ch, CURLOPT_TIMEOUT, 30);
            /* set POST method */
            curl_setopt($ch, CURLOPT_POST, 1);
            /* add POST fields parameters */
            curl_setopt($ch, CURLOPT_POSTFIELDS, $parameter);
            /* execute the cURL */
            $result = curl_exec($ch);
            curl_close($ch);
            return $result;
        } catch (Exception $exception) {
            echo 'Exception Message: ' . $exception->getMessage() . '<br/>';
            echo 'Exception Trace: ' . $exception->getTraceAsString();
        }
    }
[PHP] pobierz, plaintext

I wszystko gra

EDIT - Nowy problem - mysql_real_escape_string
------------------------------------------
Hej,
teraz mam troche inny problem. Nie potrafie sobie poradzić z prawidłowym użyciem funkcji: mysql_real_escape_string (bo to chyba jest remedium na moj problem.

Jeden z rekordów ma apostrof Company = O'Brien Transport (może wiecej ma

) i dostaje coś takiego:
You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'Brien Transport','Truck Driver','','Marlena','Szczerba','Cleaning Contractors','' at line 1

Po wstawieniu:

[PHP] pobierz, plaintext 
$query = mysql_real_escape_string($query);
[PHP] pobierz, plaintext

dostaje:

You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '\'624745000000615017\',\'Karol\',\'Czyjak\',\'Wall Steal Ltd\',\'CNC Operator\',' at line 1

Z tego co zrozumiałem czytając manual to powinienem tej funkcji użyć przed połączeniem z bazą i wtedy użyć funkcji takiej:

[PHP] pobierz, plaintext 
$records = mysql_real_escape_string($records);
[PHP] pobierz, plaintext

no ale zmienna records to jest tablica i tutaj leżę.

Kod poniżej (z wstawionym mysql_real_escape_string - które wywala błąd ale dodaje backslash co widać powyżej (co ciekawe inny klient - pewnie pierwszy z bazy)

[PHP] pobierz, plaintext 
/* Inserting in database */
        $connection = mysql_connect($this->host, $this->username, $this->password) or die(mysql_error());
        $query = "replace into crm.leads (id, firstname, lastname, company, occupation, income, spousename, spouselastname, spousecompany, spouseoccupation, spouseincome, street, city, county) value ";
        for ($k = 0; $k < count($records); $k++) {
            if ($k == 0) {
                $query .= "('" . $records[$k]['CONTACTID'] . "','" . $records[$k]['First Name'] . "','" . $records[$k]['Last Name'] . "','" . $records[$k]['Company'] . "','" . $records[$k]['Occupation'] . "','" . $records[$k]['Income'] . "','" . $records[$k]['Spouse Name'] . "','" . $records[$k]['Spouse Last Name'] . "','" . $records[$k]['Spouse Company'] . "','" . $records[$k]['Spouse Occupation'] . "','" . $records[$k]['Spouse Income'] . "','" . $records[$k]['Street'] . "','" . $records[$k]['City'] . "','" . $records[$k]['County'] . "')";
            }
            if ($k > 0) {
                $query .= ", ('" . $records[$k]['CONTACTID'] . "','" . $records[$k]['First Name'] . "','" . $records[$k]['Last Name'] . "','" . $records[$k]['Company'] . "','" . $records[$k]['Occupation'] . "','" . $records[$k]['Income'] . "','" . $records[$k]['Spouse Name'] . "','" . $records[$k]['Spouse Last Name'] . "','" . $records[$k]['Spouse Company'] . "','" . $records[$k]['Spouse Occupation'] . "','" . $records[$k]['Spouse Income'] . "','" . $records[$k]['Street'] . "','" . $records[$k]['City'] . "','" . $records[$k]['County'] . "')";
            }
        }
		$query = mysql_real_escape_string($query);
        $result = mysql_query($query, $connection) or die(mysql_error());
[PHP] pobierz, plaintext

EDIT .....
Nie wiem czy moje pytania są za trudne czy za łatwe?

Czy zbyt szczegółowo opisany problem (??wada??). Jak toś napisze nie wiem jak zrobić "coś tam coś tam .. pomóżcie" to są podpowiedzi? hmm...

nospor

14.03.2014, 11:29:59

Zamiast sie zalic na forum jak to masz trudno-latwe pytania lepiej bys zajrzal porzadnie do manuala. Tam dosc wyraznie jest napisane, ze mysql_real_escape_string masz uzywac na danych jakie wstawiasz do zapytania, a nie na calym zapytaniu....

pela222

14.03.2014, 12:27:25

Cytat(nospor @ 14.03.2014, 11:29:59 )

Tam dosc wyraznie jest napisane, ze mysql_real_escape_string masz uzywac na danych jakie wstawiasz do zapytania, a nie na calym zapytaniu....

Czyli że powinno być

? :

[PHP] pobierz, plaintext 
$records =  mysql_real_escape_string($records);
[PHP] pobierz, plaintext

Tak??
Już to próbowałem i tak jak napisałem ponieważ to jest tablica to pewnie dla tego to mi nie działa. A jak zapytałem jak to zrobić dla tabilicy to pomocy brak.
Dzięki za info. Możesz rozwinać swoją myśl żeby mi pomóc.

co do manuala to już go czytałem i próbowałem użyć tego co tam jest napisne (włączając sekcję notes - bezskutecznie

). Jakbym potrafił to bym nie pytał. Jakbym przesłał tobie książkę napisaną po chińsku to też by ci zajęło kilka miesięcy zanim byś zrozumiał pierwszą stronę ... czy nie?? Czy to oznacza że przez pierwszy miesiąc nie możesz poprosić kogoś kto zna chiński o pomoc? no bo jak tak to po co te wszystkie fora?

nospor

14.03.2014, 12:34:40

Kurcze.... prosilem, zajrzyj do manuala.... tam masz podane na przykladzie jak to zrobic. mysql_real_escape_string uzywa sie na danych a nie na tablicy z danymi. Rozrozniaj te dwie rzeczy

To jest twoja dana, ktora wkladasz do zapytania:
$records[$k]['First Name']

To na niej masz zrobic:
mysql_real_escape_string($records[$k]['First Name'])

Analogicznie na innych danych, ktore wkladasz do zapytania...

A tak pozatym to zainteresuj sie PDO lub mysqli_ oraz bindowaniem. mysql_ jest juz przestarzale i niedlugo wyleci z php

Cytat

akbym przesłał tobie książkę napisaną po chińsku to też by ci zajęło kilka miesięcy zanim byś zrozumiał pierwszą stronę ... czy nie?

Jakbym obok mial napisane po polsku to nie. W manualu masz wlasnie obok opis co i jak nalezy zrobic. tam nie ma chinszczyzny.
Jak masz napisane jak wol, ze funkcja przyjmuje STRING to masz tam wkladac STRING a nie tablice.

pela222

14.03.2014, 12:56:39

Cytat(nospor @ 14.03.2014, 12:34:40 )

To jest twoja dana, ktora wkladasz do zapytania:
$records[$k]['First Name']

To na niej masz zrobic:
mysql_real_escape_string($records[$k]['First Name'])

Czyli bedzie coś takeigo:

[PHP] pobierz, plaintext 
 /* Inserting in database */
		$connection = mysql_connect($this->host, $this->username, $this->password) or die(mysql_error());
		$query = "replace into crm.leads (id, firstname, lastname, dob, company, occupation, income, spousename, spouselastname, spousedob, spousecompany, spouseoccupation, spouseincome, street, city, county) value ";
		for ($k = 0; $k < count($records); $k++) {
            if ($k == 0) {
                $query .= "('" . $records[$k]['CONTACTID'] . "','" . $records[$k]['First Name'] . "','" . mysql_real_escape_string($records[$k]['Last Name']) . "','" . $records[$k]['Date of Birth'] . "','" . mysql_real_escape_string($records[$k]['Company']) . "','" . mysql_real_escape_string($records[$k]['Occupation']) . "','" . $records[$k]['Income'] . "','" . $records[$k]['Spouse Name'] . "','" . $records[$k]['Spouse Last Name'] . "','" . $records[$k]['Spouse DOB'] . "','" . mysql_real_escape_string($records[$k]['Spouse Company']) . "','" . $records[$k]['Spouse Occupation'] . "','" . $records[$k]['Spouse Income'] . "','" . $records[$k]['Street'] . "','" . $records[$k]['City'] . "','" . $records[$k]['County'] . "')";
            }
            if ($k > 0) {
                $query .= ", ('" . $records[$k]['CONTACTID'] . "','" . $records[$k]['First Name'] . "','" . mysql_real_escape_string($records[$k]['Last Name']) . "','" . $records[$k]['Date of Birth'] . "','" . mysql_real_escape_string($records[$k]['Company']) . "','" . mysql_real_escape_string($records[$k]['Occupation']) . "','" . $records[$k]['Income'] . "','" . $records[$k]['Spouse Name'] . "','" . $records[$k]['Spouse Last Name'] . "','" . $records[$k]['Spouse DOB'] . "','" . mysql_real_escape_string($records[$k]['Spouse Company']) . "','" . $records[$k]['Spouse Occupation'] . "','" . $records[$k]['Spouse Income'] . "','" . $records[$k]['Street'] . "','" . $records[$k]['City'] . "','" . $records[$k]['County'] . "')";
            }
        }
		$result = mysql_query($query, $connection) or die(mysql_error());
        if (isset($result) && mysql_affected_rows($connection) == count($records)) {
            echo "Data's are inserted in database successfully.<br/><br/> ";
[PHP] pobierz, plaintext

Na razie dodałem tylko tam gdzie widzę że wywało bład. Potem uzupełnię wszędzie. Musze zobaczyć bo dostaje błąd:
Column count doesn't match value count at row 1
Ale chyba chodzi o to że nie mam jakiegoś pola w mysql.

Dzieki za pomoc.

EDIT----
Już poprawiłem jak wyżej i gra muzyka.
Jeszcze raz dzięki.

nospor

14.03.2014, 13:01:52

Wyszczegolniasz 16 pol, zas wartosci dodajesz tylko dla 15. Stad komunikat bledu

ps:
nie county a country. Taka literowka, ktora drazni oczy

pela222

14.03.2014, 13:09:27

Cytat(nospor @ 14.03.2014, 13:01:52 )

ps:
nie county a country. Taka literowka, ktora drazni oczy

Niestety w tym przypadku jednak nie miałeś racji

jednak county

bo nie zawsze można mieć rację..dzięki za czujność

http://en.wikipedia.org/wiki/Counties_of_Ireland
ale jeszcze raz dzieki.

nospor

14.03.2014, 13:15:07

Acha, czyli probujesz mi powiedziec, ze w bazie przechowujesz miasta i hrabstwa a nie miasta i kraje? No jesli tak, to faktycznie moja wina.

To jest wersja lo-fi głównej zawartości. Aby zobaczyć pełną wersję z większą zawartością, obrazkami i formatowaniem proszę kliknij tutaj.