[NODEJS] Mysql 연동 2/ 세팅, 테이블 생성

- 개발환경

# 개발환경 os : windows10 Pro 64bit tool : visual studio code npm : v6.9.0 nodejs : v10.16.0 db : mysql 5.7.14

 

 

- 소스 디렉토리

# 소스 디렉토리 [ROOT]   ㄴ app.js   ㄴ config.env   ㄴ [config]      ㄴ dev.js      ㄴ prod.js        ㄴ logger.js   ㄴ [routes]      ㄴ router1.js      ㄴ router2.js   ㄴ [db]      ㄴ mysql.js

 

 

0. 사전준비

 

  0.1. Mysql 설치

https://bogyum-uncle.tistory.com/65

[MYSQL] MYSQL 설치

 

  0.2. mysql database, table 생성

 

    0.2.1. mysqldb 이름으로 스키마 생성

    0.2.2. products 테이블 생성

use mysqldb;
CREATE TABLE products(
    id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(50) NOT NULL,
    modelnumber VARCHAR(15) NOT NULL,
    series VARCHAR(30) NOT NULL
);

INSERT INTO products (name, modelnumber, series) VALUES ("victolee1", "1234", "1111");
INSERT INTO products (name, modelnumber, series) VALUES ("victolee2", "1234", "1111");
INSERT INTO products (name, modelnumber, series) VALUES ("victolee3", "1234", "1111");

 

  0.3. 기본 세팅

https://bogyum-uncle.tistory.com/73

불러오는 중입니다...

 

 

1. mysql 모듈 설치

npm install mysql

 

 

2. mysql DB 접속, 사용자 정보

 

/appRoot/db/mysql.js

var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    // port: 3306,
    user: 'root',
    password: 'root',
    database: 'mysqldb',
});

module.exports = connection;

 

 

3. mysql Connection

 

/appRoot/db/app.js

 

  - 핵심

/**
* mysql Connection
*/
let client = require('./db/mysql');
var bodyparser = require('body-parser');
app.use(bodyparser.json());

client.connect((err) => {
    if(!err)
      console.log('DB connection success');
    else
      console.log('DB connection failed\n Error : ' + JSON.stringify(err, undefined, 2));
});

 

   - 전체

//Express를 변수에 담기
var express = require("express");

//Express 호출 후 새로운 Express 애플리케이션을 변수(app)에 넣음
var app = express();

var http = require("http");
var path = require("path");

/**
 * express.static, 정적 파일 서비스 제공
 */
//path.resoleve : os에 따라 /public 혹은 \public 처럼 분리자가 다를 수 있지만 이 부분을 처리해 준다.
//__dirname : 현재 위치를 가리키는 node 전역변수
var publicPath = path.resolve(__dirname, "public");
app.use(express.static(publicPath));


/**
 *  config 설정파일  (환경변수 관리)
 *  dotenv 노드 보안 (서버, DB 정보 등)
 */
//proces.env에 .env의 내용이 들어감
require("dotenv").config({path: __dirname + '\\' + 'config.env'});
console.log(process.env.DB_NAME);

let config;
if(!process.env.NODE_ENV == 'dev'){
    config = require('./config/dev');
}else if(process.env.NODE_ENV == 'prod'){
    config = require('./config/prod');
}else{
    config = require('./config/dev');
}
console.log(config.info);


/**
 * logger
 */
var logger = require('./config/logger');
app.use(express.json());        //http 요청 메시지를 json 형태로 변환
app.use(require("morgan")("combined", {"stream": logger.stream}));


/**
* mysql Connection
*/
let client = require('./db/mysql');
var bodyparser = require('body-parser');
app.use(bodyparser.json());

client.connect((err) => {
    if(!err)
      console.log('DB connection success');
    else
      console.log('DB connection failed\n Error : ' + JSON.stringify(err, undefined, 2));
});


/**
 * Routing 경로 설정
 * 
 * app.js에서 생성된 데이터를 사용하기 위해서 require에서 app이란 객체를 전달
 */

app.use('/r1', require('./routes/router1')(app));
app.use('/r2', require('./routes/router2')(app, client));
app.use(function(request, response){
    //4XX : 클라이언트 오류
    response.statusCode = 404;
    response.end("404 Error!");
});


/**
 * swagger(미완)
 */
// const swaggerJSDoc = require('swagger-jsdoc');
// const swaggerOption = require('./swagger');
// const swaggerSpec = swaggerJSDoc(swaggerOption);
// const swaggerUi = require('swagger-ui-express');
// app.use('/api-docs', swaggerUi.serve, swaggerUi.setup(swaggerSpec));


app.listen(3000, function(){
    console.log("Server Running : 3000....!");
});