- 전체
- Sample DB
- database modeling
- [표준 SQL] Standard SQL
- G-SQL
- 10-Min
- ORACLE
- MS SQLserver
- MySQL
- SQLite
- postgreSQL
- 데이터아키텍처전문가 - 국가공인자격
- 데이터 분석 전문가 [ADP]
- [국가공인] SQL 개발자/전문가
- NoSQL
- hadoop
- hadoop eco system
- big data (빅데이터)
- stat(통계) R 언어
- XML DB & XQuery
- spark
- DataBase Tool
- 데이터분석 & 데이터사이언스
- Engineer Quality Management
- [기계학습] machine learning
- 데이터 수집 및 전처리
- 국가기술자격 빅데이터분석기사
- 암호화폐 (비트코인, cryptocurrency, bitcoin)
NoSQL [WebApp / Express] 간단한 MongoDB Middleware 만들기
2020.12.29 15:45
[WebApp / Express] 간단한 MongoDB Middleware 만들기
이번 글에서는 MongoDB의 ODM(Object Data Mapping) 툴인 mongoose를 이용하여 간단한 MongoDB Middleware를 만들어 보도록 한다.
Part 1 - Express 프로젝트 생성
우선 Express 프로젝트를 생성한다:
$ express my-project && cd my-project
생성된 프로젝트 경로에 mongoose ODM을 설치한다:
$ npm install mongoose
app.js에서 Server를 생성한다 (포트번호는 3000으로 지정하였다):
[{EXPRESS_ROOT}/app.js]
|
1
2
3
4
5
6
7
8
|
//////////////////////////////////////////////////////// ------- creates Server -------// port setupapp.set('port', process.env.PORT || 3000); var server = app.listen(app.get('port'), function() { console.log('Express server listening on port ' + server.address().port);}); |
Part 2 - mongoose connection 설정
Mongoose Connection을 하기에 앞서 MongoDB를 실행한다. 예를 들어, Terminal을 실행하여 다음 명령을 입력한다:
$ mongod --dbpath {YOUR_DB_PATH}
우선 mongoose를 로딩하고, Mongoose Connection을 위해 URI는 다음과 같이 정의하였다:
[{EXPRESS_ROOT}/app.js]
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
var mongoose = require('mongoose');...//////////////////////////////////////////////////////// ------- mongoose connections -------mongoose.connect(uri, function(req, res) { console.log('mongodb users connected');});... |
Part 3 - 간단한 mongoose 미들웨어 작성
Data Schema는 사용자의 ID, 이름, 패스워드로 구성하였으며, 다음과 같이 코드를 작성한다:
[{EXPRESS_ROOT}/routes/mongodb.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
|
var mongoose = require('mongoose');var myCount = 0;// Users Schemavar UserSchema = mongoose.Schema({ userId: String, userName: String, password: String});// compiles our schema into a model var Users = mongoose.model('Users', UserSchema);//////////////////////////////////////////////////////////////////////// insert an userexports.InsertUser = function(userId, userName, userPwd) { var myUser = new Users({ userId: userId, userName: userName, password: userPwd }); // save an user myUser.save(function(err) { console.log('A new user is inserted.'); console.log(''); });};//////////////////////////////////////////////////////////////////////// remove the userexports.RemoveUserById = function(userId) { // find the user Users.findOne({userId: userId}, function(err, data) { if(data != null) { console.log('The user is found.'); console.log(''); Users.remove({userId: userId}, function(err, data) { console.log('The user is removed.'); console.log(''); }); } else { console.log('Cannot find the user.'); console.log(''); } });};//////////////////////////////////////////////////////////////////////// update the userexports.UpdateUser = function(userId, newData) { // find the user Users.findOne({userId: userId}, function(err, data) { if(data != null) { console.log('The user is found.'); console.log(''); Users.update({userId: userId}, newData, function(err, data) { console.log('Successfully changed user account.'); console.log(''); }); } else { console.log('Cannot find the user.'); console.log(''); } });};//////////////////////////////////////////////////////////////////////// user countsexports.UserCounts = function() { Users.count({}, function(err, count) { console.log('count: ' + count); myCount = count; }); return myCount;}; |
User를 등록(insert), 삭제(remove) 및 정보를 업데이트(update)하는 함수로 구성하였다.
Part 4 - 테스트
간단한 테스트를 해보자. app.js에 다음 코드를 생성한다.
[{EXPRESS_ROOT}/app.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
|
app.get('/insertuser', function(req, res, next) { mongodb.InsertUser('cinema4d', 'gchoi', '12345'); res.send('success: the user inserted');});app.get('/removeuser', function(req, res, next) { mongodb.RemoveUserById('cinema4d'); res.send('success: the user removed');});app.get('/updateuser', function(req, res, next) { var newData = { userId: 'c4d', userName: 'gulae', password: 'asdf' }; mongodb.UpdateUser('cinema4d', newData); res.send('success: the user updated');});app.get('/usercount', function(req, res, next) { res.send('User counts: ' + mongodb.UserCounts());});... |
웹브라우저 주소창에 다음을 각각 입력하고, MongoDB를 통해 데이터를 확인한다:
127.0.0.1/insertuser
127.0.0.1/removeuser
127.0.0.1/updateuser
127.0.0.1/usercount
[출처] https://cinema4dr12.tistory.com/836
본 웹사이트는 광고를 포함하고 있습니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
