正文

【nodejs】修改了下对股票表进行crud操作的代码

IP云
IP云V管理员/3 阅读
11/30
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

表是这样的：

id是自增长字段，code和name都是255位的varchar。

下面是主角app.js的代码： 

'use strict';

var express=require('express');
var http=require('http');
var fs=require('fs');

var app=express();

var mysql=require('mysql');
var pool=mysql.createPool({
    host:'127.0.0.1',
    port:'3306',
    database:'test',
    user:'root',
    password:'12345678',
});

app.get('/index.html',function(req,rsp){
    rsp.sendFile(__dirname+'/index.html');
});

app.get('/add.html',function(req,rsp){
    rsp.sendFile(__dirname+'/add.html');
});

app.get('/modify.html/:id',function(req,rsp){
    rsp.sendFile(__dirname+'/modify.html');
});

// 列出所有股票
app.put('/list.html',function(req,res){
    req.on('data',function(data){
        //var obj=JSON.parse(data.toString());// 无须取得Ajax提交的参数
        console.log("\n list all stocks");

        pool.getConnection(function(err,connection){
            if(err){
                res.send('Can not connect to MySql DB');
                console.log(err);
            }else{
                connection.query("select * from stock ",function(err,result){
                    if(err){
                        console.log('List failed');
                        console.log(err);
                    }else{
                        console.log("List succeed");
                        console.log("result.length="+result.length);

                        var arr=[];
                        for (var i=0; i<result.length; i++) {
                            var tmp = result[i];

                            var stock=new Object;
                            stock.id=tmp['Id'];
                            stock.name=tmp['name'];
                            stock.code=tmp['code'];

                            arr.push(stock);
                        } 

                        res.send(JSON.stringify(arr));
                    }

                    connection.release();
                })
            }
        });
    });
});

// 添加一个股票
app.put('/add.html',function(req,res){
    req.on('data',function(data){
        var obj=JSON.parse(data.toString());// 取得Ajax提交的参数
        console.log("\n add stock name="+obj.name+" code="+obj.code);

        pool.getConnection(function(err,connection){
            if(err){
                res.send('Can not connect to MySql DB');
                console.log(err);
            }else{
                var str;
                connection.query('insert into stock set ?',{name:obj.name,code:obj.code},function(err,result){
                    if(err){
                        str='Insert failed';
                        console.log(err);
                    }else{
                        str="Insert succeed";
                        res.send(str);
                    }
                    console.log(str);

                    connection.release();
                })
            }
        });
    });
});

// 按ID删除一个股票
app.put('/del.html',function(req,res){
    req.on('data',function(data){
        var obj=JSON.parse(data.toString());// 取得Ajax提交的参数
        console.log("\n delete stock id="+obj.id);

        pool.getConnection(function(err,connection){
            if(err){
                res.send('Can not connect to MySql DB');
                console.log(err);
            }else{
                var str;
                connection.query('delete from stock where ? ',{id:obj.id},function(err,result){
                    if(err){
                        str='delete failed';
                        console.log(err);
                    }else{
                        str="delete succeed";
                        var info={'status':'ok','id':obj.id}
                        res.send(JSON.stringify(info));
                    }

                    console.log(str);
                    connection.release();
                })
            }
        });
    });
});

// 按ID取出一个股票
app.put('/fetchone.html',function(req,res){
    req.on('data',function(data){
        var obj=JSON.parse(data.toString());// 取得Ajax提交的参数
        console.log("\n fetchone id="+obj.id);

        pool.getConnection(function(err,connection){
            if(err){
                res.send('Can not connect to MySql DB');
                console.log(err);
            }else{

                var str;
                connection.query("select * from stock where ?",{id:obj.id},function(err,result){
                    if(err){
                        str='fetchone failed';
                        console.log(err);
                    }else{
                        str="fetchone succeed";

                        console.log("result.length="+result.length);

                        var arr=[];
                        for (var i=0; i<result.length; i++) {
                            var tmp = result[i];

                            var stock=new Object;
                            stock.id=tmp['Id'];
                            stock.name=tmp['name'];
                            stock.code=tmp['code'];

                            arr.push(stock);
                        } 

                        res.send(JSON.stringify(arr));
                    }
                    console.log(str);                    

                    connection.release();
                })
            }
        });
    });
});

// 更改一个股票
app.put('/modify.html',function(req,res){
    req.on('data',function(data){
        var obj=JSON.parse(data.toString());// 取得Ajax提交的参数
        console.log("\n modify stock id="+obj.id+" new code="+obj.code+" new name="+obj.name);

        pool.getConnection(function(err,connection){
            if(err){
                res.send('Can not connect to MySql DB');
                console.log(err);
            }else{
                var str;
                connection.query('update stock set code=?,name=? where id=? ',[obj.code,obj.name,obj.id],function(err,result){
                    if(err){
                        str='modify failed';
                        console.log(err);
                    }else{
                        str="modify succeed";

                        var info={'status':'ok','id':obj.id}
                        res.send(JSON.stringify(info));
                    }
                    console.log(str);
                    connection.release();
                })
            }
        });
    });
});

app.listen(8080,"127.0.0.1");

index页面进入时是这样的：

index.html的代码如下： 

<!DOCTYPE html>
<html lang="utf-8">
<meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
 <head>
  <title>get data from db</title>
 </head>

 <body onload="getAllStocks()">
  <table border="1">
    <caption>全体股票列表</caption>
    <tr>
        <th>id</th><th>code</th><th>name</th><th>删除</th><th>修改</th>
    </tr>
    <tbody id="mytable">
    </tbody>
  </table>
  <br>

  <a href="javascript:gotoAddPage();">添加</a>
 </body>
</html>
<script type="text/javascript">
<!--
function getAllStocks(){
    var obj={
        name:"none",
    };

    var xhr=new XMLHttpRequest();
    xhr.open('put','list.html',true);

    xhr.onload=function(e){
        if(this.status==200){
            var arr=JSON.parse(this.response);
            updateTable(arr);
        }
    };

    xhr.send(JSON.stringify(obj));
}

function updateTable(arr){
    var table=document.getElementById("mytable");

    for(var i=table.childNodes.length-1;i>=0;i--){
        table.removeChild(table.childNodes[i]);
    }

    for(var i=0;i<arr.length;i++){
        var emp=arr[i];

        var tr=document.createElement("tr");
        tr.setAttribute('id',emp.id);

        var td1=document.createElement("td");
        td1.appendChild(document.createTextNode(emp.id));
        tr.appendChild(td1);

        var td2=document.createElement("td");
        td2.appendChild(document.createTextNode(emp.code));
        tr.appendChild(td2);

        var td3=document.createElement("td");
        td3.appendChild(document.createTextNode(emp.name));
        tr.appendChild(td3);

        var td4=document.createElement("td");
        var a1=document.createElement("a");
        a1.appendChild(document.createTextNode(emp.id));
        a1.setAttribute('href','javascript:deleteStock('+emp.id+')');
        td4.appendChild(a1);
        tr.appendChild(td4);

        var td5=document.createElement("td");
        var a2=document.createElement("a");
        a2.appendChild(document.createTextNode(emp.id));
        a2.setAttribute('href','javascript:goModify('+emp.id+')');
        td5.appendChild(a2);
        tr.appendChild(td5);

        table.appendChild(tr);
    }
}

function gotoAddPage(){
    window.location="/add.html"
}

function deleteStock(id){
    //alert(id);

    var obj={
        id:id,
    };

    var xhr=new XMLHttpRequest();
    xhr.open('put','del.html',true);

    xhr.onload=function(e){
        if(this.status==200){
            var info=JSON.parse(this.response);

            if(info.status=='ok'){
                alert('删除成功');
                tr=document.getElementById(info.id);
                tr.parentNode.removeChild(tr);
            }
        }
    };

    xhr.send(JSON.stringify(obj));
}

function goModify(id){
    window.location="/modify.html/"+id;
}

//-->
</script>

修改页面modify.html是这样的：

modify.html的代码是这样的： 

<!DOCTYPE html>
<html lang="utf-8">
<meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
 <head>
  <title>modify data from db</title>
 </head>

 <body onload="fetchStock();">
    <h3>修改股票</h3>
  <form id="form1">
    股票Id：<input type="text" id="sid" value="" readonly><br/>
    股票代号：<input type="text" id="scode" value=""><br/>
    股票名称：<input type="text" id="sname" value=""><br/>
    <input type="button" value="提交" onclick="modifyStock();"/>
  </form>
 </body>
</html>
<script type="text/javascript">
<!--
function fetchStock(){
    var url=window.location.href.toString();
    var pos=url.lastIndexOf("/");// 找最后一个斜杠位置
    var id=url.slice(pos+1);

    var obj={
        id:id
    };

    var xhr=new XMLHttpRequest();
    xhr.open('put','http://localhost:8080/fetchone.html',true);// 注意地址的写法

    xhr.onload=function(e){
        if(this.status==200){
            var arr=JSON.parse(this.response);
            var stock=arr[0];

            document.getElementById('sid').value=stock.id;
            document.getElementById('scode').value=stock.code;
            document.getElementById('sname').value=stock.name;
        }
    };

    xhr.send(JSON.stringify(obj));
}

function modifyStock(){

    var obj={
        id:document.getElementById("sid").value,
        name:document.getElementById("sname").value,
        code:document.getElementById("scode").value
    };

    var xhr=new XMLHttpRequest();
    xhr.open('put','http://localhost:8080/modify.html',true);

    xhr.onload=function(e){
        if(this.status==200){
            var info=JSON.parse(this.response);

            if(info.status=='ok'){
                alert('修改成功');
                window.location="/index.html";
            }

        }
    };

    xhr.send(JSON.stringify(obj));
}

//-->
</script>

添加页面add.html是这样的：

add.html的代码是这样的： 

<!DOCTYPE html>
<html lang="utf-8">
<meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
 <head>
  <title>add data from db</title>
 </head>

 <body >
    <h3>添加股票</h3>
  <form id="form1">
    股票代号：<input type="text" id="scode" value=""><br/>
    股票名称：<input type="text" id="sname" value=""><br/>
    <input type="button" value="提交" onclick="addStock();"/>
  </form>
 </body>
</html>
<script type="text/javascript">
<!--
function addStock(){

    var obj={
        name:document.getElementById("sname").value,
        code:document.getElementById("scode").value
    };

    var xhr=new XMLHttpRequest();
    xhr.open('put','add.html',true);

    xhr.onload=function(e){
        if(this.status==200){
            //alert(this.response);
            var retval=this.response.toString();

            if(retval=='Insert succeed'){
                alert('插入成功，将转入列表页');
                window.location="/index.html";
            }

        }
    };

    xhr.send(JSON.stringify(obj));
}

function gotoAddPage(){
    window.location="/add.html"
}

//-->
</script>

好了，crud代码就到这里了。

2018年4月10日完成 2018年4月11日修改

相关阅读

目录[+]