nodejs如何连接Mysql,分享nodejs连接Mysql数据库的方法

nodejs如何连接Mysql,其实nodejs连接mysql数据库比较简单。

首先创建一个数据库及表。如下:

create databases node;
create table test(
	id  int  AUTO_INCREMENT PRIMARY KEY ,
	name  char(50)
)ENGINE=InnoDB DEFAULT CHARSET=utf8;
nodejs连接mysql是需要mysql的驱动支持的:

下面安装MySQL驱动:

$ npm install mysql
下面是nodeJS代码:

var sys = require('util'); 
console.log('正在连接MySQL...'); 
var client = require('mysql').createClient({'host':'localhost','port':3306,'user':'root','password':'xxx'});

clientConnectionReady = function(client) 
{
    client.query('use node', function(error, results) { 
        if(error) { 
            console.log('ClientConnectionReady Error: ' + error.message); 
            client.end(); 
            return; 
        }else{
 	    console.log('已经连接上MySQL....');
	} 
        clientReady(client); 
    }); 
};

clientReady = function(client) { 
    var values = ['不错啊']; 
    client.query('insert into test set name = ?', values, 
        function(error, results) { 
            if(error) { 
                console.log("ClientReady Error: " + error.message); 
                client.end(); 
                return; 
            } 
            console.log('Inserted: ' + results.affectedRows + ' row.'); 
            console.log('Id inserted: ' + results.insertId); 
        } 
    ); 
    getData(client); 
}

getData = function(client) { 
    client.query( 
        'select * from test', 
        function selectCb(error, results, fields) { 
           if (error) { 
                console.log('GetData Error: ' + error.message); 
                client.end(); 
                return; 
           } 

	   for(var i=0; i<results.length; i++){
		var firstResult = results[i]; 
        	console.log('id: ' + firstResult['id']+'    name: ' + firstResult['name']);
	   }

    	}
    ); 
    client.end(); 
    console.log('关闭MySQL连接...'); 
};



clientConnectionReady(client);


关键词: nodejs连接mysql , nodejs , mysql

上一篇: Linux查看占用内存最高和占用CPU最高的前5个进程
下一篇: Discuzx 2.0/2.5/3.0论坛直接发帖接口,Discuzx 接口POST发帖更省事啦

目前还没有人评论,您发表点看法?
发表评论

评论内容 (必填):