成都创新互联网站制作重庆分公司

Node.js中操作MySQL数据库的方法

这篇文章给大家分享的是有关Node.js中操作MySQL数据库的方法的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。

成都创新互联公司服务项目包括沈北新网站建设、沈北新网站制作、沈北新网页制作以及沈北新网络营销策划等。多年来,我们专注于互联网行业,利用自身积累的技术优势、行业经验、深度合作伙伴关系等,向广大中小型企业、政府机构等提供互联网行业的解决方案,沈北新网站推广取得了明显的社会效益与经济效益。目前,我们服务的客户以成都为中心已经辐射到沈北新省份的部分城市,未来相信会继续扩大服务区域并继续获得客户的支持与信任!

使用mysql这个npm模块操作MySQL数据库的基础教程。 不涉及MySQL的安装和配置,如果电脑中还未安装MySQL, 推荐安装WAMP、XAMPP等集成环境。本文中还使用到了轻量级的Node.js框架Koa搭建web程序,为的是通过前端浏览器请求的方式来模拟项目场景,你无需掌握Koa框架的语法也是可以轻松阅读本文的。

初始化项目

创建项目目录,并使用npm init初始化项目后,执行下面操作:

安装依赖
npm install mysql koa koa-router
创建index.js
// index.js

const Koa = require('koa');
const Router = require('koa-router');
const mysql = require('mysql');

const app = new Koa();
const router = new Router();

const connection = mysql.createConnection({
  host: 'localhost', // 填写你的mysql host
  user: 'root', // 填写你的mysql用户名
  password: '123456' // 填写你的mysql密码
})

connection.connect(err => {
  if(err) throw err;
  console.log('mysql connncted success!');
})

router.get('/', ctx => {
  ctx.body = 'Visit index';
})
app.use(router.routes());

app.listen(3000);

在shell中执行node index.js,当看到shell中打印出mysql connected success!,表明MySQL数据库连接成功。

Node.js中操作MySQL数据库的方法

打开浏览器, 访问localhost:3000,当看到屏幕显示Visit index时,表名项目初始化成功。

Node.js中操作MySQL数据库的方法

数据库操作

创建数据库

当访问/createdb时,创建一个mysqlkoa的数据库,代码如下:

router.get('/createdb', ctx => {
  return new Promise(resolve => {
    const sql = `CREATE DATABASE mysqlkoa`;

    connection.query(sql, (err) => {
      if (err) throw err;
      ctx.body = {
        code: 200,
        msg: `create database mysqlkoa success!`
      }
      resolve();
    });
  })
})

重新执行node index.js,并使用浏览器访问localhost:3000/createdb

Node.js中操作MySQL数据库的方法

创建数据表

为了方便,我们直接在连接时使用刚才创建的数据库,需要在mysql.createConnection中添加database:mysqlkoa的配置项。

const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: '123456',
  database: 'mysqlkoa' // 添加该列
})

当访问/createtable时,我们创建一个数据表fe_frame,该表用来保存前端框架的数据:

router.get('/createtable', ctx => {
  return new Promise(resolve => {
    const sql = `CREATE TABLE fe_frame(
      id INT(11) AUTO_INCREMENT PRIMARY KEY,
      name VARCHAR(255),
      author VARCHAR(255)
    )`;
    connection.query(sql, (err ,results, filelds) => {
      if (err) throw err;
      ctx.body = {
        code: 200,
        msg: `create table of fe_frame success!`
      }
      resolve();
    })
  })
})

重新执行node index.js,并使用浏览器访问localhost:3000/createtable

Node.js中操作MySQL数据库的方法

插入数据
插入单条数据

当访问/insert时,用来插入单条数据:

router.get('/insert', ctx => {
  return new Promise(resolve => {
    const sql = `INSERT INTO fe_frame(name, author)
    VALUES('vue', 'Evan')`;
    connection.query(sql, (err) => {
      if (err) throw err;
      ctx.body = {
        cde: 200,
        msg: `insert data to fe_frame success!`
      }
      resolve();
    })
  })
})

重新执行node index.js,并使用浏览器访问localhost:3000/insert

Node.js中操作MySQL数据库的方法

插入多条数据

当访问/insertmulti时,用来插入多条数据:

router.get('/insertmulti', ctx => {
  return new Promise(resolve => {
    const sql = `INSERT INTO fe_frame(name, author)
    VALUES ?`;
    const values = [
      ['React', 'Facebook'],
      ['Angular', 'Google'],
      ['jQuery', 'John Resig']
    ];
    connection.query(sql, [values], (err, result) => {
      if (err) throw err;
      ctx.body = {
        code: 200,
        msg: `insert ${result.affectedRows} data to fe_frame success!`        
      }
      resolve();
    })
  })
})

重新执行node index.js,并使用浏览器访问localhost:3000/insertmulti

Node.js中操作MySQL数据库的方法

使用phpMyAdmin访问,可以看到此时mysqlkoa表如下

Node.js中操作MySQL数据库的方法

删除数据

当访问/delete时,删除相应行。我们使用请求参数name来指定删除哪个框架,在服务器端使用ctx.query.name获取,代码如下:

router.get('/delete', ctx => {
  return new Promise(resolve => {
    const name = ctx.query.name;
    const sql = `DELETE FROM fe_frame WHERE name = '${name}'`;
    connection.query(sql, (err, result) => {
      if (err) throw err;
      ctx.body = {
        code: 200,
        msg: `delete ${result.affectedRows} data from fe_frame success!`
      };
      resolve();
    })
  })
})

重新执行node index.js,并使用浏览器访问http://localhost:3000/delete?name=jQuery

Node.js中操作MySQL数据库的方法

修改数据

当访问/update时,更新vue框架的作者名为Evan You,代码如下:

router.get('/update', ctx => {
  return new Promise(resolve => {
    const sql =  `UPDATE fe_frame SET author = 'Evan You' WHERE NAME = 'vue'`;
    connection.query(sql, (err, result) => {
      if (err) throw err;
      ctx.body = {
        code: 200,
        msg: `update ${result.affectedRows} data from fe_frame success!`
      };
      resolve();
    })
  })
})

重新执行node index.js,并使用浏览器访问http://localhost:3000/update

Node.js中操作MySQL数据库的方法

查找数据

当访问/select时,获取满足请求参数中框架名条件的项,代码如下:

router.get('/select', ctx => {
  return new Promise(resolve => {
    let name = ctx.query.name;
    const sql = `SELECT * FROM fe_frame WHERE name = '${name}'`;
    connection.query(sql, (err, result) => {
      if (err) throw err;
      ctx.body = {
        code: 200,
        data: result
      }
      resolve();
    })
  })
})

重新执行node index.js,并使用浏览器访问http://localhost:3000/select?name=vue

Node.js中操作MySQL数据库的方法

感谢各位的阅读!关于“Node.js中操作MySQL数据库的方法”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!


分享名称:Node.js中操作MySQL数据库的方法
网页路径:http://cxhlcq.com/article/jiggse.html

其他资讯

在线咨询

微信咨询

电话咨询

028-86922220(工作日)

18980820575(7×24)

提交需求

返回顶部