nodejs 定时 mysql_nodejs 使用 mysql
相比與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)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: qsettings删除注册表_Qt Q
- 下一篇: mysql移植海思_海思Hi3518EV