一、安装

npm install mysql

二、引入模块,并连接mysql

varmysql  =require(‘mysql’);//调用MySQL模块//创建一个connectionvarconnection = mysql.createConnection({host:’127.0.0.1′,//主机user    :’root’,//MySQL认证用户名password :’abcd’,//MySQL认证用户密码port:’3306′,//端口号database:’school’,//数据库名称});//创建一个connectionconnection.connect(function(err){if(err){console.log(‘[query] – :’+err);return;    }console.log(‘[connection connect]  succeed!’);});//执行SQL语句connection.query(‘SELECT 1 + 1 AS solution’,function(err, rows, fields){if(err) {console.log(‘[query] – :’+err);return;    }console.log(‘The solution is: ‘, rows[0].solution);  });//关闭connectionconnection.end(function(err){if(err){return;    }console.log(‘[connection end] succeed!’);});

test->插入数据

varmysql  =require(‘mysql’);varconnection = mysql.createConnection({host:’192.168.0.200′,user:’root’,password:’abcd’,port:’3306′,database:’nodesample’, }); connection.connect();varuserAddSql =’INSERT INTO userinfo(Id,UserName,UserPass) VALUES(0,?,?)’;varuserAddSql_Params = [‘Wilson’,’abcd’];//增connection.query(userAddSql,userAddSql_Params,function(err, result){if(err){console.log(‘[INSERT ERROR] – ‘,err.message);return;        }console.log(‘————————–INSERT—————————-‘);//console.log(‘INSERT ID:’,result.insertId);        console.log(‘INSERT ID:’,result);console.log(‘—————————————————————–nn’);  });connection.end();

从执行结果可以看出,result中包含一些有用的信息,affectedRows(受影响的行数)insertId(插入的主键ID)等等。

有受影响的行数和插入数据的ID,就可以很方便进行后续的一些操作(比如判断是否成功或者继续根据插入数据的ID进行其它操作)

test->查询数据

varmysql  =require(‘mysql’);varconnection = mysql.createConnection({host:’192.168.0.200′,user:’root’,password:’abcd’,port:’3306′,database:’nodesample’, }); connection.connect();varuserGetSql =’SELECT * FROM userinfo’;//查connection.query(userGetSql,function(err, result){if(err){console.log(‘[SELECT ERROR] – ‘,err.message);return;        }console.log(‘————————–SELECT—————————-‘);console.log(result);console.log(‘—————————————————————–nn’);  });connection.end();

从查询出来的结果可以看出,result返回了一个JSON格式的数据

三、结束数据库连接两种方法和区别

前面的示例中我在结尾处都会调用一个connection.end()方法,这个方法connection.connect()对应,一个开始,一个结束!

结束连接其实有两种方法end(),destory();

end()

end()方法在queries都结束后执行,end()方法接收一个回调函数,queries执行出错,仍然后结束连接,错误会返回给回调函数err参数,可以在回调函数中处理!

destory()

比较暴力,没有回调函数,即刻执行,不管queries是否完成!

四、连接池Pooling connections(生产环境请使用连接池)

1.连接池的创建,使用createPool方法,options和createConntion一致,可以监听connection事件。

varmysql =require(‘mysql’);//创建连接池varpool  = mysql.createPool({host:’192.168.0.200′,user:’root’,password:’abcd’});

连接池可以直接使用,也可以共享一个连接或管理多个连接(引用官方示例)

//直接使用pool.query(‘SELECT 1 + 1 AS solution’,function(err, rows, fields){if(err)throwerr;console.log(‘The solution is: ‘, rows[0].solution);});//共享pool.getConnection(function(err, connection){// connected! (unless err is set)});

3.释放

调用connection.release()方法,会把连接放回连接池,等待其它使用者使用!

varmysql =require(‘mysql’);varpool  = mysql.createPool({host:’192.168.0.200′,user:’root’,password:’abcd’,port:’3306′,database:’nodesample’});pool.getConnection(function(err, connection){    connection.query(‘SELECT * FROM userinfo;’,function(err, result){console.log(result);        connection.release();    });    connection.query(‘SELECT * FROM userinfo;’,function(err, result){console.log(result);        connection.release();    });});

五、断线重连

数据库可以因为各种原因导致连接不上,这种就必须有重连接机制!

主要判断errorcode:PROTOCOL_CONNECTION_LOST

varmysql =require(‘mysql’);vardb_config = {host:’192.168.0.200′,user:’root’,password:’abcd’,port:’3306′,database:’nodesample’};varconnection;functionhandleDisconnect(){  connection = mysql.createConnection(db_config);                                                connection.connect(function(err){if(err) {console.log(“进行断线重连:”+newDate());      setTimeout(handleDisconnect,2000);//2秒重连一次return;    }console.log(“连接成功”);    });                                                                            connection.on(‘error’,function(err){console.log(‘db error’, err);if(err.code =’PROTOCOL_CONNECTION_LOST’) {      handleDisconnect();                            }else{throwerr;                                    }  });}handleDisconnect();

作者:victor

链接:https://www.jianshu.com/p/e875856a588a

來源:简书

著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

文章来源于互联网:nodejs连接mysql

发表评论