var Sequelize = require('sequelize');
module.exports = new Sequelize('test', 'root', null, {//密码为空用null或''表示
    host: 'localhost', // 数据库地址
    dialect: 'mysql', // 指定连接的数据库类型
    pool: {
        max: 5, // 连接池中最大连接数量
        min: 0, // 连接池中最小连接数量
        idle: 10000 // 如果一个线程 10 秒钟内没有被使用过的话，那么就释放线程
    }
});

// user.js
var Sequelize = require('sequelize');
var sequelize = require('../config/db');
// 创建 model
var User = sequelize.define('user', {
    userName: {
        type: Sequelize.STRING // 指定值的类型
    },
    // 没有指定 field，表中键名称则与对象键名相同，为 email
    email: {
        type: Sequelize.STRING
    }
}, {
    // 如果为 true 则表的名称和 model 相同，即 user
    // 为 false MySQL创建的表名称会是复数 users
    // 如果指定的表名称本就是复数形式则不变
    freezeTableName: false
});
// 创建表
// User.sync() 会创建表并且返回一个Promise对象
// 如果 force = true 则会把存在的表（如果users表已存在）先销毁再创建表
// 默认情况下 forse = false
var user = User.sync({ force: false });
// 添加新用户
exports.addUser = function(userName, email) {
    // 向 user 表中插入数据
    return User.create({
        userName: userName,
        email: email
    });
};
// 通过用户名查找用户
exports.findByName = function(userName) {
    return User.findOne({ where: { userName: userName } });
};
//通过id找用户
exports.findById = function(id) {
    return User.findOne({ where: { id: id } });
};

var express = require('express');
var router = express.Router();
var user = require('../models/user');
/* GET users listing. */
router.get('/', function(req, res, next) {
    if(req.query.id){
        user.findById(req.query.id).then(function(user){
            res.send(user.userName);
        });
    }else{
      res.send('hello users');
    }
});
router.get('/addUser', function(req, res, next) {
    user.addUser('llan', 'llan@163.com').then(function() {
        // 查询新添加的用户
        return user.findByName('llan');
    }).then(function(user) {
        res.send(user.userName);
    });
});
module.exports = router;

//...
var express = require('express')
var multer  = require('multer')
var app = express()
app.use(multer({
    dest: './uploads/'
}).single('file'));
//...

router.post('/script/addFile',function(req,res,next){
    console.log('file',req.file)
});

pool.getConnection(function(err, connection) {
    var script;
    var id = req.query.id;
    fs.readFile(req.file.path, function (err, data) {
        if (err) {
            return console.error(err);
        }
        script = data.toString();
        connection.query($sql.script.updateScript, [script,id], function(err, result) {
            if(result) {
                result = {
                    code: 200,
                    success:true
                };
            }
            // 以json形式，把操作结果返回给前台页面
            jsonWrite(res, result);
            // 释放连接
            connection.release();
        });
    });
});

script:{
    updateScript:'update script set script=? where id=?'
}

app.listen(3000, function () {
    console.log('my app listening on port 3000!');
});