parse json
This commit is contained in:
parent
d74a01fa05
commit
e85c821dee
|
@ -1,12 +1,34 @@
|
|||
#! /usr/bin/php
|
||||
<?php
|
||||
include 'config.php';
|
||||
|
||||
$sql = "SELECT scans.id, content FROM scans inner join sites on sites.id=scans.site where sites.type='json' and parsed=0";
|
||||
$sql = "SELECT scans.id, content FROM scans where id = 2235";
|
||||
$sql = "SELECT scans.id, content FROM scans where site=7 and parsed=0";
|
||||
foreach ($pdo->query($sql) as $row){
|
||||
$fromJSON = json_decode($row['content']);
|
||||
foreach ($fromJSON->features as $feature){
|
||||
$feature = $feature->attributes;
|
||||
var_dump($feature);
|
||||
$place = $feature->Country_Region . '.' . $feature->Province_State;
|
||||
$amount = $feature->Confirmed;
|
||||
$cured = $feature->Recovered;
|
||||
$deaths = $feature->Deaths;
|
||||
|
||||
$sql = "INSERT INTO `data`(`scan`, `place`, `amount`, `deaths`, `cured`) VALUES (?,?,?,?,?)";
|
||||
$stmt = $pdo->prepare($sql);
|
||||
$stmt->bindParam(1, $row['id']);
|
||||
$stmt->bindParam(2, $place);
|
||||
$stmt->bindParam(3, $amount);
|
||||
$stmt->bindParam(4, $deaths);
|
||||
$stmt->bindParam(5, $cured);
|
||||
if (!$stmt->execute()){
|
||||
var_dump($stmt->errorInfo());
|
||||
}
|
||||
}
|
||||
|
||||
$sql = "UPDATE `scans` SET `parsed`=1 WHERE ?";
|
||||
$stmt = $pdo->prepare($sql);
|
||||
$stmt->bindParam(1, $row['id']);
|
||||
if (!$stmt->execute()){
|
||||
var_dump($stmt->errorInfo());
|
||||
}
|
||||
}
|
Loading…
Reference in New Issue