建站
咨詢
售后
建站咨詢
新聞中心
Node中怎么連接MySQL數(shù)據(jù)庫(kù)，很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來(lái)學(xué)習(xí)下，希望你能有所收獲。
“專業(yè)、務(wù)實(shí)、高效、創(chuàng)新、把客戶的事當(dāng)成自己的事”是我們每一個(gè)人一直以來(lái)堅(jiān)持追求的企業(yè)文化。 成都創(chuàng)新互聯(lián)是您可以信賴的網(wǎng)站建設(shè)服務(wù)商、專業(yè)的互聯(lián)網(wǎng)服務(wù)提供商! 專注于網(wǎng)站制作、成都網(wǎng)站制作、軟件開(kāi)發(fā)、設(shè)計(jì)服務(wù)業(yè)務(wù)。我們始終堅(jiān)持以客戶需求為導(dǎo)向，結(jié)合用戶體驗(yàn)與視覺(jué)傳達(dá)，提供有針對(duì)性的項(xiàng)目解決方案，提供專業(yè)性的建議，創(chuàng)新互聯(lián)建站將不斷地超越自我，追逐市場(chǎng)，引領(lǐng)市場(chǎng)！
npm install --save mysql
使用上述命令安裝完MySQL的模塊后，就可以直接使用了，官網(wǎng)的DOCS里一個(gè)簡(jiǎn)單的例子如下就可以入門了。
var mysql = require('mysql');
var connection = mysql.createConnection({
host: 'localhost',
user: 'me',
password : 'secret',
database : 'my_db'
});
connection.connect();
connection.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {
if (err) throw err;
console.log('The solution is: ', rows[0].solution);
});
connection.end();很簡(jiǎn)單的一個(gè)例子，從上面的例子可以得出：使用createConnection(option)方法創(chuàng)建一個(gè)連接對(duì)象，然后連接對(duì)象的connect()方法創(chuàng)建連接，最后使用query()方法執(zhí)行SQL語(yǔ)句，返回結(jié)果作為回調(diào)函數(shù)的參數(shù)rows返回，rows為數(shù)組類型。
1. 連接
創(chuàng)建連接對(duì)象，需要傳入連接數(shù)據(jù)庫(kù)的一些連接參數(shù)，也就是createConnection(option)里的option，option是一個(gè)對(duì)象，以鍵值對(duì)的形式傳入createConnection()方法里。上例列舉出了最基本的參數(shù)：
host 主機(jī)名
user 連接數(shù)據(jù)庫(kù)的用戶
password 密碼
database 數(shù)據(jù)庫(kù)名稱
還有其他的參數(shù)，可以查詢下官方DOCS，這里不一一列舉了，初期學(xué)習(xí)上面這些參數(shù)就足以。
2. 關(guān)閉
關(guān)閉一個(gè)連接使用end()方法，end()方法提供一個(gè)回調(diào)函數(shù)，如下：
connect.end(function(err){
console.log('End a connection');
});這是建議使用的方法，end()方法會(huì)等待連接回調(diào)完成后才關(guān)閉連接。官方還提供了另外一種方法destroy()方法，這個(gè)方法直接關(guān)閉連接，不會(huì)等待回調(diào)完成。
舉個(gè)簡(jiǎn)單的例子：
var mysql = require('mysql');
var option = require('./connect.js').option;
var conn = mysql.createConnection(option);
conn.query('select * from message',function(err,rows,fields){
if(!err){
console.log(rows);
}
});
conn.end(function(err){
console.log('end a connection');
});最終結(jié)果會(huì)是：先打印完SELECT數(shù)據(jù)表結(jié)果后，再打印end a connection。而如果你將關(guān)閉方法換成conn.destroy();，那么你就別想返回任何結(jié)果了，因?yàn)檫€沒(méi)等回調(diào)結(jié)束就已經(jīng)終止連接了。
3. 連接池
連接池的原理是一開(kāi)始就給你創(chuàng)建多個(gè)連接對(duì)象放在一個(gè)“池子”里，用的時(shí)候取一個(gè)，用完了放回“池子”里，在一定程度上是有利于節(jié)省系統(tǒng)開(kāi)銷的，因?yàn)檫B接對(duì)象是在最開(kāi)始的時(shí)候就創(chuàng)建好了，使用的時(shí)候不再需要系統(tǒng)開(kāi)銷去創(chuàng)建數(shù)據(jù)庫(kù)連接對(duì)象。官方DOCS介紹了連接方法：
var mysql = require('mysql');
var pool = mysql.createPool({
connectionLimit : 10,
host : 'example.org',
user : 'bob',
password : 'secret',
database : 'my_db'
});
pool.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {
if (err) throw err;
console.log('The solution is: ', rows[0].solution);
});創(chuàng)建連接池的方法是createPool(option)，option里多了一個(gè)參數(shù)connectionLimit指的是一次性在連接池里創(chuàng)建多少個(gè)連接對(duì)象，默認(rèn)10個(gè)。如果你想共享一個(gè)連接對(duì)象，可以使用下面方法進(jìn)行連接；
var mysql = require('mysql');
var pool = mysql.createPool({
host : 'example.org',
user : 'bob',
password : 'secret',
database : 'my_db'
});
pool.getConnection(function(err, connection) {
// Use the connection
connection.query( 'SELECT something FROM sometable', function(err, rows) {
// And done with the connection.
connection.release();
// Don't use the connection here, it has been returned to the pool.
});
// Use the connection
connection.query( 'SELECT something2 FROM sometable2', function(err, rows) {
// And done with the connection.
connection.release();
// Don't use the connection here, it has been returned to the pool.
});
});使用一個(gè)連接對(duì)象執(zhí)行兩次query()函數(shù)。
4. 示例1
使用基本的連接方式來(lái)連接數(shù)據(jù)庫(kù)，分別定義數(shù)據(jù)連接以及關(guān)閉的function，如下示例：
// connect.js 數(shù)據(jù)庫(kù)連接與關(guān)閉
var mysql = require('mysql');
var config = require('./config.json'); // 將數(shù)據(jù)庫(kù)連接參數(shù)寫入mysql對(duì)象，即config.mysql
var connCount = 0; // 統(tǒng)計(jì)目前未關(guān)閉的連接
exports.getConn = function(){
connCount ++;
console.log('............................OPEN a connection, has '+ connCount + ' connection.');
return mysql.createConnection(config.mysql);
};
exports.endConn = function(conn){
conn.end(function(err){
if(!err){
connCount --;
console.log('.........................CLOSE a connection, has '+ connCount + ' connection.');
}
});
};然后給個(gè)使用數(shù)據(jù)庫(kù)的示例，
// db.js 查詢用戶信息
var connect = require('./connect.js'); // 引入數(shù)據(jù)連接方法
exports.getUser = function(username, callback){
var connection = connect.getConn();
var sql = 'select * from user where username = "' + username + '"';
connection.query(sql,function(err,rows,fields){
callback(err,rows,fields);
});
connect.endConn(connection);
}5. 示例2
使用數(shù)據(jù)庫(kù)連接池，同樣先創(chuàng)建數(shù)據(jù)庫(kù)連接池的方法，如下兩種方式：
// connect.js 直接使用
var mysql = require('mysql');
var config = require('./config.json');
var pool = mysql.createPool(config.mysql);
exports.querySQL = function(sql,callback){
pool.query(sql, function(err,rows,fields){
callback(err,rows,fields);
});
}// connect.js 使用getConnection方法
var mysql = require('mysql');
var config = require('./config.json');
var pool = mysql.createPool(config.mysql);
exports.querySQL = function(sql, callback){
pool.getConnection(function(err,conn){
conn.query(sql,function(err,rows,fields){
callback(err,rows,fields);
conn.release(); // 不要忘了釋放
});
});
}使用的時(shí)候，直接使用querySQL方法即可，如下：
// db.js 查詢用戶信息
var connect = require('./connect.js');
exports.getUser = function(username,callback){
var sql = 'select * from user where username = "' + username + '"';
connect.querySQL(sql,function(err,rows,fields){
callback(err,rows,fields);
});
};看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對(duì)創(chuàng)新互聯(lián)的支持。
當(dāng)前文章：Node中怎么連接mysql數(shù)據(jù)庫(kù)
標(biāo)題網(wǎng)址：http://fisionsoft.com.cn/article/gpisdo.html
