JSON to MYSQL using PDO

<?php



error_reporting(E_ALL);
echo '<pre>';

$sets = array();
$useraccounts = array("cricshare", "gp3123123123", "spider3323");

foreach ($useraccounts as $useracct)
{
    $page = 1;
    do
    {
        $url = "https://api.dailymotion.com/user/$useracct/videos?page=$page&limit=100";
        echo PHP_EOL . "READING $url";
        $jso = file_get_contents($url);
        if (!$jso) trigger_error("READ FAILURE: $url", E_USER_ERROR);
        $data = json_decode($jso);
        if (!$data) trigger_error("JSON FAILURE: $url", E_USER_ERROR);
        if (!$data->list)
        {
            var_dump($data);
            trigger_error("DATA FAILURE: $url", E_USER_ERROR);
        }
        $sets = array_merge($sets, $data->list);
        $hasMore = $data->has_more;
        if (!$hasMore)
            break;
        $page++;
    } while ($hasMore);
}

$JSON= json_encode($sets, JSON_PRETTY_PRINT);
echo '<pre>';
echo $new;

$user = "xx";
$pass = "xxx";

try
{
    $dbh = new PDO('mysql:host=localhost;dbname=xxx', $user, $pass);
    $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $dbh->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);






$stmt = $dbh->prepare("INSERT INTO DMVideosStage
(id, title, channel, owner)
    values(:id,:title, :channel, :owner)
    on duplicate key update title= :title, channel= :channel, owner= :owner");


//$stmt->bindParam(':id', $id);
    $stmt->bindParam(':id', $JSON->id, PDO::PARAM_STR);
$stmt->bindParam(':title', $JSON->title, PDO::PARAM_STR);
$stmt->bindParam(':channel', $JSON->channel, PDO::PARAM_STR);
$stmt->bindParam(':owner', $JSON->owner, PDO::PARAM_STR);

$stmt->execute() ;

$dbh = null;
}

catch(PDOException $e)
{
    print "Error!: " . $e->getMessage() . "<br/>";
    die();
}

Select allOpen in new window