ホームページ > 記事 > ウェブフロントエンド > Nodejsでmysqlを操作・使用する方法（コード付き）

Nodejsでmysqlを操作・使用する方法（コード付き）

不言オリジナル: 2018-08-14 16:46:021561ブラウズ

この記事の内容は、nodejs での mysql の操作と使用方法に関するものです (コード付き)。必要な方は参考にしていただければ幸いです。

インストール

npm install mysql

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) { 

  … 

  });

を削除します。4.

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

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

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

  … 

  });

のデータベース接続を終了します。

前の例では、私はconnection.end() メソッドは最後に呼び出されます。このメソッドは connection.connect() に対応し、一方が開始し、もう一方が終了します。

実際には接続を終了するメソッドは 2 つあります: end() と destroy();

end() メソッドはクエリが完了した後にコールバック関数を受け取ります。実行すると、クエリが完了すると接続が終了します。コールバック関数の 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 に設定し、接続をキューに入れます。false に設定します。そしてエラーを返します connectionLimit 接続制限、デフォルト: 10queueLimit 接続リクエストキュー制限の最大値、0 に設定すると制限なし、デフォルト: 0

3. リリース

connection.release() メソッドを呼び出すと、接続を接続プールに戻し、他のユーザーを待ちます。

その他…１。 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);