8.5 Sequelize 외래키로 참조 테이블 데이터 검색하기

외래키를 갖는 테이블을 정의하는 이유는 해당 키 값을 통해 참조하는 테이블의 정보를 접근하기 위함이죠. 이런 상황을 가정해보겠습니다.

각 테이블의 id값은 index 역할을 하는 기본 키 이고, board 테이블의 fk_userId 필드는 user테이블의 외래키입니다. 즉 fk_userId의 값을 통해서 user 테이블의 모든 값을 가져올 수 있다는 얘기가 됩니다.

board 를 게시판이라고 생각하면 게시판이 가지고 있는 필드는 가장 간단하게 한다면 제목과 내용을 가지고 있을 것입니다.

근데 이 글을 쓴 사람이 누군지를 알고싶으면 user 테이블에서 정보를 가져와야할 것입니다. 게시판 글을 로딩하는 함수를 만들어보았습니다.

function boardLoadFunction(callback) {
    models.Board.findAll().then(function(result){    //result가 board 테이블의 모든 값을 json으로 반환
        var jsonObj = [];                //board 테이블의 데이터를 담을 배열
        var tasks = [
            function(call){            
                if(result.length==0)    //게시판에 글이 하나도 없을 때0값 리턴
                    callback(0)
                else{
                    for(var i=0;i<result.length;i++)        //데이터의 개수만큼 반복문
                        jsonObj.push(result[i].dataValues)    //jsonObj 배열에 select * from board 값을 저장
                    call(null,jsonObj);                        //위의 쿼리문 결과를 다음 함수로 넘겨줌
                }
            },
            function(jsonObj,call){
                var i =0;                            
                var nameList = {};                            //{ 외래키 : 이름 } 의 형태로 만들 json 데이터
                jsonObj.forEach(function(element){            //board 테이블과 user테이블의 데이터를 비교
                    models.User.findOne({                    
                        where:{id:element.fk_userId}        //board의 외래키와 user의 id값의 일치여부
                    }).then(function(user){
                        nameList[element.fk_userId] = user.dataValues.name    
                        //nameList 객체에 { 외래키 : 이름 } 으로 저장
                        i++;
                        if(jsonObj.length==i)    //배열 끝까지 비교가 끝나면 다음 함수로 넘겨줌
                            call(null,nameList);        
                    })
                })
            },
            function(nameList,call) {            //jsonObj에 name값을 추가한 데이터를 최종적으로 만듦
                var i=0
                jsonObj.forEach(function(element){    
                    if(nameList.hasOwnProperty(element.fk_userId)){
                        jsonObj[i].name = nameList[element.fk_userId]    //jsonObj객체에 name key와 key value 추가
                        i++
                    }
                    if(i==jsonObj.length)
                        callback(jsonObj)        //배열 끝까지 비교가 끝나면 app.js로 넘겨줌
                })
            }
        ]
        async.waterfall(tasks,function(err){
            if(err)
                console.log(err)
        })
    }).catch(function(err){
        console.log(err);
    })
}

async 모듈을 이용 하였는데, 일단 게시판에 글이 하나도 없을 때를 처리하고 그 외에 경우에는 board 테이블의 정보들 에다가 외래키 값에 일치하는 user 테이블의 name 값을 result 객체에 합쳐서 callback 함수로 app.js에 전달해주었습니다.

app.js

app.get('/commuity',function(req,res){
    board.boardLoadFunction(function(result){
        var jsonStr = JSON.stringify(result);
        if(result.length==0)
            res.render('commuity',{data:0})
        else
            res.render('commuity',{data:jsonStr})
    })
});

게시판의 subject, content필드와 더불어 user 테이블의 정보까지 합쳐진 json 객체를 client 에 전달합니다.

board 테이블이 가지고 있는 subject와 content필드 외에 외래키로 user 테이블의 name 필드를 얻어와서 합쳐진 객체로 작성자까지 출력을 해줄 수 있게 되었습니다.