집 >웹 프론트엔드 >JS 튜토리얼 >nodejs에서 mysql을 작동하고 사용하는 방법(코드 포함)

nodejs에서 mysql을 작동하고 사용하는 방법(코드 포함)

不言원래의: 2018-08-14 16:46:021582검색

이 기사의 내용은 nodejs에서 mysql을 작동하고 사용하는 방법에 대한 것입니다(코드 포함). 도움이 필요한 친구들이 참고할 수 있기를 바랍니다.

Installation

npm install mysql

Test MySQL

mysql을 다운로드하면 설명되지 않습니다. 직접 설치하면 매우 간단합니다.
공식 예제 사용

var mysql      = require(‘mysql’); 
  var connection = mysql.createConnection({ 
    host     : ‘localhost’, 
    user     : ‘me’, 
    password : ‘secret’, 

    database : ‘my_db’ 

  });//创建mysql链接 

   connection.connect(); 

   connection.query(‘SELECT 1 + 1 AS solution’, function (error, results, fields) { 

    if (error) throw error; 

    console.log(‘The solution is: ‘, results[0].solution); 

  });//执行sql语句 

   connection.end();//关闭链接

연결 옵션 알아보기

데이터베이스 연결을 생성하려면 먼저 옵션을 이해해야 합니다

　 host：主机地址 （默认：localhost） 

  user：用户名 

  password：密码 

  port：端口号 （默认：3306） 

  database：数据库名 

  charset：连接字符集（默认：’UTF8_GENERAL_CI’，注意字符集的字母都要大写） 

  localAddress：此IP用于TCP连接（可选） 

  socketPath：连接到unix域路径，当使用 host 和 port 时会被忽略 

  timezone：时区（默认：’local’） 

  connectTimeout：连接超时（默认：不限制；单位：毫秒） 

  stringifyObjects：是否序列化对象（默认：’false’ ；与安全相关(https://github.com/felixge/node-mysql/issues/501) 

  typeCast：是否将列值转化为本地JavaScript类型值 （默认：true） 

  queryFormat：自定义query语句格式化方法 (https://github.com/felixge/node-mysql#custom-format) 

  supportBigNumbers：数据库支持bigint或decimal类型列时，需要设此option为true （默认：false） 

  bigNumberStrings：supportBigNumbers和bigNumberStrings启用 强制bigint或decimal列以JavaScript字符串类型返回（默认：false） 

  dateStrings：强制timestamp,datetime,data类型以字符串类型返回，而不是JavaScript Date类型（默认：false） 

  debug：开启调试（默认：false） 

  multipleStatements：是否许一个query中有多个MySQL语句 （默认：false） 

  flags：用于修改连接标志，更多详情：(https://github.com/felixge/node-mysql#connection-flags) 

  ssl：使用ssl参数（与crypto.createCredenitals参数格式一至）或一个包含ssl配置文件名称的字符串，目前只捆绑Amazon RDS的配置文件

# 🎜🎜#추가, 삭제, 수정, 확인

추가, 삭제, 수정, 확인은 주로 SQL 문에 의해 결정됩니다.

1, 추가

var  userAddSql = ‘INSERT INTO userinfo(Id,UserName,UserPass) VALUES(0,?,?)’; 

  var  userAddSql_Params = [‘Wilson’, ‘abcd’]; 

  connection.query(userAddSql,userAddSql_Params,function (err, result) { 

    … 

  });

2, 삭제

var userModSql = ‘DELETE FROM userinfo’; 

  connection.query(userModSql,function (err, result) { 

  … 

  });

var userModSql = ‘UPDATE userinfo SET UserName = ?,UserPass = ? WHERE Id = ?’; 

  var userModSql_Params = [‘钟慰’, ‘5678’,1]; 

  connection.query(userModSql,userModSql_Params,function (err, result) { 

  … 

  });

4 수정

이전 예에서는 마지막에 Connection.end() 메서드를 호출하겠습니다. 이 메서드는 연결.connect()가 시작과 끝에 해당합니다!

실제로 연결을 종료하는 두 가지 방법이 있습니다: end() 및 destroy(); 연결, 오류는 콜백 함수에서 처리할 수 있는 err 매개변수로 반환됩니다!

Destory()는 콜백 기능이 없고 쿼리 완료 여부에 관계없이 즉시 실행됩니다.

연결 끊김 및 재연결

var  userGetSql = ‘SELECT * FROM userinfo’; 

  connection.query(userGetSql ,function (err, result) { 

  … 

  });

sql 링크 풀 연결 풀링

1. createPool 메소드를 사용하면 옵션이 createConntion과 일치하며 연결 이벤트를 수신할 수 있습니다.

연결 풀이 자동으로 연결 해제되었다가 다시 연결됩니다

var mysql = require(‘mysql’); 

  var db_config = { 

    host     : ‘192.168.0.200’, 

    user     : ‘root’, 

    password : ‘abcd’, 

    port: ‘3306’, 

    database: ‘nodesample’ 

  }; 

  var connection; 

  function handleDisconnect() { 

    connection = mysql.createConnection(db_config); 

    connection.connect(function(err) { 

      if(err) { 

        console.log(“进行断线重连：” + new Date()); 

        setTimeout(handleDisconnect, 2000);   //2秒重连一次 

        return; 

      } 

       console.log(“连接成功”); 

    }); 

    connection.on(‘error’, function(err) { 

      console.log(‘db error’, err); 

      if(err.code === ‘PROTOCOL_CONNECTION_LOST’) {  

        handleDisconnect(); 

      } else { 

        throw err; 

      } 

    }); 

  } 

  handleDisconnect();

#🎜 🎜#2. 기타 연결 풀 구성 옵션

waitForConnections연결 풀에 연결이 없거나 최대 제한을 초과하는 경우 true로 설정되고 연결이 queue. false로 설정하면 오류가 반환됩니다.#🎜 🎜# ConnectionLimit 연결 제한, 기본값: 10 queueLimit 최대 연결 요청 대기열 제한, 0으로 설정하면 제한 없음을 나타냄, 기본값: 0
#🎜🎜 # 　　

3. Release 연결을 다시 연결 풀에 넣고 다른 사용자가 사용할 때까지 기다립니다.

기타...

1.escape()
SQL 주입을 방지하려면 pool.escape() 및 connect.escape()를 사용할 수 있습니다. 말할 것도 없이 'SELECT * FROM userinfo WHERE id = ' + pool을 사용하여

을 시도해 볼 수 있습니다. .escape ('5 OR ID = 6')
2.escapeId()
SQL 식별자(데이터베이스 이름, 테이블 이름, 열 이름)를 신뢰할 수 없는 경우, 변환 방법 escapeId()를 사용할 수 있습니다.

이 'SELECT * FROM 게시물 ORDER BY' + connect.escapeId("date");

3.format(과 유사합니다. )
mysql.format을 사용하여 쿼리 문을 준비할 수 있습니다. 이 함수는 매개 변수를 이스케이프하는 데 적합한 방법을 자동으로 선택합니다.

var mysql = require(‘mysql’); 

  //创建连接池 

  var pool  = mysql.createPool({ 

    host     : ‘192.168.0.200’, 

    user     : ‘root’, 

    password : ‘abcd’ 

  }); 

  //监听connection事件 

  pool.on(‘connection’, function(connection) { 

      connection.query(‘SET SESSION auto_increment_increment=1’); 

  }); 

    

  连接池可以直接使用，也可以共享一个连接或管理多个连接（引用官方示例） 

  //直接使用 

  pool.query(‘SELECT 1 + 1 AS solution’, function(err, rows, fields) { 

    if (err) throw err; 

    console.log(‘The solution is: ‘, rows[0].solution); 

  }); 

  //共享 

  pool.getConnection(function(err, connection) { 

    // connected! (unless err is set) 

  });

4. 사용자 정의 서식 지정 기능

var sql = “SELECT * FROM ? WHERE ? = ?”; 

     var inserts = [‘users’, ‘id’, 123]; 

      sql = mysql.format(sql, inserts);