nodejs笔记之连接mysql数据库

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了nodejs笔记之连接mysql数据库，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2190字，纯文字阅读大概需要4分钟。

内容图文

1.安装mysql模块；

npm install mysql

2.引入mysql模块

创建一个server.js文件

const http = require("http");
const mystatic = require("./mystatic")
const mysql = require("mysql");

http.createServer((req,res)=>{
    console.log(req.url);
    mystatic(req,res)

  // 连接数据库
const connection = mysql.createConnection({
  host:"localhost",
  user:"root",
  password:"root",
  database:"yuedu_db",
  charset:"UTF8_GENERAL_CI"
})
connection.connect();


    if(req.url =="/api/getGoods"){
      connection.query("select * from t_types",function(error,results,fields){
        if(error) throw error;
        res.writeHead(200,{"Content-Type":"text/plain;charset=utf-8;"});
        res.end(JSON.stringify(results))
    })
       
    }else if(req.url == "/api/getUsers"){
      connection.query("select * from t_articles",function(error,results,fields){
        if(error) throw error;
        res.writeHead(200,{"Content-Type":"text/plain;charset=utf-8;"});
        console.log("the result is "+results)
        res.end(JSON.stringify(results))
    })
    }
}).listen(3000)

创建一个mystatic.js文件

var path =require("path");
var fs = require("fs");
var mime = require("Mime");

function mystatic(req,res){
    var path_last=path.extname(req.url);
    if(req.url=="/"){
        fs.readFile(__dirname+"/app"+"/index.html",function(err,data){
            res.writeHead(200,{
                "content-type":"text/html;charset=utf-8;"
            });
            res.end(data)
        })
    }

    if(path_last){
        res.writeHead(200,{"Content-type":mime.getType(path_last)+";charset=utf-8;"});

        var url = __dirname+(path_last==".icon"?"":"/app")+req.url;
        fs.readFile(url,function(err,data){
            res.end(data)
        })
    }
}

module.exports=mystatic;

然后运行server.js启动服务器；

node server.js

每次服务器中的代码修改都需要启动服务器，比较麻烦，但是可以使用nodemon每次帮助自动启动服务器；

具体的看https://www.cnblogs.com/chris-oil/p/6239097.html这篇文章；

向数据库中插入*.json的数据

var mysql      = require('mysql');
var data=require("./data.json");
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : 'root',
  database : 'xiaomi',
  port: '3307'
});

connection.connect();
 
for(var i=0;i<data.length;i++){
  for(var j=0;j<data[i].list.length;j++){
    var sql="insert into product (title,tit,img_url,type,price) values(?,?,?,?,?)";
    var obj=data[i].list[j];
    connection.query(sql,[data[i].title,obj.tit,obj.img_url,obj.type,obj.price])
  }
}
 
connection.end();

内容总结

以上是互联网集市为您收集整理的nodejs笔记之连接mysql数据库全部内容，希望文章能够帮你解决nodejs笔记之连接mysql数据库所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端