▶ nodejs 의 App 포스팅은 생활코딩에서 제공하는 강의를 기반으로 한 학습내용입니다.
▶ 출처 : 생활코딩 > WEB > WEB2 - Node.js > Node.js - MySQL (https://opentutorials.org/course/3347)
▷ 해당 학습 과정의 프로젝트를 저의 Github Repository 에도 게시하였습니다. (devdhjo/nodejs_opentutorials)
◇ MySQL 모듈을 이용해서 Node.js 홈페이지에 글을 작성하는 방법을 학습합니다.
1. main.js 파일의 ‘/create’ 처리 코드를 수정합니다.
1) 파일 목록을 가져오는 함수 readdir 를 삭제하고, 데이터베이스 목록을 조회하는 쿼리를 추가합니다.
- 변수 filelist 를 삭제하고, 쿼리 결과가 담긴 변수 topics 를 사용합니다.
var app = http.createServer(function(request,response) {
...
if(pathname == '/') {
...
} else if (pathname == '/create') {
- fs.readdir('./data', 'utf8', function(error, filelist) {
+ db.query('SELECT * FROM topic', function(error, topics) {
var title = 'WEB - Create';
- var list = template.list(filelist);
+ var list = template.list(topics);
var html = template.HTML(title, list, `
...
`, '');
response.writeHead(200);
response.end(html);
})
} else if (pathname == '/create_process') {
...
2. main.js 파일의 ‘/create_process’ 처리 코드를 수정합니다.
1) 파일을 생성하는 함수 writeFile 를 삭제하고, 데이터베이스를 입력하는 쿼리를 추가합니다.
-
쿼리 실행에서 에러가 발생한 경우 처리를 위한 코드도 함께 추가합니다.
-
쿼리 실행 콜백함수의 writeHead 에서 지정하는 Location 을 현재 입력된 데이터의 id 로 변경합니다.
– 콜백 함수의 결과 객체에서 ‘insertId’ 로 접근하면 현재 입력된 데이터의 id 를 가져올 수 있습니다.
– 참고자료 (npm > mysql > Getting the id of an inserted row)
var app = http.createServer(function(request,response){
...
if(pathname == '/') {
...
} else if (pathname == '/create') {
...
} else if (pathname == '/create_process') {
var body = '';
request.on('data', function(data) {
body = body + data;
})
request.on('end', function() {
var post = qs.parse(body);
- var title = post.title;
- var description = post.description;
- fs.writeFile(`data/${title}`, description, 'utf8', function(err) {
+ db.query(
+ `INSERT INTO topic (title, description, created, author_id) VALUES (?, ?, NOW(), ?);`,
+ [post.title, post.description, 1], function(error, result) {
+ if(error) throw error;
- response.writeHead(302, {Location: `/?id=${title}`});
+ response.writeHead(302, {Location: `/?id=${result.insertId}`});
response.end();
})
})
} else if (pathname == '/update') {
...
3. 수정 된 main.js 를 실행합니다.
- window + R → cmd 실행
D:\workspace\nodejs\webapp>node main.js
- main.js (수정사항 보기)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
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
var http = require('http');
var fs = require('fs');
var url = require('url');
var qs = require('querystring');
var template = require('./lib/template.js');
var path = require('path');
var sanitizeHtml = require('sanitize-html');
var mysql = require('mysql');
var db = mysql.createConnection({
host : 'localhost',
user : 'TESTUSER',
password : '1234',
database : 'TESTDB'
});
db.connect();
var app = http.createServer(function(request,response) {
var _url = request.url;
var queryData = url.parse(_url, true).query;
var pathname = url.parse(_url, true).pathname;
if(pathname == '/') {
if(queryData.id == undefined) {
db.query('SELECT * FROM topic', function(error, topics) {
var title = 'Welcome';
var description = 'Hello, Node.js';
var list = template.list(topics);
var html = template.HTML(title, list,
`<h2>${title}</h2><p>${description}</p>`,
`<a href="/create">Create</a>`);
response.writeHead(200);
response.end(html);
})
} else {
db.query('SELECT * FROM topic', function(error, topics) {
db.query(`SELECT * FROM topic WHERE id=?`, [queryData.id], function(error2, topic) {
var title = topic[0].title;
var description = topic[0].description;
var list = template.list(topics);
var html = template.HTML(title, list,
`<h2>${title}</h2><p>${description}</p>`,
`<a href="/create">Create</a> <a href="/update?id=${queryData.id}">Update</a>
<form action="delete_process" method="post">
<input type="hidden" name="id" value="${queryData.id}">
<input type="submit" value="Delete">
</form>
`);
response.writeHead(200);
response.end(html);
})
})
}
} else if (pathname == '/create') {
db.query('SELECT * FROM topic', function(error, topics) {
var title = 'Welcome - Create';
var list = template.list(topics);
var html = template.HTML(title, list,
`<form action="/create_process" method="post">
<p><input type="text" name="title" placeholder="title"></p>
<p><textarea name="description" placeholder="description"></textarea></p>
<p><input type="submit"></p>
</form>
`, ``);
response.writeHead(200);
response.end(html);
})
} else if (pathname == '/create_process') {
var body = '';
request.on('data', function(data) {
body = body + data;
})
request.on('end', function() {
var post = qs.parse(body);
db.query(
`INSERT INTO topic (title, description, created, author_id) VALUES (?, ?, NOW(), ?);`,
[post.title, post.description, 1], function(error, result) {
if(error) throw error;
response.writeHead(302, {Location: `/?id=${result.insertId}`});
response.end();
})
})
} else if (pathname == '/update') {
fs.readdir('./data', function(error, filelist) {
var filteredId = path.parse(queryData.id).base;
fs.readFile(`data/${filteredId}`, 'utf8', function(err, description) {
var title = queryData.id;
var list = template.list(filelist);
var html = template.HTML(title, list,
`<form action="/update_process" method="post">
<input type="hidden" name="id" value="${title}">
<p><input type="text" name="title" placeholder="title" value="${title}"></p>
<p><textarea name="description" placeholder="description">${description}</textarea></p>
<p><input type="submit"></p>
</form>
`, `<a href="/create">Create</a> <a href="/update?id=${title}">Update</a>`);
response.writeHead(200);
response.end(html);
})
})
} else if (pathname == '/update_process') {
var body = '';
request.on('data', function(data) {
body = body + data;
})
request.on('end', function() {
var post = qs.parse(body);
var id = post.id;
var title = post.title;
var description = post.description;
fs.rename(`data/${id}`, `data/${title}`, function(error){
fs.writeFile(`data/${title}`, description, 'utf8', function(err) {
response.writeHead(302, {Location: `/?id=${title}`});
response.end();
})
})
})
} else if (pathname == '/delete_process') {
var body = '';
request.on('data', function(data) {
body = body + data;
})
request.on('end', function() {
var post = qs.parse(body);
var id = post.id;
var filteredId = path.parse(id).base;
fs.unlink(`data/${filteredId}`, function(error){
response.writeHead(302, {Location: `/`});
response.end();
})
})
} else {
response.writeHead(404);
response.end('Not found');
}
});
app.listen(3000);