node.js 操做mysql數據庫

nodeJS 操做 MySQL

1. 在數據庫（如例所示lzq）裏建1張表（如例所示teachers）。

2. 安裝nodeJS版MySQL驅動：

   npm install mysql;

3. 執行startSQL.js文件：

   node startSQL.js

4. 測試環境:

   node.js 0.6.12

5. 共2個js文件：startSQL.js and CRUD.js.

startSQL.js ------------------------------->

var CRUD = require('./CRUD'),

     sys = require('util'),

     client = require('mysql').createClient({'host':'localhost',

                                                   'port':3306,

                                           'user':'root',

                                           'password':'123456'}),

     ClientConnectionReady = function(client){

// - just for test, these variables can be from request process program. ---------------------------------

var value = ['10', 'fillp', 'abc'],

insertSQLString = 'INSERT INTO teachers SET id = ?, name = ? , pwd = ?',

                         //teachers is the table name.

selectSQLString = 'SELECT * FROM teachers',

updateSQLString = "update teachers set NAME='ipone' where ID=4",

deleteSQLString = 'delete from teachers where ID=10'; 

// -----------------------------------

console.log('ClientConnectionReady'),

console.log('\n');

client.query('USE lzq', function(error, results) { // lzq is the name of database.

if(error){  

console.log('ClientConnectionReady Error: ' + error.message), 

client.end(); 

return;  

}  

console.log('Connecting to MySQL...'),

console.log('Connected to MySQL automatically'),

console.log('\n'),

//CRUD._insert(client,insertSQLString,value), 

CRUD._select(client,selectSQLString),

//CRUD._update(client,updateSQLString), 

//CRUD._delete(client,deleteSQLString),

console.log('connection success...'),

console.log('\n'),

client.end(), 

console.log('Connection closed'),

console.log('\n');

});  

};

ClientConnectionReady(client);

CRUD.js -------------------------------->

var CRUD = {

_insert : function(client,insertSQLString,value){ 

client.query(insertSQLString, value,  

function(error, results) {  

if(error) {  

console.log("ClientReady Error: " + error.message),  

client.end(); 

return;  

}  

console.log('Inserted: ' + results.affectedRows + ' row.'),

console.log('insert success...');

}  

); 

},

_select : function(client,selectSQLString){

client.query(selectSQLString,  

function selectCb(error, results, fields) {  

if (error) {  

console.log('GetData Error: ' + error.message), 

client.end();  

return;  

}  

if(results.length > 0){  

var firstResult,

resultSet = '';

for(var i = 0, len = results.length; i < len; i++){

firstResult = results[i],

resultSet += 'id:   ' + firstResult['id'] + '         ' + 'name:   ' + firstResult['name'] + '          ' + 'pwd:      ' + firstResult['pwd'] + '\n';   

}

}

console.log(resultSet);

/* 添加功能：使查詢結果集返回到客戶端並保證此函數的通用性. */

}

); 

},

_update : function(client,updateSQLString){

client.query(updateSQLString,  

function(error, results) {  

if(error) {  

console.log("ClientReady Error: " + error.message),  

client.end();

return;  

}  

console.log('update success...');

}  

);

},

_delete : function(client,deleteSQLString){

client.query(deleteSQLString,  

function(error, results) {  

if(error) {  

console.log("ClientReady Error: " + error.message),  

client.end();

return;  

}  

console.log('delete success...');

}  

);

}

};

exports._insert = CRUD._insert,

exports._select = CRUD._select,

exports._update = CRUD._update,

exports._delete = CRUD._delete;