相比與java,nodejs的mysql連接方式較為簡單,但需要注意其異步特性

1. 導(dǎo)入mysql模塊

建立mysql連接時,需要用到mysql模塊,一個簡單的require即可完成操作

var mysql = require('mysql');

2. 配置mysql的連接參數(shù)

在java的數(shù)據(jù)庫連接工具JDBC中,數(shù)據(jù)庫的連接參數(shù)以一個url的形式給出.

在nodejs的mysql模塊中,需要調(diào)用該模塊的方法createConnection(),該方法的參數(shù)為JSON格式,該JSON通過規(guī)定好的各個參數(shù)來自寫入數(shù)據(jù)庫的連接數(shù)據(jù)

var connection = mysql.createConnection({

host : 'localhost',

user : 'root',

password : '123456',

database : 'ttms',

charset : 'utf8'

});

3.連接并使用數(shù)據(jù)庫

如上代碼,連接參數(shù)配置之后,將創(chuàng)建一個connection對象,使用該對象的connect()方法來進(jìn)行數(shù)據(jù)庫的連接

connection.connect();

連接之后便可以使用query()函數(shù),來執(zhí)行數(shù)據(jù)庫的語句,一個簡單的查詢示例如下:

var mysql = require('mysql');

var dbFunc = {

fetchById : function(id,callback){

var connection = mysql.createConnection({

host : 'localhost',

user : 'root',

password : '123456',

database : 'ttms',

charset : 'utf8'

});

connection.connect();

var sql = "select * from studio where studio_id = " +id;

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

if(err)

throw err;

callback(result);

});

}

}

module.exports = dbFunc;

4. 需要注意,不同于java語言,nodejs的mysql操作是異步的

如上代碼中,我在傳入查詢的id的同時,還傳入了一個callback函數(shù),用來做出數(shù)據(jù)查詢完成后的操作,這是由nodejs的mysql模塊的異步特性決定的,傳入這樣一個回調(diào)函數(shù),讓只有當(dāng)數(shù)據(jù)的查詢操作完成后,才會執(zhí)行后續(xù)的處理操作,如下為一個簡單的調(diào)用操作(function.js為上面的查詢操作的文件名):

var dbFunc = require('./function.js');

var callback = function(result){

console.log("search result :");

console.log(result);

}

dbFunc.fetchById(2,callback);

總結(jié)

以上是生活随笔為你收集整理的nodejs 定时 mysql_nodejs 使用 mysql的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。