PHP PDO ระบบเพิ่มข้อมูลพนักงาน Insert Data & Inner Join

สวัสดีครับ ในบทความนี้จะแจกตัวอย่างโค้ดระบบเพิ่มข้อมูลพนักงาน Insert Data & Inner Join 2 ตาราง แบบง่ายๆ โดยเขียนในรูปแบบ PHP PDO รองรับการทำงาน PHP7 และ PHP8 สำหรับเอาไปศึกษาและพัฒนาต่อยอดครับ *ฝึกไว้ครับเผื่อได้ใช้

ตัวอย่างระบบที่มีการจัดการข้อมูลพนักงานเข้ามาเกี่ยวข้อง
1.ระบบคลังข้อมูลวิจัย คลิก
2.ระบบหนังสือเวียน คลิก
3.ระบบแจ้งซ่อม คลิก
4.ระบบยืมคืนครุภัณฑ์ คลิก
5.ระบบฐานข้อมูลศิษย์เก่า คลิก
6.ระบบอื่นๆ เพิ่มเติม คลิก

รวมคลิปสอนปรับพื้นฐาน ภาษา php ฟรี 100 คลิป ++ https://devbanban.com/?p=3940

โค้ดประกอบด้วย

PHP PDO
MySQL Inner Join
HTML
Bootstrap5
Sweet Alert
เลือกตำแหน่งงาน
ป้องกันข้อมูลซ้ำ
แสดงข้อมูลจากตาราง

มาเริ่มทำ workshop กันครับ *คอมเม้นอยู่ในโค้ด

0.รวม Workshop PHP PDO ก่อนหน้าคลิก

1.ให้สร้างฐานข้อมูลก่อนครับ เช่น ฐานข้อมูลชื่อ workshop_pdo

2.ตารางเก็บข้อมูลตำแหน่งชื่อ tbl_position (จากนั้นไปที่เมนู sql คัดลอกโค้ดไปวางและ go)

CREATE TABLE `tbl_position` (
  `p_id` int(11) NOT NULL,
  `p_name` varchar(100) NOT NULL COMMENT 'ชื่อตำแหน่ง'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

INSERT INTO `tbl_position` (`p_id`, `p_name`) VALUES
(1, 'หัวหน้าฝ่าย'),
(2, 'พนักงานบัญชี'),
(3, 'พนักงานทั่วไป'),
(4, 'ช่างคอมพิวเตอร์');

ALTER TABLE `tbl_position`
  ADD PRIMARY KEY (`p_id`);
ALTER TABLE `tbl_position`
  MODIFY `p_id` int(11) NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=5;

CREATE TABLE `tbl_position` (

`p_id` int(11) NOT NULL,

`p_name` varchar(100) NOT NULL COMMENT 'ชื่อตำแหน่ง'

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

INSERT INTO `tbl_position` (`p_id`, `p_name`) VALUES

(1, 'หัวหน้าฝ่าย'),

(2, 'พนักงานบัญชี'),

(3, 'พนักงานทั่วไป'),

(4, 'ช่างคอมพิวเตอร์');

ALTER TABLE `tbl_position`

ADD PRIMARY KEY (`p_id`);

ALTER TABLE `tbl_position`

MODIFY `p_id` int(11) NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=5;

3.ตารางเก็บข้อมูลพนักงานชื่อ tbl_emp (จากนั้นไปที่เมนู sql คัดลอกโค้ดไปวางและ go)

CREATE TABLE `tbl_emp` (
  `no` int(11) NOT NULL,
  `ref_p_id` int(11) NOT NULL COMMENT 'รหัสตำแหน่ง',
  `emp_name` varchar(100) NOT NULL COMMENT 'ชื่อ',
  `emp_surname` varchar(100) NOT NULL COMMENT 'นามสกุล',
  `emp_phone` varchar(20) NOT NULL COMMENT 'เบอร์โทร'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

ALTER TABLE `tbl_emp`
  ADD PRIMARY KEY (`no`);
ALTER TABLE `tbl_emp`
  MODIFY `no` int(11) NOT NULL AUTO_INCREMENT;

CREATE TABLE `tbl_emp` (

`no` int(11) NOT NULL,

`ref_p_id` int(11) NOT NULL COMMENT 'รหัสตำแหน่ง',

`emp_name` varchar(100) NOT NULL COMMENT 'ชื่อ',

`emp_surname` varchar(100) NOT NULL COMMENT 'นามสกุล',

`emp_phone` varchar(20) NOT NULL COMMENT 'เบอร์โทร'

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

ALTER TABLE `tbl_emp`

ADD PRIMARY KEY (`no`);

ALTER TABLE `tbl_emp`

MODIFY `no` int(11) NOT NULL AUTO_INCREMENT;

4.สร้างโฟลเดอร์สำหรับทดสอบ เช่น ชื่อโฟลเดอร์ workshop_pdo *สำหรับคนที่เพิ่งฝึกยังไม่เข้าใจข้อนี้ว่าต้องสร้างไว้ที่ไหน ให้ดูคลิปชุดนี้ก่อน รวมคลิปสอนปรับพื้นฐาน ภาษา php ฟรี 100 คลิป ++ https://devbanban.com/?p=3940

5.ไฟล์เชื่อมต่อฐานข้อมูล ชื่อไฟล์ connect.php

<?php
$servername = "localhost";
$username = "root";
$password = "yourpassword"; //ไม่ได้ตั้งรหัสผ่านก็ลบ  yourpassword ออก

try {
  $conn = new PDO("mysql:host=$servername;dbname=workshop_pdo;charset=utf8", $username, $password);
  // set the PDO error mode to exception
  $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  //echo "Connected successfully";
} catch(PDOException $e) {
  echo "Connection failed: " . $e->getMessage();
}
//Set ว/ด/ป เวลา ให้เป็นของประเทศไทย
    date_default_timezone_set('Asia/Bangkok');
?>

<?php

$servername = "localhost";

$username = "root";

$password = "yourpassword"; //ไม่ได้ตั้งรหัสผ่านก็ลบ yourpassword ออก

try {

$conn = new PDO("mysql:host=$servername;dbname=workshop_pdo;charset=utf8", $username, $password);

// set the PDO error mode to exception

$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

//echo "Connected successfully";

} catch(PDOException $e) {

echo "Connection failed: " . $e->getMessage();

}

//Set ว/ด/ป เวลา ให้เป็นของประเทศไทย

date_default_timezone_set('Asia/Bangkok');

6.ไฟล์ workshop formAddEmp.php *คอมเม้นอยู่ในโค้ด

 <?php 
//ไฟล์เชื่อมต่อฐานข้อมูล
    require_once 'connect.php';
 ?>
 <!DOCTYPE html>
<html lang="en">
  <head>
    <meta charset="UTF-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <link href="https://cdn.jsdelivr.net/npm/bootstrap@5.1.1/dist/css/bootstrap.min.css" rel="stylesheet" integrity="sha384-F3w7mX95PdgyTmZZMECAngseQB83DfGTowi0iMjiWaeVhAn4FJkqJByhZMI3AhiU" crossorigin="anonymous">
    <title>Basic PHP PDO ระบบเพิ่มข้อมูลพนักงาน by devbanban.com 2021</title>
  </head>
  <body>
    <div class="container">
      <div class="row">
        <div class="col-md-2"></div>
        <div class="col-md-8"> <br> 
          <h5>PHP PDO :: ระบบเพิ่มข้อมูลพนักงาน : Insert Data & Inner Join</h5>

          <form action="" method="post">
            <div class="mb-2 row">
                <div class="col-sm-6">
                <select name="ref_p_id" class="form-control" required>
                  <option value="">-เลือกตำแหน่งงาน-</option>
                  <?php
                  //คิวรี่ข้อมูลตำแหน่ง เพื่อมาแสดงใน select/option
                  $stmt = $conn->prepare("SELECT* FROM tbl_position");
                  $stmt->execute();
                  $result = $stmt->fetchAll();
                  foreach($result as $row) {
                  ?>
                  <option value="<?= $row['p_id'];?>">-<?= $row['p_name'];?></option>
                <?php } ?>
                </select>
              </div>
               <div class="col-sm-6">
                  <input type="text" name="xxx" class="form-control" required  placeholder="อื่นๆ ตาม Requirements..." disabled>
                </div>
              </div>
            <div class="mb-2 row">
                <div class="col-sm-6">
                <input type="text" name="emp_name" class="form-control" required minlength="3" placeholder="ชื่อ">
              </div>
             <!--  </div>
              <div class="mb-2"> -->
                <div class="col-sm-6">
                  <input type="text" name="emp_surname" class="form-control" required minlength="3" placeholder="นามสกุล">
                </div>
                </div>
                <div class="mb-2 row">
                <div class="col-sm-6">
                  <input type="text" name="emp_phone" class="form-control" required minlength="10" maxlength="10" placeholder="เบอร์โทร">
                </div>
                <div class="col-sm-6">
                  <input type="text" name="xxx" class="form-control" required  placeholder="อื่นๆ ตาม Requirements..." disabled>
                </div>
                </div>
                <div class="mb-2 row">
                <div class="d-grid gap-2 col-sm-12 mb-3">
                <button type="submit" class="btn btn-primary">เพิ่มข้อมูล</button>
              </div>
            </div>
              </form>

              <h5>รายชื่อพนักงาน</h5>
               <table class="table table-striped  table-hover table-responsive table-bordered">
                        <thead>
                            <tr>
                                <th width="5%">ลำดับ</th>
                                <th width="25%">ตำแหน่ง</th>
                                <th width="25%">ชื่อ</th>
                                <th width="25%">นามสกุล</th>
                                <th width="20%">เบอร์โทร</th>
                            </tr>
                        </thead>
                        <tbody>
                            <?php
                            //คิวรี่ข้อมูลมาแสดงในตาราง โดยเทียบข้อมูลระหว่างตารางตำแหน่งงานกับตารางพนักงานที่มีคอลัมภ์สัมพันธ์กัน ก็คือ p_id กับ ref_p_id
                            $stmtEmp = $conn->prepare("
                              SELECT e.*, p.p_name #ตารางพนักงานเอามาทุกคอลัมภ์ , ตารางตำแหน่งเอามาแค่ชื่อตำแหน่ง
                              FROM tbl_emp AS e  #AS e คือการแทนชื่อตารางให้ชื่อสั้นลงในตอนที่เอาไป inner join โค้ดจะดูไม่รก
                              INNER JOIN tbl_position AS P ON e.ref_p_id=p.p_id
                              ORDER BY e.no ASC #เรียงลำดับข้อมูลจากน้อยไปมาก
                              ");
                            $stmtEmp->execute();
                            $resultEmp = $stmtEmp->fetchAll();
                            foreach($resultEmp as $rowEmp) {
                            ?>
                            <tr>
                                <td><?= $rowEmp['no'];?></td>
                                <td><?= $rowEmp['p_name'];?></td>
                                <td><?= $rowEmp['emp_name'];?></td>
                                <td><?= $rowEmp['emp_surname'];?></td>
                                <td><?= $rowEmp['emp_phone'];?></td>
                            </tr>
                            <?php } ?>
                        </tbody>
                    </table>
            </div>
          </div>
        </div>
        <center>คอร์สออนไลน์  <a href="https://devbanban.com/?cat=250" target="_blank"> คลิก </a> </center>
      </body>
    </html>  


    <?php

  //print_r($_POST); //ตรวจสอบมี input อะไรบ้าง และส่งอะไรมาบ้าง 
  //exit();
 //ถ้ามีค่าส่งมาจากฟอร์ม
    if(isset($_POST['emp_name']) && isset($_POST['emp_surname']) && isset($_POST['emp_phone']) && isset($_POST['ref_p_id'])){
    // sweet alert 
    echo '
    <script src="https://code.jquery.com/jquery-2.1.3.min.js"></script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/sweetalert/1.1.3/sweetalert-dev.js"></script>
    <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/sweetalert/1.1.3/sweetalert.css">';

    //ไฟล์เชื่อมต่อฐานข้อมูล
    //require_once 'connect.php';
    //ประกาศตัวแปรรับค่าจากฟอร์ม
    $ref_p_id = $_POST['ref_p_id'];
    $emp_name = $_POST['emp_name'];
    $emp_surname = $_POST['emp_surname'];
    $emp_phone = $_POST['emp_phone'];

    //check duplicate เช็คขากชื่อ-นามสกุล
      $stmt = $conn->prepare("SELECT no FROM tbl_emp WHERE emp_name = :emp_name AND emp_surname = :emp_surname");
      $stmt->execute(array(':emp_name' => $emp_name, ':emp_surname' => $emp_surname ));
      //ถ้าชื่อ-นามสกุลซ้ำ ให้เด้งกลับไปหน้าฟอร์ม ปล.ข้อความใน sweetalert ปรับแต่งได้ตามความเหมาะสม
      if($stmt->rowCount() > 0){
          echo '<script>
                       setTimeout(function() {
                        swal({
                            title: "รายชื่อซ้ำ !! ",  
                            text: "กรุณาเพิ่มข้อมูลใหม่อีกครั้ง",
                            type: "warning"
                        }, function() {
                            window.location = "formAddEmp.php"; //หน้าที่ต้องการให้กระโดดไป
                        });
                      }, 1000);
                </script>';
      }else{ //ถ้าไม่ซ้ำ เก็บข้อมูลลงตาราง
              //sql insert
              $stmt = $conn->prepare("INSERT INTO tbl_emp 
                (ref_p_id, emp_name, emp_surname, emp_phone)
                VALUES 
                (:ref_p_id, :emp_name, :emp_surname, :emp_phone)");

              //brndParam ข้อความทั่วไป = PARAM_STR, ตัวเลข = PARAM_INT
              $stmt->bindParam(':emp_name', $emp_name, PDO::PARAM_STR);
              $stmt->bindParam(':emp_surname', $emp_surname , PDO::PARAM_STR);
              $stmt->bindParam(':emp_phone', $emp_phone , PDO::PARAM_STR);
              $stmt->bindParam(':ref_p_id', $ref_p_id , PDO::PARAM_INT);
              $result = $stmt->execute();
              $conn = null; //close connect db
              if($result){
                  echo '<script>
                       setTimeout(function() {
                        swal({
                            title: "เพิ่มข้อมูลพนักงานสำเร็จ",
                            type: "success"
                        }, function() {
                            window.location = "formAddEmp.php"; //หน้าที่ต้องการให้กระโดดไป
                        });
                      }, 1000);
                  </script>';
              }else{
                 echo '<script>
                       setTimeout(function() {
                        swal({
                            title: "เกิดข้อผิดพลาด",
                            type: "error"
                        }, function() {
                            window.location = "formAddEmp.php"; //หน้าที่ต้องการให้กระโดดไป
                        });
                      }, 1000);
                  </script>';
              }
             
        } //else chk dup
    } //isset 
    //devbanban.com
    ?>

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

<?php

//ไฟล์เชื่อมต่อฐานข้อมูล

require_once 'connect.php';

<!DOCTYPE html>

<head>

<title>Basic PHP PDO ระบบเพิ่มข้อมูลพนักงาน by devbanban.com 2021</title>

</head>

<body>

<h5>PHP PDO :: ระบบเพิ่มข้อมูลพนักงาน : Insert Data & Inner Join</h5>

<option value="">-เลือกตำแหน่งงาน-</option>

<?php

//คิวรี่ข้อมูลตำแหน่ง เพื่อมาแสดงใน select/option

$stmt = $conn->prepare("SELECT* FROM tbl_position");

$stmt->execute();

$result = $stmt->fetchAll();

foreach($result as $row) {

<?php } ?>

</select>

</div>

</div>

</div>

<!-- </div>

</div>

</div>

</div>

</div>

</form>

<h5>รายชื่อพนักงาน</h5>

<thead>

<tr>

<th width="5%">ลำดับ</th>

<th width="25%">ตำแหน่ง</th>

<th width="25%">นามสกุล</th>

</tr>

</thead>

<tbody>

<?php

//คิวรี่ข้อมูลมาแสดงในตาราง โดยเทียบข้อมูลระหว่างตารางตำแหน่งงานกับตารางพนักงานที่มีคอลัมภ์สัมพันธ์กัน ก็คือ p_id กับ ref_p_id

$stmtEmp = $conn->prepare("

SELECT e.*, p.p_name #ตารางพนักงานเอามาทุกคอลัมภ์ , ตารางตำแหน่งเอามาแค่ชื่อตำแหน่ง

FROM tbl_emp AS e #AS e คือการแทนชื่อตารางให้ชื่อสั้นลงในตอนที่เอาไป inner join โค้ดจะดูไม่รก

INNER JOIN tbl_position AS P ON e.ref_p_id=p.p_id

ORDER BY e.no ASC #เรียงลำดับข้อมูลจากน้อยไปมาก

");

$stmtEmp->execute();

$resultEmp = $stmtEmp->fetchAll();

foreach($resultEmp as $rowEmp) {

<tr>

</tr>

<?php } ?>

</tbody>

</table>

</div>

<center>คอร์สออนไลน์ <a href="https://devbanban.com/?cat=250" target="_blank"> คลิก </a> </center>

</body>

</html>

<?php

//print_r($_POST); //ตรวจสอบมี input อะไรบ้าง และส่งอะไรมาบ้าง

//exit();

//ถ้ามีค่าส่งมาจากฟอร์ม

if(isset($_POST['emp_name']) && isset($_POST['emp_surname']) && isset($_POST['emp_phone']) && isset($_POST['ref_p_id'])){

// sweet alert

echo '

//ไฟล์เชื่อมต่อฐานข้อมูล

//require_once 'connect.php';

//ประกาศตัวแปรรับค่าจากฟอร์ม

$ref_p_id = $_POST['ref_p_id'];

$emp_name = $_POST['emp_name'];

$emp_surname = $_POST['emp_surname'];

$emp_phone = $_POST['emp_phone'];

//check duplicate เช็คขากชื่อ-นามสกุล

$stmt = $conn->prepare("SELECT no FROM tbl_emp WHERE emp_name = :emp_name AND emp_surname = :emp_surname");

$stmt->execute(array(':emp_name' => $emp_name, ':emp_surname' => $emp_surname ));

//ถ้าชื่อ-นามสกุลซ้ำ ให้เด้งกลับไปหน้าฟอร์ม ปล.ข้อความใน sweetalert ปรับแต่งได้ตามความเหมาะสม

if($stmt->rowCount() > 0){

echo '<script>

setTimeout(function() {

swal({

title: "รายชื่อซ้ำ !! ",

text: "กรุณาเพิ่มข้อมูลใหม่อีกครั้ง",

type: "warning"

}, function() {

window.location = "formAddEmp.php"; //หน้าที่ต้องการให้กระโดดไป

});

}, 1000);

</script>';

}else{ //ถ้าไม่ซ้ำ เก็บข้อมูลลงตาราง

//sql insert

$stmt = $conn->prepare("INSERT INTO tbl_emp

(ref_p_id, emp_name, emp_surname, emp_phone)

VALUES

(:ref_p_id, :emp_name, :emp_surname, :emp_phone)");

//brndParam ข้อความทั่วไป = PARAM_STR, ตัวเลข = PARAM_INT

$stmt->bindParam(':emp_name', $emp_name, PDO::PARAM_STR);

$stmt->bindParam(':emp_surname', $emp_surname , PDO::PARAM_STR);

$stmt->bindParam(':emp_phone', $emp_phone , PDO::PARAM_STR);

$stmt->bindParam(':ref_p_id', $ref_p_id , PDO::PARAM_INT);

$result = $stmt->execute();

$conn = null; //close connect db

if($result){

echo '<script>

setTimeout(function() {

swal({

title: "เพิ่มข้อมูลพนักงานสำเร็จ",

type: "success"

}, function() {

window.location = "formAddEmp.php"; //หน้าที่ต้องการให้กระโดดไป

});

}, 1000);

</script>';

}else{

echo '<script>

setTimeout(function() {

swal({

title: "เกิดข้อผิดพลาด",

type: "error"

}, function() {

window.location = "formAddEmp.php"; //หน้าที่ต้องการให้กระโดดไป

});

}, 1000);

</script>';

}

} //else chk dup

} //isset

//devbanban.com

7.ผลการทำงาน

ลองเอาไปประยุกต์ใช้ดูครับ และฝากติดตาม workshop ต่อๆ ไปด้วยครับผม

Bootstrap5 : https://getbootstrap.com/
แหล่งศึกษา PDO เพิ่มเติม : https://websitebeaver.com/php-pdo-vs-mysqli
List of PDOStatement::bindParam data_type parameters : https://www.php.net/manual/en/pdo.constants.php

ขอแนะนำระบบพร้อมใช้งาน *รายละเอียดและราคาอยู่ใต้คลิป

ระบบพร้อมใช้ทั้งหมด คลิก

ร่วมสนับสนุน ค่ากาแฟ ค่าโฮส devbanban.com ได้ที่

ธนาคารกรุงไทย สาขาเดอะมอลล์ท่าพระ
ชื่อบัญชี นายพิศิษฐ์ บวรเลิศสุธี เลขที่ 878-0-17747-6
————————————————————————————
ธนาคารไทยพาณิชย์ สาขามหาวิทยาลัยราชภัฏธนบุรี
ชื่อบัญชี นายพิศิษฐ์ บวรเลิศสุธี เลขที่ 406-359094-1

fanpage : https://www.facebook.com/sornwebsites/

devbanban

PHP PDO ระบบเพิ่มข้อมูลพนักงาน Insert Data & Inner Join

Byพิศิษฐ์ บวรเลิศสุธี

Related

Related Post

ระบบบริหารบุคลากร ระบบ HR + ระบบบันทึกเวลาเข้างาน

ฟรีคลิปสอนทำเว็บไซต์ PHP PDO MySQL AdminLTE3 2024

ระบบหอพัก , อพาร์ทเม้นท์ รายวัน รายเดือน ราคาเบาๆ เอาไปต่อยอดได้ 2024

You missed

ระบบบริหารบุคลากร ระบบ HR + ระบบบันทึกเวลาเข้างาน

ฟรีคลิปสอนทำเว็บไซต์ PHP PDO MySQL AdminLTE3 2024

ระบบหอพัก , อพาร์ทเม้นท์ รายวัน รายเดือน ราคาเบาๆ เอาไปต่อยอดได้ 2024

แจกฟรี To-do list Ui ออกแบบจาก Bootstrap v5.3

Byพิศิษฐ์ บวรเลิศสุธี

Share this:

Related

Related Post

You missed