本文是一篇使用mysql
這個npm模塊操做MySQL數據庫的基礎教程。 不涉及MySQL的安裝和配置,若是電腦中還未安裝MySQL, 推薦安裝WAMP、XAMPP等集成環境。本文中還使用到了輕量級的Node.js框架Koa搭建web程序,爲的是經過前端瀏覽器請求的方式來模擬項目場景,你無需掌握Koa框架的語法也是能夠輕鬆閱讀本文的。javascript
建立項目目錄,並使用npm init
初始化項目後,執行下面操做:php
npm install mysql koa koa-router
// 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數據庫鏈接成功。css
打開瀏覽器, 訪問localhost:3000
,當看到屏幕顯示Visit index
時,表名項目初始化成功。html
當訪問/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
vue
爲了方便,咱們直接在鏈接時使用剛纔建立的數據庫,須要在mysql.createConnection
中添加database:mysqlkoa
的配置項。java
const connection = mysql.createConnection({ host: 'localhost', user: 'root', password: '123456', database: 'mysqlkoa' // 添加該列 })
當訪問/createtable
時,咱們建立一個數據表fe_frame
,該表用來保存前端框架的數據:node
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
mysql
當訪問/insert
時,用來插入單條數據:web
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
當訪問/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
使用phpMyAdmin訪問,能夠看到此時mysqlkoa
表以下
當訪問/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
當訪問/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
當訪問/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
mysql文檔地址: https://www.npmjs.com/package...