Advertisement
Guest User

Untitled

a guest
Jun 1st, 2018
107
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
JSON 2.12 KB | None | 0 0
  1. <?php
  2. class orders
  3. {
  4.     public $orderNumber;
  5.     public $orderDate;
  6.     public $requiredDate;
  7.     public $shippedDate;
  8.     public $status;
  9.     public $comments;
  10.     public $customerNumber;
  11.     public $orderDetails;
  12.    
  13.        
  14. }
  15.  
  16. class ordersDetail
  17. {
  18.     //public $orderNumber;
  19.     public $productCode;
  20.     public $quantityOrdered;
  21.     public $priceEach;
  22.     public $orderLineNumber;
  23. }
  24.  
  25. $db_host="localhost"; $db_nom="practicaBdd"; $db_user="root"; $db_pass="";
  26. $conn = mysqli_connect($db_host, $db_user, $db_pass, $db_nom) ;
  27.  
  28. $result = mysqli_query($conn, "SELECT o.orderNumber, o.orderDate, o.requiredDate, o.shippedDate, o.status,
  29.                                 o.comments, o.customerNumber,od.landProduct,od.seaProduct,od.airProduct,
  30.                                 od.quantityOrdered, od.priceEach, od.orderLineNumber
  31.                                 FROM Orders AS o, orderDetails AS od WHERE od.ordernumber=o.ordernumber ");
  32.  
  33. try {
  34.     $manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");
  35.    
  36.     while ($row = mysqli_fetch_array($result))  {
  37.         $e = new orders();
  38.         $e->orderNumber = $row["orderNumber"];
  39.         $e->orderDate = $row["orderDate"];
  40.         $e->requiredDate = $row["requiredDate"];
  41.         $e->shippedDate = $row["shippedDate"];
  42.         $e->status = $row["status"];
  43.         $e->comments = $row["comments"];
  44.         $e->customerNumber = $row["customerNumber"];
  45.         $e->orderDetails = new ordersDetail();
  46.         if($row["landProduct"] == NULL and $row["airProduct"] == NULL) $e->orderDetails->productCode = $row["seaProduct"];
  47.         else if($row["seaProduct"] == NULL and $row["airProduct"] == NULL) $e->orderDetails->productCode = $row["landProduct"];
  48.         else $e->orderDetails->productCode = $row["airProduct"];
  49.         $e->orderDetails->quantityOrdered = $row["quantityOrdered"];
  50.         $e->orderDetails->priceEach = $row["priceEach"];
  51.         $e->orderDetails->orderLineNumber = $row["orderLineNumber"];
  52.        
  53.        
  54.        
  55.  
  56.         $bulk = new MongoDB\Driver\BulkWrite;
  57.        
  58.         $bulk->insert($e);
  59.  
  60.         $res = $manager->executeBulkWrite('test.orders', $bulk);
  61.         var_dump($res);echo "<br>";
  62.         var_dump($e);echo "<br>";
  63.     }
  64.  
  65.     mysqli_free_result($result);
  66.     mysqli_close($conn);
  67.  
  68. }catch(Exception $e) {
  69.    echo "EXCEPTION: ".$e->getMessage(), "\n";
  70.    exit;
  71. }
  72. ?>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement