06/01 node.js 서버구축연습 3

POST방식으로 아이디와 비밀번호를 받아 DB에 등록

GET방식으로 아이디를 받아 DB정보 취득

 

let http = require('http');
let url = require('url');
let querystring = require('querystring');
const database = require('./config/database');
let db_config = require(__dirname + '/config/database.js');
let conn = db_config.init();
let resResult;

function bin2string(array){
	var result = "";
	for(var i = 0; i < array.length; ++i){
		result+= (String.fromCharCode(array[i]));
	}
	return result;
}
                            //request, response 
let server = http.createServer((req, res)=>{
    //select
    // conn.query('SELECT * FROM admin WHERE id =' + '\'admin\'', function (error, results, fields) {
    //     if (error) throw error;
    //     resResult = 'id: '+ results[0].id + ', pass: ' + results[0].pass;
    //     console.log(resResult);
    // });
    
    //insert
    // conn.query('INSERT INTO `admin` (`id`, `pass`) VALUES(\'admin4\', \'admin4\')', function (error, results, fields) {
    //     console.log(results);
    // });
    
    if(req.method == 'GET'){
        let _url = req.url;
        let query = url.parse(_url,true).query;
        conn.query('SELECT * FROM admin WHERE id = \''+query.id+'\'', function (error, results, fields) {
            if (error) throw error;
            resResult = 'id: '+ results[0].id + ', pass: ' + results[0].pass;
            console.log(resResult);
            });
     
        res.end(resResult);
    }
    else if(req.method == 'POST'){
        req.on('data', function(chunk){
            let json = bin2string(chunk);
            let obj = JSON.parse(json);
            //let {id, pass} = JSON.parse(json);
            console.log(obj.id, obj.pass);
            
            conn.query('INSERT INTO `admin` (`id`, `pass`) VALUES(\''+ obj.id+'\', \''+ obj.pass+'\')', function (error, results, fields) {
                if (error) throw error;
                });

        });
     
        req.on('end', function(){            
            res.end(resResult);
        });

        
    }

    
    //conn.end();
});

server.listen(8080, ()=>{
    console.log("서버 시작되었습니다 포트: 8080");
});