Node.js【文件系统模块、路径模块、连接 MySQL、nodemon、操作 MySQL】(三)-全面详解（学习总结---从入门到深化）-阿里云开发者社区

Node.js【文件系统模块、路径模块、连接 MySQL、nodemon、操作 MySQL】(三)-全面详解（学习总结---从入门到深化）

2024-02-02 61

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

RDS MySQL Serverless 基础系列，0.5-2RCU 50GB

云数据库 RDS MySQL，集群系列 2核4GB

RDS MySQL Serverless 高可用系列，价值2615元额度，1个月

简介： Node.js【文件系统模块、路径模块、连接 MySQL、nodemon、操作 MySQL】(三)-全面详解（学习总结---从入门到深化）

Node.js 文件系统模块（二）

打开文件

fs.open(path, flags[, mode], callback)

Flag	描述
r	以读取模式打开文件。如果文件不存在抛出异常。
r+	以读写模式打开文件。如果文件不存在抛出异常。
rs	以同步的方式读取文件。
rs+	以同步的方式读取和写入文件。
w	以写入模式打开文件，如果文件不存在则创建。
wx	类似 'w'，但是如果文件路径存在，则文件写入失败。
w+	以读写模式打开文件，如果文件不存在则创建。
wx+	类似 'w+'，但是如果文件路径存在，则文件读写失败。
a	以追加模式打开文件，如果文件不存在则创建。
ax	类似 'a'，但是如果文件路径存在，则文件追加失败。
a+	以读写追加模式打开文件，如果文件不存在则创建。
ax+	类似 'a+'，但是如果文件路径存在，则文件读取追加失败。

const fs=require('fs')
fs.open('input.txt', 'r+', function(err, fd)
{
 if (err) {
   return console.error(err);
 } 
  console.log(fd);
  fs.writeFile(fd, '小童程序员', (err) => {
    if(err){
     return  console.log(err)
   }
    console.log('写入完成')
 })
});

Node.js 文件系统模块（三）

查看文件

fs.stat(path, callback)

var fs = require("fs");
fs.stat('input.txt', function (err, stats)
{
 if (err) {
   return console.error(err);
 }
 console.log(stats);
 // 检测文件类型
 console.log("是否为文件 ? " + stats.isFile());
 console.log("是否为目录 ? " + stats.isDirectory());  
});

删除文件

fs.unlink(path, callback)

fs.unlink('input.txt', function(err) {
 if (err) {
   return console.error(err);
 }
 console.log("文件删除成功！");
});

Node.js 文件系统模块（四）

1、创建目录

fs.mkdir(path[, options], callback)

var fs = require("fs");
// tmp 目录必须存在
console.log("创建目录 tmp/test");
fs.mkdir("./tmp/test",function(err){
 if (err) {
   return console.error(err);
 }
 console.log("目录创建成功。");
});

fs.mkdir("./tmp/test",{ recursive: true
},function(err){
  if (err) {
    return console.error(err);
 }
  console.log("目录创建成功。");
});

2、读取目录

fs.readdir(path, callback)

var fs = require("fs");
console.log("查看 /tmp 目录");
fs.readdir("./tmp",function(err, files){
 if (err) {
   return console.error(err);
 }
 files.forEach( function (file){
   console.log( file );
 });
});

3、删除目录

fs.rmdir(path, callback)

var fs = require("fs");
// 执行前创建一个空的 /tmp/test 目录
console.log("准备删除目录 ./tmp/test");
fs.rmdir("./tmp/test",function(err){
 if (err) {
   return console.log(err);
 }
});

提示：

删除目录，如果目录下面有下一级则报错

Node.js 路径模块

path 是Node.js的路径模块，用来处理路径。

path.dirname()

返回路径的目录部分

require('path').dirname('./test/something') // ./test
require('path').dirname('./test/something/file.txt')
// ./test/something

path.extname()

返回路径的扩展名部分

require('path').extname('./test/something') // ''
require('path').extname('./test/something/input.txt') // '.txt'

path.isAbsolute()

如果是绝对路径，则返回 true。

require('path').isAbsolute('/test/something') // true
require('path').isAbsolute('./test/something') // false

path.join()

连接路径的两个或多个部分

const name = '程序员'
require('path').join('/', '小童', name) //'/小童/程序员'

path.parse()

解析对象的路径为组成其的片段：

root : 根路径。

dir : 从根路径开始的文件夹路径。

base : 文件名 + 扩展名

name : 文件名

ext : 文件扩展名

require('path').parse('/users/test.txt')
//{
// root: '/',
// dir: '/users',
// base: 'test.txt',
// ext: '.txt',
// name: 'test'
//}

path.relative()

接受 2 个路径作为参数。基于当前工作目录，返回从第一个路径到第二个路径的相对路径。

require('path').relative('/Users/joe','/Users/joe/test.txt') //'test.txt'
require('path').relative('/Users/joe','/Users/joe/something/test.txt') //'something/test.txt'

path.resolve()

获得相对路径的绝对路径计算

require('path').resolve('joe.txt')
require('path').resolve('/etc', 'joe.txt') //'/etc/joe.txt'

Node.js 连接 MySQL

1、安装MySQL数据库

安装 xampp

安装包下载地址： https://sourceforge.net/projects/xampp/files/

进行下载安装

启动

新建数据库，新建表

2、安装 mysql

yarn add mysql 或者 npm install mysql

3、node.js 连接 MySQL

var mysql    = require('mysql');
//创建跟数据库的连接
var connection = mysql.createConnection({
 host   : 'localhost',
 user   : 'root',
 password : '',
 database : 'test'
});
//启动连接
connection.connect();
//执行查询
connection.query('select * from test',
function (error, results) {
 if (error) throw error;
 console.log(results);
});

Node.js nodemon

安装 nodemon

yarn add nodemon 或者 npm install nodemon --save

使用nodemon运行脚本

nodemon 脚本文件

使用package.json脚本

"scripts": {
  "start":"nodemon index.js"
}

使用 npx

npx nodemon index.js

Node.js 操作 MySQL

1、查询

connection.query('select * from test where name=?','test1', function (error, results,fields) {
 if (error) throw error;
 console.log(results,'results');
});

2、插入

connection.query('insert into test(name) values (?)','test3', function (error,results, fields) {
  if (error) throw error;
  if(results.affectedRows){
    console.log('插入成功')
 }
});

3、更新

connection.query('update test set value=? where name=?', [10,'test4'], function (error, results, fields) {
  if (error) throw error;
  if (results.affectedRows) {
    console.log('更新成功')
 }
});

4、删除

connection.query('delete from test where name=?', ['test4'], function (error, results, fields) {
  if (error) throw error;
  if (results.affectedRows) {
    console.log('删除成功')
 }
});

Node.js 应用

index.html

<!DOCTYPE html>
<html lang="en">
<head>
  <meta charset="UTF-8">
  <meta http-equiv="X-UA-Compatible" content="IE=edge">
  <meta name="viewport" content="width=device-width, initial-scale=1.0">
  <title>Document</title>
  <style>
    .container {
      width: 600px;
      margin: 50px auto;
   }
    table {
      width: 100%;
      text-align: center;
   }
   table thead th {
      background-color: #aaa;
   }
    table tbody td {
      background-color: #eee;
      padding: 5px
   }
    form {
      margin-bottom: 50px;
      text-align: center;
   }
    input {
      margin-bottom: 15px;
   }
    button {
      margin-left: 10px
   }
  </style>
</head>
<body>
  <div class="container">
    <!-- 新增数据的表单 -->
    <form id="form1" action="http://localhost:3030/add"  method="post">
      名称：<input type="text"  name="name"><br />
     数量：<input type="text"  name="value"><br />
      <input type="submit" value="提交" />
    </form>
    <!-- 查询数据的输入框 -->
    <input type="text" placeholder="请输入搜索的名称" id="name">
    <button onclick="onGetList()">搜索</button>
    <!-- 展示数据的列表 -->
    <table>
      <thead>
        <th>名称</th>
        <th>数量</th>
        <th>操作</th>
      </thead>
      <tbody>
      </tbody>
    </table>
  </div>
  <script>
    // 获取数据
    var onGetList = function () {
      // 获取tbody
      var tbody = document.querySelector('tbody')
      // 获取搜索框里面的内容
     const name = document.querySelector('#name').value
      // 发送获取数据的请求
      fetch('/getlist?name=' + name).then(function (data) {
        data.json().then(function (result) {
          tbody.innerHTML = null
          // 遍历返回的数据，生成每一行数据
         result.records.forEach(function (item) {
            var tr = document.createElement('tr')
            tr.innerHTML = '<td>' + item.name + '</td>' + '<td>' + item.value + '</td>'
            var td = document.createElement('td')
            var button = document.createElement('button')
            button.innerHTML = '删除'
            // 点击删除
            button.onclick = function () {
              remove(item)
           }
            td.append(button)
            tr.appendChild(td)
            tbody.appendChild(tr)
         })
       })
     })
   }
    // 删除数据
    function remove(item) {
      // 发送请求，并传递要删除数据的id
      fetch('/remove', { method: 'POST', body: JSON.stringify({ id: item.id }), headers: { 'Content-Type': 'application/json' } }).then(function (data) {
        console.log(data)
        data.json().then(function (result) {
          console.log('成功')
          onGetList()
       })
     })
   }
    window.onload = function () {
      onGetList()
   }
  </script>
</body>
</html>

mysql.js

var mysql = require('mysql');
const sqlConfig = {
  host: 'localhost',
  user: 'root',
  password: '',
  database: 'test'
}
let connection = mysql.createConnection(sqlConfig)
const sqlFn = function (sql, arr, callback)
{
  connection.query(sql, arr, callback)
}
module.exports = sqlFn

server.js

const http=require('http')
const router=require('./router')
http.createServer(function(req,res){
  router(req,res)
}).listen('3030')

router.js

const sqlFn = require('./index')
const url = require('url')
const querystring = require('querystring')
const fs = require('fs')
module.exports = (req, res) => {
  const { pathname, query } = url.parse(req.url, true)
  console.log(req.method)
  if (req.method == 'POST') {
    let params = ''
    req.on('data', (chunk) => {
      params += chunk
   })
    req.on('end', () => {
      console.log(params)
      let postParams = querystring.parse(params)
      if (req.headers['content-type'] == 'application/json') {
        postParams = JSON.parse(params)
     }
      // 处理新增数据的请求
      if (pathname == '/add') {
        sqlFn('insert into test(id,name,value) values (null,?,?) ',[postParams.name, postParams.value], (results) => {
          if (results.affectedRows) {
           res.writeHead(200, { "Content-Type": 'application/json;charset=utf-8' })
           res.end(JSON.stringify({ code: 0, message: '操作成功' }))
         }
       })
     }
      //处理删除请求
      if (pathname == '/remove') {
        console.log(postParams)
        sqlFn('delete from test where id=? ', [postParams.id], (results) => {
          if (results.affectedRows) {
            console.log('删除成功')
            res.writeHead(200, { "Content-Type": 'application/json;charset=utf-8' })
            res.end(JSON.stringify({ code: 0, message: '操作成功' }))
         }
       })
     }
   })
 }
  if (req.method == 'GET') {
    // 处理获取数据请求
    if (pathname == '/getlist') {
      sqlFn(`select * from test where ${query.name ? 'name=?' : 'name is not null'}`, [query.name], (results) => {
        console.log(results)
        res.writeHead(200, { "Content-Type": 'application/json;charset=utf-8' })
        res.write(JSON.stringify({ code: 0, records: results }))
        res.end()
     })
   }
    //处理获取html页面请求
    if (pathname == '/index.html') {
      res.writeHead(200, { "Content-Type": 'text/html;charset=utf8' })
      fs.readFile('./index.html', (err, data) => {
        res.end(data)
     })
   }
 }
}

Node.js【文件系统模块、路径模块、连接 MySQL、nodemon、操作 MySQL】(三)-全面详解（学习总结---从入门到深化）

Node.js 文件系统模块（二）

Node.js 文件系统模块（三）

Node.js 文件系统模块（四）

Node.js 路径模块

Node.js 连接 MySQL

Node.js nodemon

Node.js 操作 MySQL

Node.js 应用

热门文章

最新文章

相关课程

相关电子书

相关实验场景

推荐镜像

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

Node.js【文件系统模块、路径模块 、连接 MySQL、nodemon、操作 MySQL】(三)-全面详解（学习总结---从入门到深化）

Node.js 文件系统模块（二）

Node.js 文件系统模块（三）

Node.js 文件系统模块（四）

Node.js 路径模块

Node.js 连接 MySQL

Node.js nodemon

Node.js 操作 MySQL

Node.js 应用

热门文章

最新文章

相关课程

相关电子书

相关实验场景

推荐镜像

Node.js【文件系统模块、路径模块、连接 MySQL、nodemon、操作 MySQL】(三)-全面详解（学习总结---从入门到深化）