用Nodejs连接MySQL

阳光穿透心脏的1/2处 2022-08-21 13:53 267阅读 0赞

出处：blog.fens.me/nodejs-mysql-intro/

解决了链接数据库/自动重连数据库/连接池等问题。

*  表新删改查
 *  连接池配置
 *  MySQL断线重连
 *  连接池超时测试

主要内容：

1.链接：

var mysql = require('mysql');
    var conn = mysql.createConnection({
        host: 'localhost',
        user: 'nodejs',
        password: 'nodejs',
        database: 'nodejs',
        port: 3306
    });
    conn.connect();
    
    var sql=' '
    
    conn.query(sql, function (err0, res0) {})

2.连接池配置：

~ vi app-pooling.js
    
    var mysql = require('mysql');
    var pool = mysql.createPool({
        host: 'localhost',
        user: 'nodejs',
        password: 'nodejs',
        database: 'nodejs',
        port: 3306
    });
    
    var selectSQL = 'select * from t_user limit 10';
    
    pool.getConnection(function (err, conn) {
        if (err) console.log("POOL ==> " + err);
    
        conn.query(selectSQL,function(err,rows){
            if (err) console.log(err);
            console.log("SELECT ==> ");
            for (var i in rows) {
                console.log(rows[i]);
            }
            conn.release();
        });
    });

输出：

D:\workspace\javascript\nodejs-node-mysql>node app-pooling.js
    SELECT ==>
    { id: 39,
      name: 'conan update',
      create_date: Wed Sep 11 2013 13:41:18 GMT+0800 (中国标准时间) }
    { id: 40,
      name: 'fens.me',
      create_date: Wed Sep 11 2013 13:41:18 GMT+0800 (中国标准时间) }

3.mysql重新断连：

~ vi app-reconnect.js
    
    var mysql = require('mysql');
    var conn;
    function handleError () {
        conn = mysql.createConnection({
            host: 'localhost',
            user: 'nodejs',
            password: 'nodejs',
            database: 'nodejs',
            port: 3306
        });
    
        //连接错误，2秒重试
        conn.connect(function (err) {
            if (err) {
                console.log('error when connecting to db:', err);
                setTimeout(handleError , 2000);
            }
        });
    
        conn.on('error', function (err) {
            console.log('db error', err);
            // 如果是连接断开，自动重新连接
            if (err.code === 'PROTOCOL_CONNECTION_LOST') {
                handleError();
            } else {
                throw err;
            }
        });
    }
    handleError();

以上只在链接超时时可以自动重连。

密码错误时：

D:\workspace\javascript\nodejs-node-mysql>node app-reconnect.js
    error when connecting to db: { [Error: ER_ACCESS_DENIED_ERROR: Access denied for user 'nodejs'@'localhost' (using pass
    rd: YES)]
      code: 'ER_ACCESS_DENIED_ERROR',
      errno: 1045,
      sqlState: '28000',
      fatal: true }
    error when connecting to db: { [Error: ER_ACCESS_DENIED_ERROR: Access denied for user 'nodejs'@'localhost' (using pass
    rd: YES)]
      code: 'ER_ACCESS_DENIED_ERROR',
      errno: 1045,
      sqlState: '28000',
      fatal: true }

数据库当机：

D:\workspace\javascript\nodejs-node-mysql>node app-reconnect.js
    db error { [Error: read ECONNRESET]
      code: 'ECONNRESET',
      errno: 'ECONNRESET',
      syscall: 'read',
      fatal: true }
    
    Error: read ECONNRESET
        at errnoException (net.js:884:11)
        at TCP.onread (net.js:539:19)

当数据库链接超时时，可正常重连：

在reconnection.js中添加：

~ vi app-reconnection.js
    
    function query(){
        console.log(new Date());
        var sql = "show variables like 'wait_timeout'";
        conn.query(sql, function (err, res) {
            console.log(res);
        });
    }
    
    query();
    setInterval(query, 15*1000);

结果：

D:\workspace\javascript\nodejs-node-mysql>node app-reconnect.js
    Wed Sep 11 2013 15:21:14 GMT+0800 (中国标准时间)
    [ { Variable_name: 'wait_timeout', Value: '10' } ]
    db error { [Error: Connection lost: The server closed the connection.] fatal: true, code: 'PROTOCOL_CONNECTION_LOST' }
    Wed Sep 11 2013 15:21:28 GMT+0800 (中国标准时间)
    [ { Variable_name: 'wait_timeout', Value: '10' } ]
    db error { [Error: Connection lost: The server closed the connection.] fatal: true, code: 'PROTOCOL_CONNECTION_LOST' }
    Wed Sep 11 2013 15:21:43 GMT+0800 (中国标准时间)
    [ { Variable_name: 'wait_timeout', Value: '10' } ]

连接池超时重连：

http://blog.fens.me/nodejs-async-timer/

\-----Async多任务时间管理;