nodejs 鏈接Mysql相關操做的示例代碼

最近在搞nodejs,要作一些數據庫的相關操做,數據庫用的是Mysql,網上也有很多代碼,紅薯也一篇博文說明了相關操做,可是拿來用的時候,發現了一些小問題,仔細研究,紅薯提供的代碼是官方的舊代碼(你們有興趣的能夠搜索一下紅薯關於這個操做的介紹),也許是後續的nodejs mysql版本作了改動,以致於以前的代碼沒法編譯,這裏小弟就爲你們更新一下。 node

首先是安裝nodejs有關mysql的包 mysql

$npm install mysql
鏈接代碼:
//init the connection
var Client = require('mysql').createConnection({


    host:"127.0.0.1",
    user:"root",
    password:"root",
    database: "test"


});


console.log('Connecting to MySQL...');
Client.connect(function(error, results) {
  if(error) {
    console.log('Connection Error: ' + error.message);
    return;
}
console.log('Connected to MySQL successfully!');
});

//select the DB
Client.query('use test', function(error, results) {
    if(error) {
        console.log('ClientConnectionReady Error: ' + error.message);
           // client.end();
           return;
       }
   });
//select sql statement
Client.query('select * from eric', function(error, results) {
    if(error) {
        console.log('ClientConnectionReady Error: ' + error.message);
        client.end();
        return;
    }
    console.log(results);
});//insert sql statement;
/*Client.query('insert into eric values(3,"a")', function(error, results) {
    if(error) {
        console.log('ClientConnectionReady Error: ' + error.message);
        client.end();
        return;
    }
    console.log("insert successfully!");
});*/


//delete sql statement
/*Client.query('delete from eric where id=3', function(error, results) {
    if(error) {
        console.log('ClientConnectionReady Error: ' + error.message);
        client.end();
        return;
    }
    console.log("delete successfully!");
});*/
//update sql statement
Client.query('update eric set name="alice" where id=2', function(error, results) {
    if(error) {
        console.log('ClientConnectionReady Error: ' + error.message);
        client.end();
        return;
    }
    console.log("update successfully!");
});
相關文章
相關標籤/搜索