01.
02.$serverName = "serverName\sqlexpress";
03.$connectionOptions = array(
04. "Database" => "old_database",
05. "UID" => "username",
06. "PWD" => "password"
07.);
08.$conn = sqlsrv_connect($serverName, $connectionOptions);
09.
10.
11.$oldData = array();
12.$query = "SELECT bill1, box1, weight1 FROM old_table";
13.$stmt = sqlsrv_query($conn, $query);
14.if ($stmt === false) {
15. die(print_r(sqlsrv_errors(), true));
16.}
17.while ($row = sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC)) {
18. $oldData[] = $row;
19.}
20.
21.
22.
23.foreach ($oldData as $row) {
24.
25. $billQuery = "INSERT INTO bill (bill_number) VALUES (?)";
26. $billParams = array($row['bill1']);
27. $billStmt = sqlsrv_prepare($conn, $billQuery, $billParams);
28. sqlsrv_execute($billStmt);
29.
30.
31. $boxQuery = "INSERT INTO box (box_number) VALUES (?)";
32. $boxParams = array($row['box1']);
33. $boxStmt = sqlsrv_prepare($conn, $boxQuery, $boxParams);
34. sqlsrv_execute($boxStmt);
35.
36.
37. $weightQuery = "INSERT INTO weight (weight_number) VALUES (?)";
38. $weightParams = array($row['weight1']);
39. $weightStmt = sqlsrv_prepare($conn, $weightQuery, $weightParams);
40. sqlsrv_execute($weightStmt);
41.
42.
43. $bill_id = sqlsrv_query($conn, "SELECT SCOPE_IDENTITY()")->fetch()[0];
44. $box_id = sqlsrv_query($conn, "SELECT SCOPE_IDENTITY()")->fetch()[0];
45. $weight_id = sqlsrv_query($conn, "SELECT SCOPE_IDENTITY()")->fetch()[0];
46.
47.
48. $bbwQuery = "INSERT INTO bill_box_weight (bill_id, box_id, weight_id) VALUES (?, ?, ?)";
49. $bbwParams = array($bill_id, $box_id, $weight_id);
50. $bbwStmt = sqlsrv_prepare($conn, $bbwQuery, $bbwParams);
51. sqlsrv_execute($bbwStmt);
52.}
...อ้างอิงตัวอย่างนี้แล้วประยุกต์ให้เข้ากับข้อมูลของตัวเอง)
