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

本文涉及的产品
云数据库 RDS MySQL Serverless,0.5-2RCU 50GB
简介: Node.js【文件系统模块、路径模块 、连接 MySQL、nodemon、操作 MySQL】(三)-全面详解(学习总结---从入门到深化)



Node.js 文件系统模块(二)

打开文件

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

Flag  描述
以读取模式打开文件。如果文件不存在抛出异常。
r+ 以读写模式打开文件。如果文件不存在抛出异常。
rs  以同步的方式读取文件。
rs+  以同步的方式读取和写入文件。
以写入模式打开文件,如果文件不存在则创建。
wx 类似 'w',但是如果文件路径存在,则文件写入失败。
w+  以读写模式打开文件,如果文件不存在则创建。
wx+  类似 'w+', 但是如果文件路径存在,则文件读写失败。
以追加模式打开文件,如果文件不存在则创建。
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)
     })
   }
 }
}
相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
13天前
|
域名解析 网络协议 JavaScript
【Node系列】node工具模块
Node.js有多个内置的工具模块,这些模块提供了用于执行各种任务的功能。
22 2
|
28天前
11_nest.js模块
11_nest.js模块
24 0
|
1月前
|
JavaScript 前端开发
Node.js之path路径模块
Node.js之path路径模块
|
1月前
|
JavaScript
Node.js之http模块
Node.js之http模块
|
17天前
|
关系型数据库 MySQL 数据库
mysql卸载、下载、安装(window版本)
mysql卸载、下载、安装(window版本)
|
1月前
|
关系型数据库 MySQL 数据库连接
关于MySQL-ODBC的zip包安装方法
关于MySQL-ODBC的zip包安装方法
|
1月前
|
关系型数据库 MySQL 数据库
rds安装数据库客户端工具
安装阿里云RDS的数据库客户端涉及在本地安装对应类型(如MySQL、PostgreSQL)的客户端工具。对于MySQL,可选择MySQL Command-Line Client或图形化工具如Navicat,安装后输入RDS实例的连接参数进行连接。对于PostgreSQL,可以使用`psql`命令行工具或图形化客户端如PgAdmin。首先从阿里云控制台获取连接信息,然后按照官方文档安装客户端,最后配置客户端连接以确保遵循安全指引。
86 1
|
6天前
|
关系型数据库 MySQL 数据库
《MySQL 简易速速上手小册》第1章:MySQL 基础和安装(2024 最新版)
《MySQL 简易速速上手小册》第1章:MySQL 基础和安装(2024 最新版)
28 4
|
29天前
|
Ubuntu 关系型数据库 MySQL
Ubuntu 中apt 安装MySQL数据库
Ubuntu 中apt 安装MySQL数据库
69 0
|
2天前
|
关系型数据库 MySQL Windows
windows安装MySQL5.7教程
windows安装MySQL5.7教程
8 0