以下内容全是我个人理解写出，如有不对，请立刻练习本人进行更改。以免被刚入门的被我带入坑里。
—node是什么？我想大家应该都知道。
node是前端未来干掉后端的一种语言，是用JavaScript来编写后端代码的一种语言。前端走后端的路让后端无路可走。是前端人员走向全栈开发的一条路。
—学习node要掌握什么呢？学习它就需要掌握一下几个方面，这是我现在学习的时候需要掌握的东西，算是很基本的东西了。
一、node的安装
二、数据库的安装和使用（sql命令）
三、node最底层基本写法
四、koa框架
五、Sequelize功能模块使用
六、读写文件
node的安装在这里就不讲了，网上一搜就都能搜到的，不想搜也可以点击这个连接，去看下node安装这些都有详细的介绍。
数据库的安装在网上也能够搜索到，安装数据库可以看下这个博客，这里写的挺详细的，从安装数据库到navicat MySQL的安装都有 查看请点击这里↓↓↓↓↓↓↓
sql的命令离不开增删改查
mydb：数据库名
user：表名
text：对应的属性名
2：要插入的数据
id：主键
age：对应的属性
增： INSERT INTO `mydb`.`user` (`text`) VALUES ('2');
删：DELETE FROM user WHERE id=1
改：UPDATE `mydb`.`user` SET `age`='22' WHERE `id`='1';
查：select * from user
以上就是数据操作的主要四个，其他命令可以百度一下，一抓一大把。
接下来进入最主要的地方了，开是接触放弃的地方了，底层的基本用法
+开始需要把数据库放进去才能够使用
$ cnpm install mysql
接下来引入你本地的数据库
// 连接数据库
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
user : 'root',
password : '123456',
database : 'node'
});
接下来开始捣鼓你的数据库（我的数据库放了一下的数据名）
接下来对下面的数据进行操作（用上面已经连接上的数据库）
node底层写法：
var http = require('http');
// 连接数据库
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
user : 'root',
password : '123456',
database : 'node'
});
// 请求下数据库
connection.connect();
var http = require("http");
var url = require("url");
// 调用方法
function start() {
function onRequest(request, response) {}
http.createServer(onRequest).listen(8888);
端口号是8888去进行请求
}
start();
新增数据方法
// 新增数据
const hello = function (response, data) {
connection.query(`INSERT INTO log (content, summary, user, day) VALUES ("${data.content}", "${data.summary}", "${data.user}","${data.day}");`, function (error, results, fields) {
if (error) throw error;
// 请求成功，返回格式
response.writeHead(200, {"Content-Type": "application/json"});
// 返回给页面的数据
response.write(JSON.stringify(results.insertId));
// 请求结束
response.end();
});
}
获取列表
// 获取列表
const hello2 = function (response, data) {
connection.query(`select * from log`, function (error, results, fields) {
if (error) throw error;
response.writeHead(200, {"Content-Type": "application/json"});
response.write(JSON.stringify(results));
response.end();
});
}
删除事件
// 删除id=4
const hello4 = function (response,data){
console.log(data)
connection.query(`DELETE FROM log WHERE id=${data.id}`,function (error,results,fields) {
if (error) throw error; response.write("ok");
response.end();
})
}
分页写法
// 分页写法
const hello3 = function (response, page, size) {
console.log('page, size', page, size)
connection.query(`select * from log limit ${size} offset ${(page-1)*size} `, function (error, results, fields) {
if (error) throw error;
response.writeHead(200, {"Content-Type": "application/json"});
response.write(JSON.stringify(results));
response.end();
});
}
调用的话直接调用方法就可以（这里还需要注意是get请求还是post请求）
// 调用方法
function start() {
function onRequest(request, response) {
// /hello
var pathname = url.parse(request.url).pathname.split('/');
// /hello3/1/10
// 接收数据
if (request.method === 'POST') {
request.on('data', function(data) {
// 把数据转换成json格式
let data1 = JSON.parse(data.toString())
console.log('data: ', data1.toString(), data1)
// 接收到的接口调用什么方法
switch(pathname[1]) {
case 'hello': { hello(response, data1) } break;
case 'hello2': { hello2(response, data1) } break;
case 'hello3': {
// 用拼接的方式（get）获取数据方法
// let page = pathname[2]
// let size = pathname[3]
// console.log(pathname)
// 用接收体来调用数据（post）
hello3(response, data1.page, data1.size)
} break;
case 'hello4': { hello4(response, data1) } break;
// 调用weitch方法
default: response.end();
}
})
}
完整的使用代码
var http = require('http');
// 连接数据库
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
user : 'root',
password : '123456',
database : 'node'
});
// 请求下数据库
connection.connect();
var http = require("http");
var url = require("url");
// 新增数据
const hello = function (response, data) {
connection.query(`INSERT INTO log (content, summary, user, day) VALUES ("${data.content}", "${data.summary}", "${data.user}","${data.day}");`, function (error, results, fields) {
if (error) throw error;
// 请求成功，返回格式
response.writeHead(200, {"Content-Type": "application/json"});
// 返回给页面的数据
response.write(JSON.stringify(results.insertId));
// 请求结束
response.end();
});
}
// 获取列表
const hello2 = function (response, data) {
connection.query(`select * from log`, function (error, results, fields) {
if (error) throw error;
response.writeHead(200, {"Content-Type": "application/json"});
response.write(JSON.stringify(results));
response.end();
});
}
// 删除id=4
const hello4 = function (response,data){
console.log(data)
connection.query(`DELETE FROM log WHERE id=${data.id}`,function (error,results,fields) {
if (error) throw error;
response.write("ok");
response.end();
})
}
// 分页写法
const hello3 = function (response, page, size) {
console.log('page, size', page, size)
connection.query(`select * from log limit ${size} offset ${(page-1)*size} `, function (error, results, fields) {
if (error) throw error;
response.writeHead(200, {"Content-Type": "application/json"});
response.write(JSON.stringify(results));
response.end();
});
}
// 调用方法
function start() {
function onRequest(request, response) {
// /hello
var pathname = url.parse(request.url).pathname.split('/');
// /hello3/1/10
// 接收数据
if (request.method === 'POST') {
request.on('data', function(data) {
// 把数据转换成json格式
let data1 = JSON.parse(data.toString())
console.log('data: ', data1.toString(), data1)
// 接收到的接口调用什么方法
switch(pathname[1]) {
case 'hello': { hello(response, data1) } break;
case 'hello2': { hello2(response, data1) } break;
case 'hello3': {
// 用拼接的方式（get）获取数据方法
// let page = pathname[2]
// let size = pathname[3]
// console.log(pathname)
// 用接收体来调用数据（post）
hello3(response, data1.page, data1.size)
} break;
case 'hello4': { hello4(response, data1) } break;
// 调用weitch方法
default: response.end();
}
})
}
// Get
if (request.method === 'GET') {
response.end('aaaaa');
}
}
http.createServer(onRequest).listen(8888);
}
start();
开始化简模式。学习使用koa框架
安装koa
npm intall koa2
npm intall koa-router
在页面引入
const Koa = require('koa')
const bodyParser = require('koa-bodyparser')
const Router = require('koa-router')
来个简单例子
const Koa = require('koa');
//引入koa
const app = new Koa();
//方法放到app下
app.use(async ctx => {
ctx.body = 'Hello World';
});
//执行方法
app.listen(3000);
//app创建端口号
koa主要的就是request的请求方法，response响应，因为太多就不在这讲了，想了解的 戳这里↓↓↓↓↓
app.use(async ctx => {
console.log(ctx.request.href)
//获取到地址，换个方法就可以获取前台传得数据
ctx.response.body = "aaaaa"
//返回值
});
来上面的去看文档慢慢敲就行了，Sequelize功能模块使用来讲一下
var Sequelize = require('sequelize');
var mysql = new Sequelize('node', 'root', '123456', {
host: 'localhost',
dialect: 'mysql',
pool: {
max: 5,
min: 0,
idle: 10000
},
})
看数据库的导入方式就不一样了，接下来我们使用的可能多数都是这样的，样式了。
//数据表里面的内容
var Log = mysql.define('log', {
id: {
primaryKey: true,
type: Sequelize.INTEGER,
},
content: Sequelize.STRING,
summary: Sequelize.STRING,
user: Sequelize.STRING,
day: Sequelize.STRING,
}, {
freezeTableName: true, // Model 对应的表名将与model名相同
timestamps: false
});
使用方法查询数据
Log.findAll({
where: {
$and: [
{ id: {gt: 32} },
//大于多少
{ id: {lt: 35} }
//小于等于多少
]
},
raw: true
}).then(res => {
console.log(res.length)
//一共多少条
for(var i=0 ;i<res.length;i++){
//遍历出来显示
Log.create(
{
content: res[i].content,
summary: res[i].summary,
user: res[i].user,
day: res[i].day
}
)
}
})
整体使用
const main = async function() {
//查询所有
let res = await Log.findAll({
raw: true
})
//写入
let newDatas = res.map(item => ({
a: item.content,
b: item.summary,
c: item.user,
d: item.day,
}))
//往新表里插入多条数据
await Aaa.bulkCreate(newDatas)
//删除数据
await Aaa.destroy({ where: {
id: 2
}})
//修改数据
await Aaa.update({
a: 'item.content',
b: 'item.summary',
c: 'item.user',
d: 'item.day',
}, {
where: {
id: 3
}
})
}
main()
接下来进行三军会师，用三种方法写成最简单的代码来调用数据
开始在app文件中
const Koa = require('koa')
const bodyParser = require('koa-bodyparser')
const router = require('./controllers')
//引入使用包
const app = new Koa()
app.use(bodyParser())
//调用koabadyparser方法
app.use(router.routes())
app.listen(3000)
//引入文件，创建端口
在controllers文件中写入方法并进行调用
const Router = require('koa-router')
const router = new Router()
const services = require('./services')
//查询所有数据
router.get('/', async (ctx, next) => {
let res = await services.hello1()
ctx.body = res
});
//返回值hello world
router.get('/hello', (ctx, next) => {
ctx.body = "hello world"
});
//新增数据
router.post('/hello2', async (ctx, next) => {
let obj = ctx.request.body
let res = await services.hello2(obj)
let eee = {
content : res.content,
summary : res.summary
}
ctx.body = {
statusCode: 200,
result:eee
}
})
//删除数据
router.post('/hello3', async (ctx, next) => {
let obj = ctx.request.body
let res = await services.hello3(obj)
ctx.body = {
statusCode: 200,
}
})
//查询数据
router.post('/hello4', async (ctx, next) => {
let obj = ctx.request.body
let res = await services.hello4(obj)
ctx.body = res
})
//更改数据
router.post('/hello5', async (ctx, next) => {
let obj = ctx.request.body
let res = await services.hello5(obj)
ctx.body = res
})
//调用
module.exports = router
在services.js文件中
const Log = require('./models')
const hello = async function (obj) {
//放个查询方法
let logs = await Log.Log.findAll({
where: {
$and: [
{id: { $gt: obj.id }},
{id: { $lte: obj.css }}
]
}
})
return logs
}
//查询所有数据大于0的
const hello1 = async function () {
let loge = await Log.Log.findAll({
where: {
id: { gt: 0},
}
})
return loge
}
//新增数据
const hello2 = async function (obj) {
let loge = await Log.rizhi.create({
content:obj.content,
summary:obj.summary,
user:obj.user,
day:"2015-10-7"
})
return loge
}
//删除数据
const hello3 = async function (obj) {
let loge = await Log.rizhi.destroy({
where:{
id : obj.id
}
})
return loge
}
查询数据
const hello4 = async function (obj) {
let ass = {
content : obj.content,
summary : obj.summary,
user : obj.user,
}
if(!obj.content){
delete ass.content
}
if(!obj.summary){
delete ass.summary
}
if(!obj.user){
delete ass.user
}
let loge = await Log.rizhi.findAll({
where:ass
})
return loge
}
//更改数据
const hello5 = async function (obj) {
let ass = {
content : obj.content,
summary : obj.summary,
user : obj.user,
}
let loge = await Log.rizhi.update(ass,{
where:{
id : obj.id
}
})
let cha = await Log.rizhi.findAll({
where: {
id: obj.id,
}
})
return cha
}
需要调用的方法
module.exports = {
hello,hello1,hello2,hello3,hello4,hello5
}
最后将表格的内容模块导入到models.js中
const mysql = require('./mysql')
//导入数据库
const Sequelize = require('sequelize')
//log表内数据格式
var Log = mysql.define('log', {
id: {
primaryKey: true,
type: Sequelize.INTEGER,
},
content: Sequelize.STRING,
summary: Sequelize.STRING,
user: Sequelize.STRING,
day: Sequelize.STRING,
}, {
freezeTableName: true, // Model 对应的表名将与model名相同
timestamps: false
});
//日志表内数据格式
var rizhi = mysql.define('rizhi', {
id: {
primaryKey: true,
type: Sequelize.INTEGER,
},
content: Sequelize.STRING,
summary: Sequelize.STRING,
user: Sequelize.STRING,
day: Sequelize.STRING,
}, {
freezeTableName: true, // Model 对应的表名将与model名相同
timestamps: false
});
调出两个表
module.exports = {Log,rizhi}
这就是一个完整的的node项目了，增删改查，以后就需要自己去扩展了
读写文件的话，就免不了书把txt，excel、sql、之间的数据转换，以后在讲。。。。。。