Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <?php
- class orders
- {
- public $orderNumber;
- public $orderDate;
- public $requiredDate;
- public $shippedDate;
- public $status;
- public $comments;
- public $customerNumber;
- public $orderDetails;
- }
- class ordersDetail
- {
- //public $orderNumber;
- public $productCode;
- public $quantityOrdered;
- public $priceEach;
- public $orderLineNumber;
- }
- $db_host="localhost"; $db_nom="practicaBdd"; $db_user="root"; $db_pass="";
- $conn = mysqli_connect($db_host, $db_user, $db_pass, $db_nom) ;
- $result = mysqli_query($conn, "SELECT o.orderNumber, o.orderDate, o.requiredDate, o.shippedDate, o.status,
- o.comments, o.customerNumber,od.landProduct,od.seaProduct,od.airProduct,
- od.quantityOrdered, od.priceEach, od.orderLineNumber
- FROM Orders AS o, orderDetails AS od WHERE od.ordernumber=o.ordernumber ");
- try {
- $manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");
- while ($row = mysqli_fetch_array($result)) {
- $e = new orders();
- $e->orderNumber = $row["orderNumber"];
- $e->orderDate = $row["orderDate"];
- $e->requiredDate = $row["requiredDate"];
- $e->shippedDate = $row["shippedDate"];
- $e->status = $row["status"];
- $e->comments = $row["comments"];
- $e->customerNumber = $row["customerNumber"];
- $e->orderDetails = new ordersDetail();
- if($row["landProduct"] == NULL and $row["airProduct"] == NULL) $e->orderDetails->productCode = $row["seaProduct"];
- else if($row["seaProduct"] == NULL and $row["airProduct"] == NULL) $e->orderDetails->productCode = $row["landProduct"];
- else $e->orderDetails->productCode = $row["airProduct"];
- $e->orderDetails->quantityOrdered = $row["quantityOrdered"];
- $e->orderDetails->priceEach = $row["priceEach"];
- $e->orderDetails->orderLineNumber = $row["orderLineNumber"];
- $bulk = new MongoDB\Driver\BulkWrite;
- $bulk->insert($e);
- $res = $manager->executeBulkWrite('test.orders', $bulk);
- var_dump($res);echo "<br>";
- var_dump($e);echo "<br>";
- }
- mysqli_free_result($result);
- mysqli_close($conn);
- }catch(Exception $e) {
- echo "EXCEPTION: ".$e->getMessage(), "\n";
- exit;
- }
- ?>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement