node.js连接mysql及相关操作.docxVIP

File:mysqlDAO.js-/* * Created by Administrator on 14-12-30. * Test Mysql DB Operation */var sys = require(sys);var mysql = require(mysql);var connection = mysql.createConnection( host: localhost, user: root, password: root, port: 3306, database: test);var sid = 100;function invoke(callback, data) if (callback = null | typeof callback = function) console.log(data); return; callback(data);/ 连接Mysql数据库exports.ready = function (callback) /this.state = disconnected; if (connection.state != disconnected) return invoke(callback, code: 0, message: already connect mysql ); / 连接mysql数据库 connection.connect(function (error) if (error) return invoke(callback, code: 1, message: connect error: + error.message ); return invoke(callback, code: 0, message: Connect to Mysql OK! ); );/ 插入数据exports.insert = function (callback) var sql = INSERT INTO t_test SET id = ?, name = ?, fee = ?, address=? ; var values = sid+, 李四 + sid, 888, 上海市浦东新区1800号; / 插入数据 connection.query(sql, values, function (error, results) if (error) return invoke(callback, code: 1, message: ClientReady Error: + error.message ); return invoke(callback, code: 0, message: Id inserted: + results.insertId ); /console.log(Inserted: + results.affectedRows + row.); /console.log(Id inserted: + results.insertId); );/ 查询数据exports.getData = function (callback) connection.query(SELECT * FROM t_test, function (error, results) if (error) invoke(callback, code: 1, message: GetData Error: + error.message ); return; if (results.length 0) var data = ; for (var i = 0; i results.length; i+) var item = resultsi; data += name is + itemname + ; ; invoke(callback, code: 0, message: data ); return; invoke(callback, code: -1, message: no result ); return; );File: mytest.js-use strict;var config = require(./config);var mysql = require(./dao/mysqlDao);exports.hello = function (req, res, next) var title; csharpCall(Node.JS, function (err, result) if (err) return next(err); title = result; ); res.render(mytest.html, info: title | hello world! );exports.connmysql = function (req, res, next) mysql.ready(function (e) res.render(mytest.html, info: e.message ); );exports.testdata = function (req, res, next) mysql.getData(function (e) res.render(mytest.html, info: e.message ); );exports.testadd = function (req, res, next) mysql.insert(function (e) res.render(mytest.html, info: e.message ); );File: config.js-use strict;exports.debug = true;exports.port = 30002;exports.email = ;exports.site_name = xxx;exports.site_desc = xxx;exports.session_secret = xxx;File: app.js-var express = require(express);var mytest = require(./controllers/mytest)var http = require(http)var config = require(./config)/ WEB服务执行模块var app = express();/ 设置WEB视图引擎app.engine(html, require(ejs).renderFile);/ 配置Web服务app.configure(function () app.set(port, config.port); /WEB服务监听端口 app.set(view engine, ejs); /视图引擎 app.set(views, _dirname + /views); /视图目录 app.set(layout, _dirname + /views/layout.html); app.set(view options, layout: true ); app.use(express.logger(dev); /按开发者级别记录日志 app.use(express.bodyParser(); app.use(express.methodOverride(); app.use(app.router); /开启路由 app.use(express.static(_dirname + /public););app.configure(development, function () app.use(express.errorHandler(););/ WEB路由app.get(/test/mysql, mytest.connmysql);app.get(/test/mysql/data, mytest.testda