nodejs 数据库操作教案

nodejs socket.io教案

nodejs electron本地化程序

nodejs 构建webserver

nodejs html5断点续传

nodejs ajax长轮询方案

ajax长轮询方案

redis

node基础教程

Node.js mysql

mysql链接

新建html，命名为   ajax_sql.html

<!Doctype html>
<html lang="en">

<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0">
    <meta http-equiv="X-UA-Compatible" content="ie=edge">
    <title>论坛</title>
    <style>
        .new {
            width: 480px;
            float: left;
        }

.new p {
            float: left;
            width: 210px;
            height: 20px;
            margin-right: 40px;
        }

.new a {
            width: 210px;
            height: 20px;
            float: left;
            overflow: hidden;
            white-space: nowrap;
            text-overflow: ellipsis;
            margin-right: 40px;
        }

.release {
            float: left;
            padding: 80px 0 0 40px;
        }

.release .title {
            width: 380px;
            height: 33px;
            border-radius: 4px;
            border: 1px solid #cfcfcf;
            box-sizing: border-box;
            padding: 0 10px;
            margin-left: 10px;
        }

.release .content {
            width: 380px;
            height: 190px;
            border: 1px solid #cdcdcd;
            border-radius: 4px;
            background: #fff;
            display: inline-block;
            margin-left: 10px;
            box-sizing: border-box;
            text-indent: 7px;
            padding: 3px 0;
        }

.release #submit {
            display: inline-block;
            padding: 7px 15px;
            border-radius: 4px;
            border: 1px solid #fff;
            background: #4CAF50;
            color: #fff;
            cursor: pointer;
            font-size: 16px;
            margin: 10px 10px;
        }
    </style>
</head>

ajax("/select", [], function (r) {
            r = JSON.parse(r);//解析为JSON字符串
            if (r.state == 1) {
                var html = "";
                for (let i = 0; i < r.msg.length; i++) {
                    html += '<div style="width: 740px;display: inline-block;">\
                        <p><a href="/new_world/'+ r.msg[i].id + '" onclick="look(' + r.msg[i].id + ',this);">' + r.msg[i].title + '</a></p>\
                        <p><span>'+ r.msg[i].date + '</span></p>\
                    </div>';
                }
                document.querySelector(".new").innerHTML += html;

} else if (r.state == 2) {
                alert(r.msg);
                location.reload();
            }
        });

look = function (id, This) {
            window.event ? window.event.returnValue = false : e.preventDefault();//阻止浏览器默认事件
            ajax(This.href, [], function (r) {
                r = JSON.parse(r);//解析为JSON字符串
                if (r.state == 1) {
                    var div = document.createElement("div");
                    div.id = "look"
                    div.style.cssText = "position: fixed; top: 0; left: 0; width: 100%; height: 100%;background: rgba(0, 0, 0, 0.8);"
                    div.innerHTML = '<div style="width: 500px; height: 500px;border-radius: 11px; margin: auto;    position: relative; top: calc( 50% - 500px/2);background: #fff; box-sizing: border-box; padding: 9px 11px; overflow: auto;    word-break: break-all;">' + r.msg + '</div>';
                    document.body.appendChild(div);
                    document.querySelector("#look").onclick = function () {
                        this.parentNode.removeChild(this);
                    }
                    document.querySelector("#look div").onclick = function () {
                        window.event ? window.event.cancelBubble = true : e.stopPropagation();
                    }
                    //console.log(r.msg);
                } else if (r.state == 2) {
                    alert(r.msg);
                }
            });

}
    </script>
</body>

</html>

新建js文件 命名为 db.js   此文件为mysql链接配置

新建js文件 命名为 ajax_sql.js   这个文件是主程序

var http = require('http'); //加载一个 http 外部模块 
var querystring = require('querystring');//导入querystring模块（解析post请求数据）
var db = require('./db.js'); //包含另外一个文件
var fs = require("fs");

http.createServer(function (req, res) {//创建一个HTTP服务器

var data = '';//创建空字符叠加数据片段
    req.on('data', function (chunk) {// chunk 默认是一个二进制数据，和 data 拼接会自动 toString
        data += chunk;
    });

res.writeHead(200, {
        'Content-Type': 'text/html;charset=utf8',
        'Access-Control-Allow-Origin': '*'
    });  //向请求的客户端发送响应头。

//当接收表单提交的数据完毕之后，就可以进一步处理了
    //注册end事件，所有数据接收完成会执行一次该方法
    req.on('end', function () {

//data = decodeURI(data);//对url进行解码（url会对中文进行编码）

if (data!="") {
            data = data.split(",");
        }
      
        if (req.method == 'GET' && req.url=='/'){//判断请求的url

var pathname = __dirname + "/ajax_sql.html";    //url.parse("/ajax.html").pathname;
            // __dirname 存储文件所在的文件目录
            fs.readFile(pathname, function (err, data) {//同步读取
                res.end(data);
            });
            return;
        }
    
    if (req.method == 'POST' && req.url.search(/select/) == 1) {//判断请求的url
        db.select("Select * from information", function (r) {

var str = { state: 1, msg: r };
            str = JSON.stringify(str);
            res.end(str);
        })
        return;
    }
         
    if (req.method == 'POST' && req.url.search(/new_world/)==1) {//判断请求的url

let url = req.url.split("/");
        url = url.slice(1);
        //url = JSON.stringify(url);

db.select("Select content from information Where id=" + url[1], function (r) {
            var str = { state: 1, msg: r[0].content };
            str = JSON.stringify(str);
            res.end(str);
        })

return;
    }

if (req.method == 'POST' && req.url == '/install') {
        time = new Date().toLocaleString();
        let sql = "INSERT INTO information(title,content,date) VALUES('" + data[0] + "','" + data[1] + "','" + time + "')";
        db.select(sql, function (r) {
            if(r.affectedRows==1){
                let str = JSON.stringify({ 'state': 1, 'msg': '添加成功' });
                res.end(str);
            }else if (r.affectedRows == 2) {
                let str = JSON.stringify({ 'state': 2, 'msg': '添加失败' });
                res.end(str);
            }
        })
        return;
    }

});

}).listen(3000);//监听 3000 端口
console.log('Server running at http://127.0.0.1:3000/');//控制台打印

接下来需要安装mysql模块  node连接数据库需要安装mysql模块
1、 win+r 打开运行窗口   win：即键盘的“开始”按键
2、输入 cmd 确定 会弹出cmd命令框
3、找到上面文件所在目录 => 右键文件 => 属性 => 找到位置 => 直接复制
4、到cmd命令框 => 输入命令 cd 复制的路径(鼠标右键-粘贴) => 回车   注：如果文件路径不是C盘需要切换 切换至D盘命令为  D:
5、安装mysql模块 输入命令 npm install mysql  等待安装
6、文件目录会出现一个 nude_modules 文件夹

新建sql文件 命名为 forum.sql 这里用Navicat for MySQL进行操作数据库  在本机新建名为forum的数据库 双击数据库将数据库连接上 图标变成绿色  在数据库名称上 右键 选择运行SQL文件 选择forum.sql 然后点击开始 完成后点击关闭

/*
Navicat MySQL Data Transfer

Source Server         : 127.0.0.1
Source Server Version : 50720
Source Host           : localhost:3305
Source Database       : forum

Target Server Type    : MYSQL
Target Server Version : 50720
File Encoding         : 65001

Date: 2018-04-22 20:40:03
*/

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for information
-- ----------------------------
DROP TABLE IF EXISTS `information`;
CREATE TABLE `information` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `title` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL,
  `content` text COLLATE utf8_unicode_ci,
  `date` text COLLATE utf8_unicode_ci COMMENT '资讯表',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=44 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;

-- ----------------------------
-- Records of information
-- ----------------------------
INSERT INTO `information` VALUES ('1', '中方回应美国“封杀”中兴：随时采取必要措施维护中企权益', '\r\n<img src=\"//inews.gtimg.com/newsapp_match/0/3290407571/0\" class=\"content-picture\">\r\n\r\n　　中兴通讯官方声明\r\n\r\n　　海外网4月17日电17日上午，针对美国商务部宣布将禁止美国公司向中兴通讯销售零部件、商品、软件和技术 7 年，中国商务部新闻发言人表示，中方注意到美国商务部宣布对中兴公司采取出口管制的措施。中方一贯要求中国企业在海外经营过程中，遵守东道国的法律政策，合法合规开展经营。中兴公司与数百家美国企业开展了广泛的贸易投资合作，为美国贡献了数以万计的就业岗位。希望美方依法依规，妥善处理，并为企业创造公正、公平、稳定的法律和政策环境。商务部将密切关注事态进展，随时准备采取必要措施，维护中国企业的合法权益。\r\n\r\n　　17日，中兴通讯也在官网发表声明称，已获悉美国商务部对公司激活拒绝令。公司正在全面评估此事件对公司可能产生的影响，与各方面积极沟通及应对。\r\n\r\n　　4 月 16 日，美国商务部宣布将禁止美国公司向中兴通讯销售零部件、商品、软件和技术 7 年，直到 2025年3月13日。理由是中兴违反了美国限制向伊朗出售美国技术的制裁条款。\r\n\r\n　　针对中兴通讯发出出口权限禁止令意味着，该公司将被禁止参与接受美国政府出口管理条例管辖的“任何形式的任何交易”，美国出口管理条例管制范围涵盖敏感技术的海外出口。\r\n\r\n　　中金报告称，美国商务部对中兴通讯施加出口权限禁止令，若不能在1-2月内达成和解，会影响通信设备和手机等业务的正常生产与销售，同时对当前全球和中国的运营商网络建设带来一定影响，并有可能影响未来5G网络的推进。目前中兴占全球电信设备市场约10%的市场份额，占中国电信设备市场约30%市场份额。中兴有1-2月的零部件的存货，若不能尽快达成和解，会影响相关业务。\r\n\r\n据了解，中兴并不是第一次受罚，上一轮美国对中兴的制裁在 2016 年 3 月生效，规定任何企业向中兴出售美国企业的零部件或仪器前，必须向商务部申请出口许可。之后，中兴积极与美方协商奏效，美国政府宣布“暂时”中止了对中兴的制裁，并给予中兴 3 个月的临时出口许可。去年3月7日，中兴最终宣布与美达成和解，其中最主要的交换条件则是支付高达8.9亿美元的刑事和民事罚金。（综编/海外网 耿佩）', '2018-4-18 15:30:11');
INSERT INTO `information` VALUES ('2', '中方回应美国“封杀”中兴：随时采取必要措施维护中企权益', '\r\n<img src=\"//inews.gtimg.com/newsapp_match/0/3290407571/0\" class=\"content-picture\">\r\n\r\n　　中兴通讯官方声明\r\n\r\n　　海外网4月17日电17日上午，针对美国商务部宣布将禁止美国公司向中兴通讯销售零部件、商品、软件和技术 7 年，中国商务部新闻发言人表示，中方注意到美国商务部宣布对中兴公司采取出口管制的措施。中方一贯要求中国企业在海外经营过程中，遵守东道国的法律政策，合法合规开展经营。中兴公司与数百家美国企业开展了广泛的贸易投资合作，为美国贡献了数以万计的就业岗位。希望美方依法依规，妥善处理，并为企业创造公正、公平、稳定的法律和政策环境。商务部将密切关注事态进展，随时准备采取必要措施，维护中国企业的合法权益。\r\n\r\n　　17日，中兴通讯也在官网发表声明称，已获悉美国商务部对公司激活拒绝令。公司正在全面评估此事件对公司可能产生的影响，与各方面积极沟通及应对。\r\n\r\n　　4 月 16 日，美国商务部宣布将禁止美国公司向中兴通讯销售零部件、商品、软件和技术 7 年，直到 2025年3月13日。理由是中兴违反了美国限制向伊朗出售美国技术的制裁条款。\r\n\r\n　　针对中兴通讯发出出口权限禁止令意味着，该公司将被禁止参与接受美国政府出口管理条例管辖的“任何形式的任何交易”，美国出口管理条例管制范围涵盖敏感技术的海外出口。\r\n\r\n　　中金报告称，美国商务部对中兴通讯施加出口权限禁止令，若不能在1-2月内达成和解，会影响通信设备和手机等业务的正常生产与销售，同时对当前全球和中国的运营商网络建设带来一定影响，并有可能影响未来5G网络的推进。目前中兴占全球电信设备市场约10%的市场份额，占中国电信设备市场约30%市场份额。中兴有1-2月的零部件的存货，若不能尽快达成和解，会影响相关业务。\r\n\r\n据了解，中兴并不是第一次受罚，上一轮美国对中兴的制裁在 2016 年 3 月生效，规定任何企业向中兴出售美国企业的零部件或仪器前，必须向商务部申请出口许可。之后，中兴积极与美方协商奏效，美国政府宣布“暂时”中止了对中兴的制裁，并给予中兴 3 个月的临时出口许可。去年3月7日，中兴最终宣布与美达成和解，其中最主要的交换条件则是支付高达8.9亿美元的刑事和民事罚金。（综编/海外网 耿佩）', '2018-4-18 15:32:42');
INSERT INTO `information` VALUES ('40', '哈哈哈', '哈哈哈', '2018-4-20 15:25:44');

-- ----------------------------
-- Procedure structure for qwe
-- ----------------------------
DROP PROCEDURE IF EXISTS `qwe`;
DELIMITER ;;
CREATE DEFINER=`root`@`%` PROCEDURE `qwe`()
BEGIN
	#Routine body goes here...
	Select * from user;
END
;;
DELIMITER ;

接下来到主程序ajax_sql.js，F5 启动程序，浏览器地址输入 http://127.0.0.1:3000，运行结果如下图一致，程序运行成功。
1、新闻资讯是从数据库获取，用ajax请求获取数据。
2、点击新闻资讯标题，ajax请求获取到此条资讯的内容。
3、点击提交，ajax请求发送数据，插入数据库，添加新闻资讯。

工作人员

 
        作者：赖文剑
        信息录入:赖文剑
        文案编辑:XXX
        视频录制:XXX
        视频编辑:XXX
        图片编辑:XXX
        关键字修改:陈鑫

有思俱乐部学习园地