기본 콘텐츠로 건너뛰기

[Node.js] Mongoose 사용하기

[Node.js] Mongoose 사용하기

MySQL에 시퀄라이즈가 있다면 몽고디비에는 몽구스가 있습니다.

몽구스에는 스키마가 있습니다. 몽고디비는 테이블이 없어서 자유롭게 데이터를 넣을 수 있지만, 때로는 이런 점이 단점으로 작용할 수 있습니다. 몽구스는 몽고디비에 데이터를 넣기 전 노드 서버 단에서 데이터를 한 번 필터링하는 역할을 해줍니다.

또한, MySQL에 있는 JSON 기능을 populate라는 메서드로 어느 정도 보완해줍니다. 따라서 관계가 있는 데이터를 쉽게 가져올 수 있습니다.

먼저 express로 learn-mongoose 폴더를 생성한 후 mongoose를 설치합니다.

express learn-mongoose 명령 폴더 이동 npm i mongoose 명령

몽고디비는 주소를 사용해 연결합니다. 주소 형식은 mongodb://[username:password@]host[:port][/[database][?options]] 와 같습니다. [] 부분은 있어도 되고 없어도 됨을 의미합니다.

먼저 schemas 폴더를 루트 디렉터리에 생성합니다. 그리고 index.js 파일을 생성합니다.

// schemas/index.js const mongoose = require('mongoose'); module.exports = () =>{ const connect = () =>{ if(process.env.NODE_ENV !== 'production'){ mongoose.set('debug',true); } mongoose.connect('mongodb://root:1234@localhost:27017/admin',{ // 접속을 시도하는 주소의 데이터베이스는 admin이지만, 실제 사용할 데이터베이스는 nodejs이다. dbName: 'nodejs', },(error)=>{ if(error){ console.log('몽고디비 연결 에러', error); }else{ console.log('몽고디비 연결 성공'); } }); }; connect(); mongoose.connection.on('error',(error)=>{ console.error('몽고디비 연결 에러', error); }); mongoose.connection.on('disconnection',()=>{ console.error('몽고디비 연결이 끊겼습니다. 연결을 재시도합니다.'); connect(); }); // 스키마 연결 부분 require('./user'); require('./comment'); };

이제 app.js와 연결하여 노드 실행 시 mongoose.connect 부분도 실행되도록 하겠습니다.

// app.js // ... var indexRouter = require('./routes/index'); var usersRouter = require('./routes/users'); var connect = require('./schemas'); var app = express(); connect(); // ...

시퀄라이즈에서 테이블을 만들었던 것처럼 몽구스 스키마(schema)를 만들어봅시다.

// schemas/user.js const mongoose = require('mongoose'); const { Schema } = mongoose; const userSchema = new Schema({ name:{ type: String, required: true, unique: true, }, age:{ type: Number, required: true, }, married:{ type:Boolean, required: true, }, comment: String, createdAt:{ type: Date, default: Date.now, }, }); module.exports = mongoose.model('User',userSchema);

// schemas/comment.js const mongoose = require('mongoose'); const { Schema } = mongoose; const { Types: {ObjectId} } = Schema; const commentSchema = new Schema({ commenter: { type: ObjectId, required: true, ref: 'User', }, comment: { type: String, required: true, }, createdAt: { type: Date, default: Date.now, }, }); module.exports = mongoose.model('Comment', commentSchema)

몽구스를 사용해 쿼리 수행을 위한 view 파일과 script파일을 생성합니다.

// views/mongoose.pug doctype html html head meta(charset='utf-8') title 몽구스 서버 style. table{ border: 1px solid black; border-collapse: collapse; } table th, table td { border: 1px solid black; } body div form#user-form fieldset legend 사용자 등록 div input#username(type="text" placeholder="이름") div input#age(type="number" placeholder="나이") div input#married(type="checkbox") label(for="married") 결혼 여부 button(type="submit") 등록 br table#user-list thead tr th 아이디 th 이름 th 나이 th 결혼여부 tbody for user in users tr td= user.id td= user.name td= user.age td= user.married ? '기혼' : '미혼' br div form#comment-form fieldset legend 댓글 등록 div input#userid(type="text" placeholder="사용자 아이디") div input#comment(type="text" placeholder="댓글") button(type="submit") 등록 br table#comment-list thead tr th 아이디 th 작성자 th 댓글 th 수정 th 삭제 tbody script(src='/mongoose.js')

// public/mongoose.js // 사용자 이름 눌렀을 때 댓글 로딩 document.querySelectorAll('#user-list tr').forEach(function (el) { el.addEventListener('click', function () { var id = el.querySelector('td').textContent; getComment(id); }); }); // 사용자 로딩 function getUser() { var xhr = new XMLHttpRequest(); xhr.onload = function () { if (xhr.status === 200) { var users = JSON.parse(xhr.responseText); console.log(users); var tbody = document.querySelector('#user-list tbody'); tbody.innerHTML = ''; users.map(function (user) { var row = document.createElement('tr'); row.addEventListener('click', function () { getComment(user._id); }); var td = document.createElement('td'); td.textContent = user._id; row.appendChild(td); td = document.createElement('td'); td.textContent = user.name; row.appendChild(td); td = document.createElement('td'); td.textContent = user.age; row.appendChild(td); td = document.createElement('td'); td.textContent = user.married ? '기혼' : '미혼'; row.appendChild(td); tbody.appendChild(row); }); } else { console.error(xhr.responseText); } }; xhr.open('GET', '/users'); xhr.send(); } // 댓글 로딩 function getComment(id) { var xhr = new XMLHttpRequest(); xhr.onload = function () { if (xhr.status === 200) { var comments = JSON.parse(xhr.responseText); var tbody = document.querySelector('#comment-list tbody'); tbody.innerHTML = ''; comments.map(function (comment) { var row = document.createElement('tr'); var td = document.createElement('td'); td.textContent = comment._id; row.appendChild(td); td = document.createElement('td'); td.textContent = comment.commenter.name; row.appendChild(td); td = document.createElement('td'); td.textContent = comment.comment; row.appendChild(td); var edit = document.createElement('button'); edit.textContent = '수정'; edit.addEventListener('click', function () { // 수정 클릭 시 var newComment = prompt('바꿀 내용을 입력하세요'); if (!newComment) { return alert('내용을 반드시 입력하셔야 합니다'); } var xhr = new XMLHttpRequest(); xhr.onload = function () { if (xhr.status === 200) { console.log(xhr.responseText); getComment(id); } else { console.error(xhr.responseText); } }; xhr.open('PATCH', '/comments/' + comment._id); xhr.setRequestHeader('Content-Type', 'application/json'); xhr.send(JSON.stringify({ comment: newComment })); }); var remove = document.createElement('button'); remove.textContent = '삭제'; remove.addEventListener('click', function () { // 삭제 클릭 시 var xhr = new XMLHttpRequest(); xhr.onload = function () { if (xhr.status === 200) { console.log(xhr.responseText); getComment(id); } else { console.error(xhr.responseText); } }; xhr.open('DELETE', '/comments/' + comment._id); xhr.send(); }); td = document.createElement('td'); td.appendChild(edit); row.appendChild(td); td = document.createElement('td'); td.appendChild(remove); row.appendChild(td); tbody.appendChild(row); }); } else { console.error(xhr.responseText); } }; xhr.open('GET', '/comments/' + id); xhr.send(); } // 사용자 등록 시 document.getElementById('user-form').addEventListener('submit', function (e) { e.preventDefault(); var name = e.target.username.value; var age = e.target.age.value; var married = e.target.married.checked; if (!name) { return alert('이름을 입력하세요'); } if (!age) { return alert('나이를 입력하세요'); } var xhr = new XMLHttpRequest(); xhr.onload = function () { if (xhr.status === 201) { console.log(xhr.responseText); getUser(); } else { console.error(xhr.responseText); } }; xhr.open('POST', '/users'); xhr.setRequestHeader('Content-Type', 'application/json'); xhr.send(JSON.stringify({ name: name, age: age, married: married })); e.target.username.value = ''; e.target.age.value = ''; e.target.married.checked = false; }); // 댓글 등록 시 document.getElementById('comment-form').addEventListener('submit', function (e) { e.preventDefault(); var id = e.target.userid.value; var comment = e.target.comment.value; if (!id) { return alert('아이디를 입력하세요'); } if (!comment) { return alert('댓글을 입력하세요'); } var xhr = new XMLHttpRequest(); xhr.onload = function () { if (xhr.status === 201) { console.log(xhr.responseText); getComment(id); } else { console.error(xhr.responseText); } }; xhr.open('POST', '/comments'); xhr.setRequestHeader('Content-Type', 'application/json'); xhr.send(JSON.stringify({ id: id, comment: comment })); e.target.userid.value = ''; e.target.comment.value = ''; });

앞서 sequelize를 사용했을때와 비슷한 형태의 예제입니다.

이제 라우터를 작성해보도록 하겠습니다.

// routes/index.js var express = require('express'); var User = require('../schemas/user'); var router = express.Router(); router.get('/',function(req,res,next){ User.find({}) .then((users)=>{ res.render('mongoose', { users }); }) .catch((err)=>{ console.error(err); next(err); }); }); module.exports = router;

// routes/users.js var express = require('express'); var User = require('../schemas/user') var router = express.Router(); router.get('/',function(req,res,next){ User.find({}) .then((users)=>{ res.json(users); }) .catch((err)=>{ console.error(err); next(err); }); }); router.post('/',function(req,res,next){ const user = new User({ name: req.body.name, age: req.body.age, married: req.body.married, }); user.save() .then((result)=>{ console.log(result); res.status(201).json(result); }) .catch((err)=>{ console.error(err); next(err); }); }); module.exports = router;

// routes/comments.js var express = require('express'); var Comment = require('../schemas/comment') var router = express.Router(); router.get("/:id",function(req,res,next){ Comment.find({commenter: req.params.id }).populate('commenter') .then((comments)=>{ console.log(comments); res.json(comments); }) .catch((err)=>{ console.error(err); next(err); }); }); router.post('/',function(req,res,next){ const comment = new Comment({ commenter: req.body.id, comment: req.body.comment, }); comment.save() .then((result)=>{ return Comment.populate(result,{path: 'commenter'}); }) .then((result)=>{ res.status(201).json(result); }) .catch((err)=>{ console.error(err); next(err); }); }); router.patch('/:id', function(req,res,next){ Comment.update({_id: req.params.id}, { comment: req.body.comment}) .then((result)=>{ res.json(result); }) .catch((err)=>{ console.error(err); next(err); }); }); router.delete('/:id', function(req,res,next){ Comment.remove({_id: req.params.id }) .then((result)=>{ res.json(result); }) .catch((err)=>{ console.error(err); next(err); }); }); module.exports = router;

마지막으로 라우터를 서버에 연결하기 위해 app.js 파일을 수정합니다.

// app.js var createError = require('http-errors'); var express = require('express'); var path = require('path'); var cookieParser = require('cookie-parser'); var logger = require('morgan'); var indexRouter = require('./routes/index'); var usersRouter = require('./routes/users'); var commentsRouter = require('./routes/comments'); var connect = require('./schemas'); var app = express(); connect(); // view engine setup app.set('views', path.join(__dirname, 'views')); app.set('view engine', 'pug'); app.use(logger('dev')); app.use(express.static(path.join(__dirname, 'public'))); // 위로 이동 완료 app.use(express.json()); app.use(express.urlencoded({ extended: false })); app.use(cookieParser()); app.use('/', indexRouter); app.use('/users', usersRouter); app.use('/comments', commentsRouter); // catch 404 and forward to error handler app.use(function(req, res, next) { next(createError(404)); }); // error handler app.use(function(err, req, res, next) { // set locals, only providing error in development res.locals.message = err.message; res.locals.error = req.app.get('env') === 'development' ? err : {}; // render the error page res.status(err.status || 500); res.render('error'); }); module.exports = app;

서버를 실행하기 전에 몽고디비 서버를 먼저 실행(mongod -- auth)해야 합니다. 서버가 실행되면 npm start로 웹 서버를 실행시킵니다.

서버 실행 화면

출처 : Node.js 교과서

from http://badaturtle93.tistory.com/42 by ccl(A) rewrite - 2020-03-13 17:20:05

댓글

댓글 쓰기

이 블로그의 인기 게시물

AWS instance로 Nodejs 구현하기

AWS instance로 Nodejs 구현하기 서버와 데이터베이스 관리 차원에서 효율적으로 관리하기 위해선 로컬보다는 서버를 호스팅해서 하는 것이 좋다. 우리는 Nodejs를 구동하기 위해 AWS에서 인스턴스를 할당받을 계획이다. 인스턴스의 pem키를 발급받아 nodejs와 npm까지는 설치를 완료한 상태이다. $ sudo npm install -g express 다음의 명령어를 입력하면 글로벌 옵션으로 어느 path에서든 express를 사용할 수 있게 설치한다. 다음과 같이 실행이 된다면 성공이다. 이후 Express generator를 설치한다. $ sudo npm install -g express-generator@4 버전은 4.x이며 이 역시 글로벌 옵션으로 설치해 준다. 이제 Node monitoring을 위해 nodemon을 설치해 준다. $ sudo npm install -g nodemon 모든 설치가 끝났다. 이제 nodejs를 실행시킬 프로젝트용 directory를 만든다. 이렇게 만들어 주고 express를 실행시키면 된다. $ express -e 다음과 같은 결과가 나오면 된다. 이제 node package를 설치하는 명령어를 입력하자. $ sudo npm install 이제 vi를 통해 포트번호를 정의해보자. app.set의 마지막에 한줄을 추가하면 된다. app.set('port', process.env.PORT || 9000); 이로써 우리는 9000번 포트를 사용하게 되었다. 또한 마지막줄에 서버를 생성하기 위한 코드를 작성하자. module.exports = app; var server = app.listen(app.get('port'), function() { console.log('Express server listening on port ' + server.address().port); }); 이...
댓글 쓰기
자세한 내용 보기

카카오 오픈빌더와 외부 API 연동(feat.Nodejs)

카카오 오픈빌더와 외부 API 연동(feat.Nodejs) 이전에 플러스 친구와 외부 API 연동에 관한 글을 작성한 적 있습니다. 하지만 지난 2년동안 플러스 친구에 많은 변화가 생겼는데요. 카카오 플러스 친구의 명칭이 카카오 채널로 바뀌고, 챗봇 세팅 방식이 기존 [카카오 플러스 친구 - 외부 API 연동] 구조에서 오픈빌더가 추가되어 [카카오 채널(구 플러스 친구) - 카카오 i 오픈빌더 - 외부 API 연동] 구조로 바뀌었습니다. 이번 글에서는 오픈빌더의 챗봇 시나리오 관리 기능을 간단히 소개하고 외부 API를 연동하는 예제를 다뤄보겠습니다. (연동파트는 5번 항목부터 보시면 됩니다.) 1. 블록 블록은 오픈빌더에서 질의/응답을 관리하는 최소 단위로, 사용자의 발화와 챗봇의 대답을 입력할 수 있습니다. 예를들어 인사라는 블록을 만들고 인사에 해당하는 사용자 발화 패턴들을 입력해두면, 실제 채널 톡방에서 그에 해당하는 발화가 들어왔을때 입력해둔 응답이 나오는 형식입니다. 예전에는 패턴과 발화 키워드가 1:1 매칭, 즉 입력해둔 패턴과 사용자 발화의 string이 정확히 일치할때만 블록이 실행됐었는데, 발화 패턴을 20개 이상 등록하면 머신러닝 기능을 이용할 수 있도록 기능이 생겼습니다. 아마 유사도 분석 개념이 기본으로 들어가있을 것이기 때문에 블록의 주제와 벗어나는 너무 뜬금없는 발화패턴들을 많이 넣지 않도록 하는걸 권장하겠습니다. 2. 시나리오 시나리오는 '블록'들을 묶어서 관리할 수 있는 단위로, 일종의 폴더 구조라고 생각하면 쉽습니다. 오픈빌더에서 좌측 상단에 파란 버튼을 클릭하여 시나리오를 생성할 수 있습니다. 하나의 시나리오에서 모든 블록을 관리하면 챗봇 도메인이 커질수록 관리가 어려워지니 아래 같은식으로 시나리오를 사용하여 블록을 구조화하면 운영 측면에서 수월해집니다. 3. 컨텍스트 컨텍스트는 맥락이라는 뜻 입니다. 오픈빌더에 존재하는 컨텍스트는 자연어 분석을 통해서 맥...
댓글 쓰기
자세한 내용 보기

[MongoDB] 몽고디비 시작하기

[MongoDB] 몽고디비 시작하기 Mac을 사용하고 있어서 macOS기준으로 포스팅을 작성합니다. 1. 몽고디비란? MongoDB 는 무료 오픈 소스 플랫폼 문서 지향 데이터 베이스(Cross-Platform Document-Oriented)입니다. NoSQL의 일종으로 확장성이 좋고 성능이 우수합니다. JSON과 같은 동적 스키마(Schema)형 문서들을 선호함으로써 전통적인 테이블 기반 관계형 데이터베이스들(RDMS)과는 차별화 됩니다. 1) NoSQL이란? NoSQL 데이터베이스는 전통적인 관계형 데이터베이스 보다 덜 제한적인 일관성 모델을 이용합니다. 때문에 NoSQL데이터베이스는 단순 검색 및 추가 작업이 쉬워서 빅데이터(Big Data) 및 실시간 웹 애플리케이션(Web Application)에 자주 쓰입니다. NoSQL이란 이름은 "SQL을 사용하지 않는다(No SQL)" 라는 의미가 아니고, SQL 계열 쿼리 언어를 사용 할 수도 있다는 사실을 강조하기 위한 이름으로 "Not only SQL" 의 약어입니다. 2) NoSQL vs SQL SQL (MySQL) NoSQL(MongoDB) 규칙에 맞는 데이터 입력 자유로운 데이터 입력 테이블 간 JOIN 지원 컬렉션 간 JOIN 미지원 트랜잭션 지원 트랜잭션 미지원 안정성, 일관성 확장성, 가용성 용어 (테이블, 로우, 컬럼) 용어 (컬렉션, 다큐먼트, 필드) 2. 몽고디비 설치하기 공식 사이트의 메뉴얼을 따라해봅니다. https://docs.mongodb.com/manual/tutorial/install-mongodb-on-os-x/ Homebrew를 활용해서 설치하는 방법을 그대로 따라했습니당ㅇㅅㅇ (Homebrew를 설치하지 않았다면 설치한 후에! 진행하면 됩니다) 터미널 창에 순서대로 실행 brew tap mongodb/brew brew install mongodb-community@4.2 brew s...
댓글 쓰기
자세한 내용 보기