>[success] # 安裝 -- mysqljs/mysql * [npm 對 mysqljs 介紹](https://www.npmjs.com/package/mysql) * [github 對mysqljs 介紹](https://github.com/mysqljs/mysql#install) >[danger] ##### 安裝 -- mysqljs ~~~ 1.npm install mysqljs/mysql ~~~ >[danger] ##### github 給出 -- 使用案例 ~~~ var mysql = require('mysql'); // 導入包 var connection = mysql.createConnection({ host : 'localhost', // 連接地址 user : 'me', // 用戶名 password : 'secret', //密碼 database : 'my_db' // 數據庫名稱 }); connection.connect(); // 連接數據庫 // 執行sql 語句 connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) { if (error) throw error; console.log('The solution is: ', results[0].solution); }); // 關閉連接 connection.end(); ~~~ >[danger] ##### 增 -- insert ~~~ 1.在sql 語句 使用? 號 做占位符 2.插入語句時候使用對象的格式進行插入語句 ~~~ ~~~ // 加載數據庫驅動 const mysql = require('mysql'); // 創建數據庫連接 const connection = mysql.createConnection({ host: 'localhost', // 數據庫所在的服務器的域名或者IP地址 user: 'root', // 登錄數據庫的賬號 password: '', // 登錄數據庫的密碼 database: 'book' // 數據庫名稱 }); // 執行連接操作 connection.connect(); let sql = 'insert into book set ?' let data = { name : '明朝那些事', author : '當年明月', category : '文學', description : '明朝的歷史' } // 操作數據庫 connection.query(sql,data, function(error, results, fields) { if (error) throw error; // console.log(results); if(results.affectedRows == 1){ // 判斷更改成功數據個數 console.log('數據插入成功'); } }); // 關閉數據庫 connection.end(); ~~~ >[danger] ##### 刪 -- delete ~~~ 1.在sql 語句 使用? 號 做占位符 2.刪除的時候使用[] 來填充? 占位的條件 ~~~ ~~~ // 加載數據庫驅動 const mysql = require('mysql'); // 創建數據庫連接 const connection = mysql.createConnection({ host: 'localhost', // 數據庫所在的服務器的域名或者IP地址 user: 'root', // 登錄數據庫的賬號 password: '', // 登錄數據庫的密碼 database: 'book' // 數據庫名稱 }); // 執行連接操作 connection.connect(); let sql = 'delete from book where id = ?'; let data = [9]; // 操作數據庫 connection.query(sql,data, function(error, results, fields) { if (error) throw error; // console.log(results); if(results.affectedRows == 1){ console.log('刪除成功'); } }); // 關閉數據庫 connection.end(); ~~~ >[danger] ##### 更新 -- updata ~~~ 1.在sql 語句 使用? 號 做占位符 2.更新的時候使用[] 來填充? 占位的條件 ~~~ ~~~ const mysql = require('mysql'); // 創建數據庫連接 const connection = mysql.createConnection({ host: 'localhost', // 數據庫所在的服務器的域名或者IP地址 user: 'root', // 登錄數據庫的賬號 password: '', // 登錄數據庫的密碼 database: 'book' // 數據庫名稱 }); // 執行連接操作 connection.connect(); let sql = 'update book set name=?,author=?,category=?,description=? where id=?'; let data = ['浪潮之巔','吳軍','計算機','IT巨頭的興衰史',8]; // 操作數據庫 connection.query(sql,data, function(error, results, fields) { if (error) throw error; // console.log(results); if(results.affectedRows == 1){ console.log('更新成功'); } }); // 關閉數據庫 connection.end(); ~~~ >[danger] ##### 查 -- select ~~~ 1.在sql 語句 使用? 號 做占位符 2.查詢的時候使用[] 來填充? 占位的條件 ~~~ ~~~ // 加載數據庫驅動 const mysql = require('mysql'); // 創建數據庫連接 const connection = mysql.createConnection({ host: 'localhost', // 數據庫所在的服務器的域名或者IP地址 user: 'root', // 登錄數據庫的賬號 password: '', // 登錄數據庫的密碼 database: 'book' // 數據庫名稱 }); // 執行連接操作 connection.connect(); let sql = 'select * from book where id = ?'; let data = [6]; // 操作數據庫 connection.query(sql,data, function(error, results, fields) { if (error) throw error; console.log(results[0].name); // console.log(results); }); // 關閉數據庫 connection.end(); ~~~ >[danger] ##### 進行分裝 - api ~~~ 1.不管是增刪改查，所有方法都有一共性都是需要連接數據庫，并且關閉數 據庫，根據共性 將這個提取出來 ，封裝一下作為調用 2.exports.base將這個api 暴露出去 ~~~ ~~~ /* 封裝操作數據庫的通用api */ const mysql = require('mysql'); exports.base = (sql,data,callback) => { // 創建數據庫連接 const connection = mysql.createConnection({ host: 'localhost', // 數據庫所在的服務器的域名或者IP地址 user: 'root', // 登錄數據庫的賬號 password: '', // 登錄數據庫的密碼 database: 'book' // 數據庫名稱 }); // 執行連接操作 connection.connect(); // 操作數據庫(數據庫操作也是異步的) connection.query(sql,data, function(error, results, fields) { if (error) throw error; callback(results); }); // 關閉數據庫 connection.end(); } ~~~ >[danger] ##### 使用 -- api ~~~ 1.三個參數sql,data,callback，一次分別是sql 語句，查詢添加的數據，和回調函數 2.其中當想查全部數據的時候，我們可以將第二個變量data 傳值為null ~~~ ~~~ /* 測試通用api */ const db = require('./db.js'); // 插入操作 let sql = 'insert into book set ?'; let data = { name : '笑傲江湖', author : '金庸', category : '文學', description : '武俠小說' } db.base(sql,data,(result)=>{ console.log(result); }); // 更新操作 let sql = 'update book set name=?,author=?,category=?,description=? where id=?'; let data = ['天龍八部','金庸','文學','武俠小說',11]; db.base(sql,data,(result)=>{ console.log(result); }); // 刪除操作 let sql = 'delete from book where id = ?'; let data = [11]; db.base(sql,data,(result)=>{ console.log(result); }); // 查詢操作 let sql = 'select * from book where id = ?'; let data = [8]; db.base(sql,data,(result)=>{ console.log(result[0].name); }); ~~~