nodejs 增删该查操作数据库(routes文件夹下的users.js)
2016-11-22 08:44
381 查看
//最上面的参数
var URL = require('url');
var express = require('express');
var router = express.Router();
var mysql = require('mysql');
/* GET users listing. */
router.get('/', function(req, res, next) {
res.render('index');
});
//数据库
var table = 'user';
var mydb = {
host : '127.0.0.1',
user : 'root',
password : 'root',
port : '3306',
database: 'test',
};
var con = mysql.createConnection(mydb);
con.connect();
//添加
router.get('/addUser',function(req,res,next){
var params = URL.parse(req.url, true).query;
var sql = 'INSERT INTO '+table+' VALUES(null,?,?)';
var param = [params.name,params.pwd];
con.query(sql,param,function(err,result){
res.send(JSON.stringify(result));
});
});
//查询
router.get('/show',function(req,res,next){
var sql = 'SELECT * FROM '+table;
con.query(sql,function(err,result){
res.send(JSON.stringify(result));
})
})
//删除
router.get('/del', function(req, res, next) {
var params = URL.parse(req.url, true).query;
var id = params.id;
var sql = 'DELETE FROM '+table+' WHERE id=?';
con.query(sql,[id],function(err,result){
if(result)
{
res.render('form');
}else{
// res.json(result);
}
})
});
//修改接值
router.get('/save', function(req, res, next) {
var params = URL.parse(req.url, true).query;
var id = params.id;
var sql = 'SELECT * FROM '+table+' WHERE id=?';
//con.query(sql,[id],function(err,result){
con.query(sql,[id],function(err,result){
if(err)
{
res.json(err.message);
}
res.send(JSON.stringify(result));
})
})
//修改接值
router.get('/update', function(req, res, next) {
var params = URL.parse(req.url, true).query;
var id = params.id;
var name = params.name;
var pwd = params.pwd;
var sql = 'UPDATE '+table+' SET `name`=? , `pwd`=? WHERE id=?';
con.query(sql,[name,pwd,id],function(err,result){
if(err)
{
res.json(err.message);
}
var success=1;
res.json(success);
})
})
//登录提交
router.get('/loginDo', function(req, res, next) {
var params = URL.parse(req.url, true).query;
var name = params.name;
var pwd = params.pwd;
var sql = 'SELECT * FROM '+table+' WHERE name=? AND pwd=?';
//con.query(sql,[id],function(err,result){
con.query(sql,[name,pwd],function(err,result){
if(err)
{
res.json(err.message);
}
//res.send(JSON.stringify(result));
var success=1;
res.json(success);
})
})
var URL = require('url');
var express = require('express');
var router = express.Router();
var mysql = require('mysql');
/* GET users listing. */
router.get('/', function(req, res, next) {
res.render('index');
});
//数据库
var table = 'user';
var mydb = {
host : '127.0.0.1',
user : 'root',
password : 'root',
port : '3306',
database: 'test',
};
var con = mysql.createConnection(mydb);
con.connect();
//添加
router.get('/addUser',function(req,res,next){
var params = URL.parse(req.url, true).query;
var sql = 'INSERT INTO '+table+' VALUES(null,?,?)';
var param = [params.name,params.pwd];
con.query(sql,param,function(err,result){
res.send(JSON.stringify(result));
});
});
//查询
router.get('/show',function(req,res,next){
var sql = 'SELECT * FROM '+table;
con.query(sql,function(err,result){
res.send(JSON.stringify(result));
})
})
//删除
router.get('/del', function(req, res, next) {
var params = URL.parse(req.url, true).query;
var id = params.id;
var sql = 'DELETE FROM '+table+' WHERE id=?';
con.query(sql,[id],function(err,result){
if(result)
{
res.render('form');
}else{
// res.json(result);
}
})
});
//修改接值
router.get('/save', function(req, res, next) {
var params = URL.parse(req.url, true).query;
var id = params.id;
var sql = 'SELECT * FROM '+table+' WHERE id=?';
//con.query(sql,[id],function(err,result){
con.query(sql,[id],function(err,result){
if(err)
{
res.json(err.message);
}
res.send(JSON.stringify(result));
})
})
//修改接值
router.get('/update', function(req, res, next) {
var params = URL.parse(req.url, true).query;
var id = params.id;
var name = params.name;
var pwd = params.pwd;
var sql = 'UPDATE '+table+' SET `name`=? , `pwd`=? WHERE id=?';
con.query(sql,[name,pwd,id],function(err,result){
if(err)
{
res.json(err.message);
}
var success=1;
res.json(success);
})
})
//登录提交
router.get('/loginDo', function(req, res, next) {
var params = URL.parse(req.url, true).query;
var name = params.name;
var pwd = params.pwd;
var sql = 'SELECT * FROM '+table+' WHERE name=? AND pwd=?';
//con.query(sql,[id],function(err,result){
con.query(sql,[name,pwd],function(err,result){
if(err)
{
res.json(err.message);
}
//res.send(JSON.stringify(result));
var success=1;
res.json(success);
})
})
相关文章推荐
- nodejs 增删该查操作数据库(routes文件夹下的users.js)
- nodejs自学之旅(完结篇)—— 简单数据库操作增删改查、表关联and分页排序
- nodejs遍历文件夹下并操作HTML/CSS/JS/PNG/JPG的方法
- C# ADO.net连接数据库 进行增删改查操作
- js对json增删改查操作
- Js 操作文件及文件夹
- JAVA数据库基本操作,增删改查
- c# 数据库增删改查操作
- ASP.NET 使用类对数据库进行增删改查操作
- 对文件或文件夹进行 增删改查等操作的工具类
- js表格增删操作
- JabaBean对数据库的操作----增删改查
- js操作数据库
- 关于ADO.NET数据库操作中的增删改查讲解
- js获取数据库中多个id然后进行操作
- CodeIgniter 数据库操作 -- 增删改查
- 对数据库表进行简单的增删改查操作的通用类
- JDBC连接数据库,对数据库进行增删查改操作
- JavaScript操作数据库JS操作Access数据库
- django数据库基本操作增删改查