let foo = require('foo')

//导出多个数据
exports.a = 'hello'
exports.b = 1
exports.c = {}

//导出单个数据
module.exports = 'hello'
//也可用来导出多个数据
module.exports = {
    a: 'hello',
    b: 1
}

/*  node模块化的底层实现
var module = {
    exports: {}
}
var exports = module.exports
*/
//开始执行文件中的代码
...code
/*
return modeule.exports
*/

let http = require('http')
let server = http.createServer()    //创建服务器实例
//注册事件时回调函数有两个参数
//请求对象request
//相应对象response
server.on('request', (req,res)=>{          //给服务器注册请求事件
    console.log('收到客户端请求'+req.url)   //url返回路径
    //response对象有个方法write可以向客户端发送响应流
    //write可以调用多次，但最后一定要用end结束，否则客户端一直等待
    res.write('hello')
    res.write(' world')
    res.end('aaa')  //可以只写这条语句表示将str写入流之后立即end
})
server.listen(3000, ()=>{       //监听3000端口号
    console.log('服务器开启成功')
})

let express = require('express')
let app = express()
app.use(express.static('./public/'))//按照路由路径直接访问静态资源路径
app.use('/public/', express.static('./public/'))//按照/public/后的路由路径访问静态资源路径

let express = require('express')
let app = express()
app.engine('html', require('art-template-express'))//设置以html为扩展名的文件将启动模板引擎来渲染
app.get('/', (req, res)=>{
  res.render('index.html', {title: 'my template'})  //res默认没有render方法，当设置模板引擎后才会启用，第一个参数不能使用文件路径，express默认会从当前项目中的views文件夹中查找待渲染的文件
})
app.set('views', 'public')  //修改模板默认查找路径，第一个参数不能写错

let bodyParse = require('body-parse')
app.use(bodyParse.urlencoded({extend: false}))
app.use(bodyParse.json())
app.post('/poster', (req, res)=>{
  console.log(req.body) //返回值为请求体的对象
})

function add(x, y, callback){
  setTimeout(()=>{
    callback(x+y)
  })
}
add(1,2,res=>{
  console.log(res)
})

let mongoose = require('mongoose')
//第一步：连接数据库
mongoose.connect('mongodb://localhost/test')
//第二步：创建文档结构
let userSchema = new mongoose.Schema({
  name: {
    type: String,
    require: true
  },
  password: {
    type: String,
    require: true
  },
  email : {
    type: String,
    require: false
  }
})
//第三步：将文档结构应用给文档模型
//第一个参数： 约定是使用第一个字母为大写的单数形式，mongoose会创建一个将此参数调整为小写的复数形式的集合
//第二个参数：需要应用的文档结构
let Users = mongoose.model('User', userSchema)
//第四步：通过模型新增文档对象
Users.create({
  name: '张三妹',
  password: '1223445',
  email: 'aaa@qq.com'
}, (err)=>{
  if(err){
    console.log('保存失败！')
  }else{
    console.log('保存成功！')
  }
})
//或者实例化模型生成文档实例，最后save来保存修改
let user = new Users({
  name: '张三妹',
  password: '1223445',
  email: 'aaa@qq.com'
})
user.save((err, ret)=>{
  if(err){
    console.log('保存失败！')
  }else{
    console.log('保存成功！', ret)
  }
})

//查询满足条件的所有文档对象
//model.find(匹配条件, 投影, 筛选条件, 回调函数)
//投影决定查询出来的字段，可以通过'字段1 -字段2'的形式决定显示与不显示的字段
//筛选条件可用skip，limit，sort等

//model.count(conditions, callback) 用来返回查询到的数据数
users.find({name: '张三妹'}, (err, ret)=>{
    if(err){
      console.log('查询失败！')
    }else{
      console.log('查询成功！', ret)
    }
  })
//查询满足条件的第一条文档对象
users.findOne({name: '张三妹'}, (err, ret)=>{
    if(err){
      console.log('查询失败！')
    }else{
      console.log('查询成功！', ret)
    }
  })

//model.update(conditions, obj, [options], [callback])
//options: multi:true
users.findByIdAndUpdate({'_id': '5cf4cbbce4837e1c10075aa7'}, {
    password: '1223'
  }, (err, ret)=>{
    if(err){
      console.log('修改失败！', err)
    }else{
      console.log('修改成功！', ret)  //ret值为查询到的文档对象修改前的数据
    }
  })
//通过递归修改
users.findById({'_id': '5cf4cbbce4837e1c10075aa7'}, (err, ret)=>{
    if(err){
      console.log('修改失败！', err)
    }else{
      ret.update({  //在查询到的文档基础上调用方法
        $set: {
          password: '1223'
        }
      },err=>{
        if(err) return
        console.log('修改成功！')
      })
      
    }
  })

//model.remove
//model.deleteOne
//model.deleteMany
users.findByIdAndDelete({'_id': '5cf4cbbce4837e1c10075aa7'}, (err, ret)=>{
    if(err){
      console.log('删除失败！', err)
    }else{
      console.log('删除成功！', ret)  //ret的值为删除前查询到的文档对象的数据
    }
  })

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'me',
  password : 'secret',
  database : 'my_db'
});
 
connection.connect();
 
connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results[0].solution);
});
 
connection.end();

fs.readFile('a.txt', (err, data)=>{
  if(err){
    //JS语法，抛出异常,两个作用：
    //1. 阻止程序继续执行
    //2. 将错误消息打印到控制台中
    throw err 
  }else{
    console.log('a')
  }
})
fs.readFile('b.txt', (err, data)=>{
  if(err){
    //JS语法，抛出异常,两个作用：
    //1. 阻止程序继续执行
    //2. 将错误消息打印到控制台中
    throw err 
  }else{
    console.log('b')
  }
})
fs.readFile('c.txt', (err, data)=>{
  if(err){
    //JS语法，抛出异常,两个作用：
    //1. 阻止程序继续执行
    //2. 将错误消息打印到控制台中
    throw err 
  }else{
    console.log('c')
  }
})

$.get('/a', (req, res)=>{
  setTimeout(()=>{
    $.post('/b', (req, res)=>{
      setTimeout(()=>{
          ...
      })
    })
  })
})

function pReadFile(filepath){
  return new Promise((resolve, reject)=>{
    fs.readFile(filepath, (err, data)=>{
      if(err){
        reject(err)
      }else{
        resolve(data)
      }
    })
  })
}
pReadFile('a.txt')
.then(data=>{
  console.log(data)
//如果返回的是一个promise对象，则下一个then方法中的形参就是这个promise对象resolve
//如果不是，则下一个then方法中的形参就是这个返回的值
  return pReadFile('b.txt') 
}).then(data=>{
  console.log(data)
  return pReadFile('c.txt') 
}).then(data=>{
  console.log(data, 'end')
})

function pAjax(router， callback){
  return new Promise((resolve, reject)=>{
    let xhr = new XMLHttpRequest()
    xhr.onload = function(data){
      callback&&callback(null, data)
      resolve(JSON.parse(data))
    }
    xhr.onerror = function(err){
      callback&&callback(err)
      reject(err)
    }
    xhr.open('get', router)
    xhr.send()
  })
}
pAjax('/a')
.then(data=>{
  console.log(data)
  return pAjax('/b')
}).then(data=>{
  console.log(data)
  return pAjax('/c')
}).catch(err=>{
  console.log(err)
})

let session = require('express-session')

app.use(session({
  secret: 'aaaa',     //决定用户数据与什么字符串共同生成加密cookie，提高安全等级
  resave: false,      //决定是否重新更新当前session的生命周期当session过期时无论session数据有没有被修改过
  saveUninitialized: false    //决定是否要初始化session. 设置为false时，如果服务端没有保存过session数据则不会向客户端发送session的cookie
}))

req.session.user = user //保存session数据
req.session.user  //获取session数据

app.use((req, res, next)=>{
  next()    //此方法会调用下一个匹配到的中间件，如果没有则默认在页面显示not get (路径)
})

app.use('/', (req, res, next)=>{})

app.get('/', (req, res, next)=>{})
app.post('/', (req, res, next)=>{})

app.use('/', (req, res, next)=>{
  let err = true
  if(err){
    next(new Error()) //当给next传入参数时，直接跳转到错误处理中间件
  }
})
app.use('/', (err, req, res, next)=>{ //必须为四个参数否则不是错误处理中间件
  console.log(err)  //err的值是上个next中传入的参数值
  res.send(404)
})