NodeJS

[NodeJS] - MySQL 연동하기(Connection Pool), insert문

Riucc 2018. 12. 3. 15:45

○ NodeJS - MySQL 연동하기(Connection Pool), insert문

 

※ Connection Pool 설정은 http://riucc.tistory.com/533 참조


// app.js


// 'pool.getConnection() -> connection.query() -> connection.release()' 코드 흐름을 따름


router.route('/process/notice_write_action').post(function(req, res) {

    // post로 전송한 데이터 받아옴(name = notice_title, name = notice_desc)

    var title = req.body.notice_title;   

    var desc = req.body.notice_desc;


    // 커넥션 풀에서 연결 객체를 가져옴

    pool.getConnection(function(err, conn) {

        if (err) {

            if (conn) {

                conn.release();  // 반드시 해제해야 함

             } 

            callback(err, null);

            return;

        }   

        console.log('데이터베이스 연결 스레드 아이디 : ' + conn.threadId);


        // 현재날짜 구하기

        var dt = new Date();

        var year = dt.getFullYear();

        var month = dt.getMonth() + 1;

        var day = dt.getDate();

        var hour = dt.getHours();

        var minute = dt.getMinutes();

        var second = dt.getSeconds();

        var current_date = (year + '-' + month + '-' + day + ' ' + hour + ':' 

        + minute + ':' + second);


       // 데이터들을 객체로 만듬(db속성:넣을 값)

        var data = {noticeTitle:title, noticeDesc:desc, noticeDate:current_date};

   

        // SQL 문을 실행함(set 으로 객체 만든거 가져다 사용)

        conn.query('insert into notice set ?', data, function(err, result) {

            conn.release();  // 반드시 해제해야 함(해제안할 시 DB연결 수가 계속 늘어남!!!)

                                  //  connectionLimit 값이 작을 경우 초과해서 서버 터짐  

            console.log(result);

            if(result) {

                console.log('정상적으로 공지사항 DB에 입력 완료');

                res.redirect('/process/notice');  

            } else {

                console.log('공지사항 DB에 입력 실패');

            }

        });

    });

});


// notice_write.ejs


<!-- 공지 제목 : notice_title, 공지 내용 : notice_desc -->
<div class="container">
<h3 style="margin-bottom: 30px; text-align: center;">공지사항 작성</h3>
<form method="post" action="/process/notice_write_action">
<div class="form-group">
<!-- Name field -->
<label class="control-label" for="name">공지 제목</label>
<input class="form-control" id="notice_title" name="notice_title"
type="text" />
</div>

<div class="form-group">
<!-- Message field -->
<label class="control-label" for="message">공지 내용</label>
<textarea class="form-control" cols="40" id="notice_desc" name="notice_desc"
rows="10"></textarea>
</div>

<div class="form-group">
<button class="btn btn-primary" name="submit" type="submit"
style="float: right;">작성</button>
</div>
</form>
</div>


저작자표시