blog_mysql 初步完成

把mongoDB数据库替换成mysql 方便操作

Author: strwind

app.js

@@ -0,0 +1,50 @@
+
+/**
+ * Module dependencies.
+ */
+
+var express = require('express')
+  , routes = require('./routes')
+  , user = require('./routes/user')
+  , http = require('http')
+  , path = require('path')
+  , settings = require('./settings')
+  , flash = require('connect-flash');
+
+var app = express();
+
+app.configure(function(){
+  app.set('port', process.env.PORT || 3000);
+  app.set('views', __dirname + '/views');
+  app.set('view engine', 'ejs');
+  app.use(flash());
+  app.use(express.favicon());
+  app.use(express.logger('dev'));
+  app.use(express.bodyParser());
+  app.use(express.methodOverride());
+  app.use(express.cookieParser());
+  app.use(express.session({ 
+      secret: settings.cookieSecret
+   }));
+  app.use(app.router);
+  app.use(express.static(path.join(__dirname, 'public')));
+});
+
+app.configure('development', function(){
+    app.use(express.errorHandler());
+});
+
+app.use(function(req,res,next){
+    var err = req.flash('error'),
+        success = req.flash('success');
+    res.locals.user = req.session.user;
+    res.locals.error = err.length ? err : null;
+    res.locals.success = success.length ? success : null;
+    next();
+});
+
+http.createServer(app).listen(app.get('port'), function(err){
+  console.log("Express server listening on port " + app.get('port'));
+});
+
+routes(app);

models/db.js

@@ -0,0 +1,27 @@
+/*
+var settings = require('../settings'),
+    Db = require('mongodb').Db,
+    Connection = require('mongodb').Connection,
+    Server = require('mongodb').Server;
+module.exports = new Db(settings.db, new Server(settings.host, Connection.DEFAULT_PORT, {}));
+*/
+var mysql = require('mysql'),
+    settings = require('../settings');
+var connection = mysql.createConnection({
+    host : settings.host,
+    database : 'blog_mysql',
+    user : 'root',
+    password : ''
+});
+connection.connect();
+module.exports = connection;
+
+/*
+connection.query('SELECT * FROM users', function(err, rows, fields) {
+  if (err) throw err;
+
+  console.log('The solution is: ', rows);
+});
+
+connection.end();
+*/

models/post.js

@@ -0,0 +1,47 @@
+
+var mysql = require('./db');
+
+function Post(username, title, post, time) {
+    this.user = username;
+    this.title= title;
+    this.post = post;
+    if (time) {
+        this.time = time;
+    } else {
+        this.time = new Date();
+    }
+}
+Post.prototype.save = function save(callback) {
+    var post = {
+        user: this.user,
+        title:this.title,
+        post: this.post,
+        time: this.time,
+    };
+    var query = mysql.query('INSERT INTO posts SET ?', post, function(err, result) {
+        if(err){
+            callback(err);
+        }
+        console.log(result);
+        callback(err, result);
+    });
+};
+//几个路由共用，所以为静态方法
+Post.get = function get(username, callback) {
+    var query = username || '*';
+    var sql = 'SELECT '+ query +' FROM posts';
+    mysql.query(sql, function(err, rows, fields) {
+         if (err) {
+             callback(err);
+         }
+         rows.forEach(function (row, index) {
+            var now = row.time;
+            row.time = now.getFullYear() + "-" + (now.getUTCMonth()+1) + "-" + now.getUTCDate();
+         });
+         rows.reverse();//倒序排列
+         callback(null, rows);
+    });
+};
+
+module.exports = Post;
+

models/user.js

@@ -0,0 +1,36 @@
+
+var mysql = require('./db');
+function User(user){
+    this.name = user.name;
+    this.password = user.password;
+};
+
+User.prototype.save = function save(callback) {
+    var post  = {
+        name:this.name,
+        password: this.password
+    };
+    var query = mysql.query('INSERT INTO users SET ?', post, function(err, result) {
+        if(err){
+            callback(err);
+        }
+        callback(err, result);
+    });
+};
+
+//几个路由共用，所以为静态方法
+User.get = function get(username, callback){
+    var query = username;
+    var sql = 'SELECT * FROM users WHERE `NAME`= '+ query;
+    
+    mysql.query(sql, function(err, rows, fields) {
+        if(err){
+            callback(err);
+        }
+        var row = rows ? rows[0] : [];
+        callback(err, row);
+    });
+};
+
+module.exports = User;
+