一、建立數據庫連接：createConnection(Object)方法
該方法接受一個對象作為參數，該對象有四個常用的屬性host，user，password，database。與php中鏈接數據庫的參數相同。屬性列表如下：
還可以使用字符串連接數據庫例如：
var connection = mysql.createConnection('mysql://user:pass@host/db?debug=true&charset=BIG5_CHINESE_CI&timezone=-0700');
三、創建連接池 createPool(Object)
Object和createConnection參數相同。
可以監聽connection事件，并設置session值
pool.on('connection', function(connection) { connection.query('SET SESSION auto_increment_increment=1') }); connection.release()釋放鏈接到連接池。如果需要關閉連接并且刪除，需要使用connection.destroy()
pool除了接受和connection相同的參數外，還接受幾個擴展的參數
createConnection: 用于創建鏈接的函數. (Default: mysql.createConnection)
waitForConnections: 決定當沒有連接池或者鏈接數打到最大值時pool的行為. 為true時鏈接會被放入隊列中在可用是調用，為false時會立即返回error. (Default: true)
connectionLimit: 最大連接數. (Default: 10)
queueLimit: 連接池中連接請求的烈的最大長度，超過這個長度就會報錯，值為0時沒有限制. (Default: 0)
四、連接池集群
允許不同的host鏈接
// create var poolCluster = mysql.createPoolCluster(); poolCluster.add(config); // anonymous group poolCluster.add('MASTER', masterConfig); poolCluster.add('SLAVE1', slave1Config); poolCluster.add('SLAVE2', slave2Config); // Target Group : ALL(anonymous, MASTER, SLAVE1-2), Selector : round-robin(default) poolCluster.getConnection(function (err, connection) {}); // Target Group : MASTER, Selector : round-robin poolCluster.getConnection('MASTER', function (err, connection) {}); // Target Group : SLAVE1-2, Selector : order // If can't connect to SLAVE1, return SLAVE2. (remove SLAVE1 in the cluster) poolCluster.on('remove', function (nodeId) { console.log('REMOVED NODE : ' + nodeId); // nodeId = SLAVE1 }); poolCluster.getConnection('SLAVE*', 'ORDER', function (err, connection) {}); // of namespace : of(pattern, selector) poolCluster.of('*').getConnection(function (err, connection) {}); var pool = poolCluster.of('SLAVE*', 'RANDOM'); pool.getConnection(function (err, connection) {}); pool.getConnection(function (err, connection) {}); // destroy poolCluster.end(); 鏈接集群的可選參數
canRetry: 值為true時，允許連接失敗時重試(Default: true)
removeNodeErrorCount: 當連接失敗時 errorCount 值會增加. 當errorCount 值大于 removeNodeErrorCount 將會從PoolCluster中刪除一個節點. (Default: 5)
五、切換用戶/改變連接狀態
Mysql允許在比斷開連接的的情況下切換用戶
connection.changeUser({user : 'john'}, function(err) { if (err) throw err; }); 參數
六、處理服務器連接斷開
var db_config = { host: 'localhost', user: 'root', password: '', database: 'example' }; var connection; function handleDisconnect() { connection = mysql.createConnection(db_config); // Recreate the connection, since // the old one cannot be reused. connection.connect(function(err) { // The server is either down if(err) { // or restarting (takes a while sometimes). console.log('error when connecting to db:', err); setTimeout(handleDisconnect, 2000); // We introduce a delay before attempting to reconnect, } // to avoid a hot loop, and to allow our node script to }); // process asynchronous requests in the meantime. // If you're also serving http, display a 503 error. connection.on('error', function(err) { console.log('db error', err); if(err.code === 'PROTOCOL_CONNECTION_LOST') { // Connection to the MySQL server is usually handleDisconnect(); // lost due to either server restart, or a } else { // connnection idle timeout (the wait_timeout throw err; // server variable configures this) } }); } handleDisconnect(); 七、轉義查詢值
為了避免SQL注入攻擊，需要轉義用戶提交的數據。可以使用connection.escape() 或者 pool.escape()
例如：
var userId = 'some user provided value'; var sql = 'SELECT * FROM users WHERE id = ' + connection.escape(userId); connection.query(sql, function(err, results) { // ... }); 或者使用？作為占位符 connection.query('SELECT * FROM users WHERE id = ?', [userId], function(err, results) { // ... }); 不同類型值的轉換結果 Numbers 不變 Booleans 轉換為字符串 'true' / 'false' Date 對象轉換為字符串 'YYYY-mm-dd HH:ii:ss' Buffers 轉換為是6進制字符串 Strings 不變 Arrays => ['a', 'b'] 轉換為 'a', 'b' 嵌套數組 [['a', 'b'], ['c', 'd']] 轉換為 ('a', 'b'), ('c', 'd') Objects 轉換為 key = 'val' pairs. 嵌套對象轉換為字符串. undefined / null ===> NULL NaN / Infinity 不變. MySQL 不支持這些值, 除非有工具支持，否則插入這些值會引起錯誤. 轉換實例： var post = {id: 1, title: 'Hello MySQL'}; var query = connection.query('INSERT INTO posts SET ?', post, function(err, result) { // Neat! }); console.log(query.sql); // INSERT INTO posts SET `id` = 1, `title` = 'Hello MySQL'
或者手動轉換
var query = "SELECT * FROM posts WHERE title=" + mysql.escape("Hello MySQL"); console.log(query); // SELECT * FROM posts WHERE title='Hello MySQL' 八、轉換查詢標識符
如果不能信任SQL標識符(數據庫名、表名、列名)，可以使用轉換方法mysql.escapeId(identifier)；
var sorter = 'date'; var query = 'SELECT * FROM posts ORDER BY ' + mysql.escapeId(sorter); console.log(query); // SELECT * FROM posts ORDER BY `date` 支持轉義多個 var sorter = 'date'; var query = 'SELECT * FROM posts ORDER BY ' + mysql.escapeId('posts.' + sorter); console.log(query); // SELECT * FROM posts ORDER BY `posts`.`date` 可以使用??作為標識符的占位符 var userId = 1; var columns = ['username', 'email']; var query = connection.query('SELECT ?? FROM ?? WHERE id = ?', [columns, 'users', userId], function(err, results) { // ... }); console.log(query.sql); // SELECT `username`, `email` FROM `users` WHERE id = 1 九、準備查詢
可以使用mysql.format來準備查詢語句，該函數會自動的選擇合適的方法轉義參數。
var sql = "SELECT * FROM ?? WHERE ?? = ?"; var inserts = ['users', 'id', userId]; sql = mysql.format(sql, inserts); 10、自定義格式化函數 connection.config.queryFormat = function (query, values) { if (!values) return query; return query.replace(//:(/w+)/g, function (txt, key) { if (values.hasOwnProperty(key)) { return this.escape(values[key]); } return txt; }.bind(this)); }; connection.query("UPDATE posts SET title = :title", { title: "Hello MySQL" }); 十、獲取插入行的id
當使用自增主鍵時獲取插入行id，如：
connection.query('INSERT INTO posts SET ?', {title: 'test'}, function(err, result) { if (err) throw err; console.log(result.insertId); }); 十一、流處理
有時你希望選擇大量的行并且希望在數據到達時就處理他們，你就可以使用這個方法
var query = connection.query('SELECT * FROM posts'); query .on('error', function(err) { // Handle error, an 'end' event will be emitted after this as well }) .on('fields', function(fields) { // the field packets for the rows to follow }) .on('result', function(row) { // Pausing the connnection is useful if your processing involves I/O connection.pause(); processRow(row, function() { connection.resume(); }); }) .on('end', function() { // all rows have been received }); 十二、混合查詢語句（多語句查詢）
因為混合查詢容易被SQL注入攻擊，默認是不允許的，可以使用var connection = mysql.createConnection({multipleStatements: true});開啟該功能。
混合查詢實例：
connection.query('SELECT 1; SELECT 2', function(err, results) { if (err) throw err; // `results` is an array with one element for every statement in the query: console.log(results[0]); // [{1: 1}] console.log(results[1]); // [{2: 2}] }); 同樣可以使用流處理混合查詢結果：
var query = connection.query('SELECT 1; SELECT 2'); query .on('fields', function(fields, index) { // the fields for the result rows that follow }) .on('result', function(row, index) { // index refers to the statement this result belongs to (starts at 0) }); 如果其中一個查詢語句出錯，Error對象會包含err.index指示錯誤語句的id，整個查詢也會終止。
混合查詢結果的流處理方式是做實驗性的，不穩定。
十三、事務處理
connection級別的簡單事務處理
connection.beginTransaction(function(err) { if (err) { throw err; } connection.query('INSERT INTO posts SET title=?', title, function(err, result) { if (err) { connection.rollback(function() { throw err; }); } var log = 'Post ' + result.insertId + ' added'; connection.query('INSERT INTO log SET data=?', log, function(err, result) { if (err) { connection.rollback(function() { throw err; }); } connection.commit(function(err) { if (err) { connection.rollback(function() { throw err; }); } console.log('success!'); }); }); }); }); 十四、錯誤處理
err.code = string err.fatal => boolean
PS：使用mysql模塊時遇到的坑
之前寫了個小程序Node News，用到了MySQL數據庫，在本地測試均沒神馬問題。放上服務器運行一段時間后，偶然發現打開頁面的時候頁面一直處于等待狀態，直到Nginx返回超時錯誤。于是上服務器檢查了遍，發現程序仍然在運行，且能正確記錄每次的請求，再修改代碼跟蹤調試，原來是在查詢數據庫的時候，回調一直沒有被執行，程序就掛在那里了。
想了很久也想不明白為神馬mysql模塊沒有執行回調，最后突然想起來去看了下錯誤日志，才發現有個“No reconnection after connection lost”錯誤沒有被捕捉到，原來是連接丟失了，上github上看了下文檔和issues，上面說到連接丟失后不會自動重新連接，會觸發error事件。我趕緊給程序添加了斷線后自動重連功能，現在已正常運行了10多天。
MySQL中有一個名叫wait_timeout的變量，表示操作超時時間，當連接超過一定時間沒有活動后，會自動關閉該連接，這個值默認為28800（即8小時）。
自動重連數據庫的代碼：
function handleError (err) { if (err) { // 如果是連接斷開，自動重新連接 if (err.code === 'PROTOCOL_CONNECTION_LOST') { connect(); } else { console.error(err.stack || err); } }}// 連接數據庫function connect () { db = mysql.createConnection(config); db.connect(handleError); db.on('error', handleError);}var db;connect();網上流傳的大多數使用mysql模塊的代碼，往往忽略了這個問題，一不小心就讓一撥又一撥的人往坑里踩了。
有童鞋回復問使用pool又會怎樣，于是去看了下mysql模塊的源碼：目前可在npm中安裝到的最新版本為2.0.0-alpha7，使用mysql.createPool()來創建的pool沒辦法自動處理連接被關閉的問題，但是在github上的版本已經修復了（應該還沒發布到npm上），當觸發了connection的error事件時，會把該connection對象從連接池中移除。（源碼：https://github.com/felixge/node-mysql/blob/master/lib/Pool.js#L119 ）
使用pool的代碼：
var mysql = require('mysql');var pool = mysql.createPool(config);pool.getConnection(function(err, connection) { // Use the connection connection.query( 'SELECT something FROM sometable', function(err, rows) { // And done with the connection. connection.end(); // Don't use the connection here, it has been returned to the pool. });});新聞熱點
疑難解答
