本文實例講述了node.js連接mysql與基本用法。分享給大家供大家參考,具體如下:
下載mysql模塊
使用命令npm install mysql
下載mysql模塊
mysql引入模塊
var mysql = require("mysql");
創建連接池
使用createPool()
創建一個mysql連接池,傳入一個表參數作為連接信息
var pool = mysql.createPool({ host:"127.0.0.1", port:3306, //默認端口3306 database:"student", //需要連接的數據庫 user:"root", //用戶名 password:"123456", //密碼});
編寫操作函數
使用連接池的方法getConnection()
獲取連接方法
參數callback方法有三個參數錯誤信息err,SQL語句的結果sql_result,字段說明fields_desc
conn.query(sql,callback)
執行發送來的sql語句,然后調用callback
function mysql_exec(sql,callback){ //getConnection是從連接池獲得mysql的連接通道 //異步獲取,成功就會調用callback,conn就會返回一個 //與mysql通訊句柄 pool.getConnection(function(err,conn){ if(err){ if(callback){ callback(err,null,null); } return; } conn.query(sql,function(sql_err,sql_result,fields_desc){ if(sql_err){ if(callback){ callback(sql_err,null,null); } return; } //sql_result返回結果 //field_desc if(callback){ callback(null,sql_result,fields_desc); } }) });}
使用操作函數
sql操作基本都是異步進行的
mysql_exec("select * from mess",function(err,sql_result,fields_desc){ if(err){ console.log(err); return; } if(sql_result){ console.log(sql_result); //此處會打印出sql返回結果 } if(fields_desc){ console.log(fields_desc); //此處會打印出每個字段的說明 }});
希望本文所述對大家nodejs程序設計有所幫助。
新聞熱點
疑難解答