Day6

인덱스 추가해서 스키마정의하고

(검색 속도 향상)

//스키마 정의
        userSchema =mongoose.Schema({
            id :{type :String, required:true, unique :true},
            password:{type: String, required:true},
            name: {type:String, index:'hashed'},
            age:{type:Number, 'default':-1},
            created_at:{type:Date, index:{unique:false},'default': Date.now},
            updated_at:{type:Date, index:{unique:false},'default': Date.now}
        });

 

스키마 객체에 메소드 추가해서 사용

1.아이디 검색 후 맞는게 있으면 비번도 확인 ( findId)

2.전체 사용자 리스트 불러오기 ( findAll)

에 사용

 

		//스키마에 static 메소드 추가
        // 함수 이름 + 함수 객체 
        //id 속엉을 전닯망아 검색후 콜백으로 결과 넘겨줌
        userSchema.static('findById', function(id, callback){
            return this.find({id:id}, callback);
        });
        //모든 문서 데이터 반환
        userSchema.static('findAll', function(callback){
            return this.find({}, callback);
        });
     
        ....
        
        //id로 검색 
         userModel.findById(id, function(err,results){
        if(err){
            callback(err, null);
            return;
        }
         .....
        
        // 전체 사용자 조회
         userModel.findAll(function(err, results){
            if(err){
                console.log('사용자 리스트 조회중 에러 발생 : '+err.stack);
           ....  
              

---

 

var express = require('express'),
    http = require('http'),
    path = require('path');

var bodyParser = require('body-parser'),
    static = require('serve-static'),
    expressErrorHandler = require('express-error-handler'),
    cookieParser = require('cookie-parser'),
    expressSession = require('express-session');

var mongoClient = require('mongodb').MongoClient,
    mongoose = require('mongoose');

var app = express();  

app.set('port', process.env.port || 3000);

app.use(bodyParser.urlencoded({extended:false}));
app.use(bodyParser.json());
app.use('/public', static(path.join(__dirname, 'public')));
app.use(cookieParser());
app.use(expressSession({
    secret: 'my key',
    resave: true,
    saveUninitialized :true
}));

var database;
var userSchema;
var userModel;

//db에 연결
function connectDB(){
    //db 연결정보
    var databaseUrl = 'mongodb://localhost:27017/local';
    
    //db 연결
    console.log('....db에 연결합니다. ' );
    //기본 promise(mPromise)를 노드의 promise로 교체
    mongoose.Promise = global.Promise;
    mongoose.connect(databaseUrl);
    
    database = mongoose.connection;
    
    //db 연결이 안됬을때 
    database.on('error', console.error.bind(console, 'mongoose 연결 error'));
   
    //db가 연결됬을때 
    database.on('open', function(){
         console.log('db에 연결됬습니다. :'+ databaseUrl );
        
        //스키마 정의
        userSchema =mongoose.Schema({
            id :{type :String, required:true, unique :true},
            password:{type: String, required:true},
            name: {type:String, index:'hashed'},
            age:{type:Number, 'default':-1},
            created_at:{type:Date, index:{unique:false},'default': Date.now},
            updated_at:{type:Date, index:{unique:false},'default': Date.now}
        });
        
        //스키마에 static 메소드 추가
        // 함수 이름 + 함수 객체 
        //id 속엉을 전닯망아 검색후 콜백으로 결과 넘겨줌
        userSchema.static('findById', function(id, callback){
            return this.find({id:id}, callback);
        });
        //모든 문서 데이터 반환
        userSchema.static('findAll', function(callback){
            return this.find({}, callback);
        });
        
        console.log('스키마가 정의됨' );
        
        //userModel 정의
        userModel = mongoose.model("users2", userSchema);
        console.log('사용자 모델 정의됨' );
    });
    
    //연결이 끊어졌을때  5초 후 다시 연결 
    database.on('disconnected', function(){
        console.log('연결 끊어짐. 5초후 다시 연결합니다' );
        setInterval(connectDB, 5000);
    });
    
}

// 사용자 인증
var authUser = function(database,id, password, callback){
    console.log('authUser 함수 호출됨');
    
    //ID로 검색
    userModel.findById(id, function(err,results){
        if(err){
            callback(err, null);
            return;
        }
        
        console.log('ID : %s로 검색 결과 ',id);
        console.log(results);
        
        if(results.length>0){
            console.log('ID와 일치하는 사용자 찾음');
            
            //비밀번호 확인
            if(results[0]._doc.password == password){
                console.log('비밀번호 일치함');
                callback(null,results);
            }else{
                console.log('비밀번호 일치하지 않음');
                callback(null,null);
            }
        
        }else{
            console.log('ID와 일치하는 사용자 못찾음');
            callback(null,null);
        }
    });
    
    //id랑 비번으로 인증여부 확인
   /* userModel.find({"id":id, "password":password}, function(err,results){
        if(err){
            callback(err,null);
            return;
        }
        
        console.log('id :%s, password: %s 로 검색한 결과', id, password);
        console.dir(results);
        
        if(results.length > 0){
            console.log('일치하는 ㅅ 찾음');
            callback(null, results);
        }else{
            console.log('일치하는 사람 없음');
            callback(null,null);
        }
    }); */
    
}

// 사용자 추가
var addUser = function(database, id, password, name, callback){
    console.log('adduser 호출됨 '+ id);
    
    var user = new userModel({"id":id, "password":password, "name":name});
    
    user.save(function(err, result){
        if(err){
            callback(err, null);
            return;
        }
        console.log('사용자 데이터 추가함');
        callback(null,user);
    });
 
}

var router = express.Router();

router.route('/process/login').post(function(req,res){
    console.log('/process/login 호출됨 ');
    
    var paramId = req.body.id || req.query.id;
    var paramPassword = req.body.password || req.query.password;
    
    //db가 연결되었으면
    if(database){
        authUser(database, paramId, paramPassword, function(err,docs){
            if(err){
                console.log(err.stack);
                throw err; 
            }
            
            if(docs){
                console.dir(docs);
                var userName = docs[0].name;
                res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
                res.write('<h1> 로그인 성공 </h1>');
                res.write('<div><p>Param id : ' + paramId + '</p></div>');
                res.write('<div><p>Param password : ' + paramPassword + '</p></div>');
                res.write("<br><br><a href='/public/login.html'> 다시 로그인 </a>");
                res.end();
            }else{
                res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
                res.write('<h1> 로그인 실패 </h1>');
                res.write('<div><p> 아이디랑 비번 다시 확인 </p></div>');
                res.write("<br><br><a href='/public/login.html'> 다시 로그인 </a>");
                res.end();
            }
        });
     //db랑 연결안됬으면
    }else{
            res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
            res.write('<h1> DB 연결 실패 </h1>');
            res.write('<div><p> DB에 연결하지 못했습니다 </p></div>');
            //res.write("<br><br><a href='/public/login.html'> 다시 로그인 </a>");
            res.end();     
    }
    
});

//사용자 추가 라우팅 함수 
router.route('/process/adduser').post(function(req,res){
    console.log('/process/adduser 호출됨');
    
    var paramId = req.body.id || req.query.id;
    var paramPassword = req.body.password || req.query.password;
    var paramName = req.body.name || req.query.name;
    
    console.log('요청 파라미터 : ' + paramId + ', ' + paramPassword + ', ' + paramName);
    
    //db 연결됬으면
    if(database){
        addUser(database,paramId,paramPassword, paramName, function(err,result){
            if(err){
                console.log(err.stack);
                throw err; 
            }
            
            // 추가된 거 있으면 
            if(result) {// && result.insertedCount >0 ){
                  console.log('res11 : '+ result);
                
                res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
                res.write('<h1> 사용자 추가 성공 </h1>');
                res.write('<div><p>사용자 id : ' + paramId + '</p></div>');
                res.write('<div><p>사용자 name : ' + paramName + '</p></div>');
                res.end();
             //추가할거 없으면     
            }else{
                  console.log('res 22: '+ result);
                res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
                res.write('<h1> 추가 실패 </h1>');
                res.write("<br><br><a href = '/public/adduser.html'> 사용자 추가하기 </a>");
                res.end();
            }
        });
    }else{
        res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
        res.write('<h1> DB 연결 실패 </h1>');
        res.end();
    }
    
})

router.route('/process/listuser').post(function(req, res){
    console.log('/process/listuser 호출됨');
    
    // db 연결되면 
    if(database){
        userModel.findAll(function(err, results){
            if(err){
                console.log('사용자 리스트 조회중 에러 발생 : '+err.stack);
                
                res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
                res.write('<h1> 사용자 리스트 조회중 에러 발생 </h1>');
                res.write('<p>' + err.stack + '</p');
                res.end();
                
                return;
            }
            
            //결과 있으면 
            if(results.length>0){ // results.length>0 ??
                console.dir(results);
                
                res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
                res.write('<h1> 사용자 리스트 </h1>');
                res.write('<div><ul>');
                
                for(var i = 0; i< results.length; i++){
                    var curId = results[i]._doc.id;
                    var curName = results[i]._doc.name;
                    res.write('    <li>#' + (i+1) + ' : ' + curId + ', ' + curName + '</li>');
                }
                
                res.write('<div><ul>');
                res.end();
            //결과 없으면    
            }else{
                res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
                res.write('<h1> 사용자 리스트 조회 실패</h1>');
                res.end();
            }
        });
    }else{
        console.log('db 연결 오류 ');
        res.writeHead('200', {'Content-Type':'text/html;charset=utf8'});
        res.write('<h1> DB 연결 실패</h1>');
        res.end();
    }
});


app.use('/',router);

var errorHandler = expressErrorHandler({
    static :{
        '404':'./public/404.html'
    }
});

app.use(expressErrorHandler.httpError(404));
app.use(errorHandler);

    
app.listen(app.get('port'), function(){
    console.log('Server Started '+ app.get('port'));
    
    //db연결
    connectDB();
});