1 MySQL查询对象
2 MySQL查询数组
3 mysql2库介绍使用
4 mysql2预处理语句
5 mysql2连接池使用
6 mysql2的Promi
这里仅说明如何使用服务器连接数据库并进行操作。
预处理语句就是可以输入变量的语句（表现形式是有符号：？）。需要使用.execute来执行；
需要运行普通的语句（不添加变量的语句）。就使用query。
预处理语句有很多好处，比如性能好、安全性（sql注入）。
如果连接的用户很多，每次都创建数据库的连接和销毁连接会有影响，所以创建数据库连接的时候我们可以使用连接池来做优化
没使用连接池的连接方法：
使用了连接池的方法：
需要下载相应的第三方库才能让node驱动数据库：
npm install mysql2
准备数据-将json文件的数据插入到数据库中
从phpne.json文件里面获取json格式的数据并写到数据库里面。
const mysql = require('mysql2');const connection = mysql.createConnection({host: 'localhost',port: 3306,user: 'root',password: 'Coderwhy123.',database: 'music_db' });const statement = `INSERT INTO products SET ?;` const phoneJson = require('./phone.json');for (let phone of phoneJson) {connection.query(statement, phone); }
phone.jsond的内容：
[{"brand": "华为","title": "华为nova 3（全网通） ","price": 2699,"score": 6.7,"voteCnt": 65,"url": "http://detail.zol.com.cn/cell_phone/index1185512.shtml","pid": "1185512"},{"brand": "华为","title": "华为P20 Pro（6GB RAM/全网通） ","price": 4488,"score": 8.3,"voteCnt": 103,"url": "http://detail.zol.com.cn/cell_phone/index1207038.shtml","pid": "1207038"},{"brand": "华为","title": "华为P20（全网通） ","price": 3388,"score": 8.4,"voteCnt": 127,"url": "http://detail.zol.com.cn/cell_phone/index1175779.shtml","pid": "1175779"},{"brand": "华为","title": "华为nova 3i（4GB RAM/全网通） ","price": 1999,"score": 7,"voteCnt": 9,"url": "http://detail.zol.com.cn/cell_phone/index1222100.shtml","pid": "1222100"}
]mysql2-基本使用
const mysql = require('mysql2')// 1.创建一个连接(连接上数据库) const connection = mysql.createConnection({host: 'localhost',port: 3306,database: 'music_db',user: 'root',password: 'Coderwhy123.' })// 2.执行操作语句, 操作数据库 const statement = 'SELECT * FROM `students`;' // structure query language: DDL/DML/DQL/DCL // query可以执行DDL/DML/DQL/DCL的语句的代码。返回的值在回调函数里面。 connection.query(statement, (err, values, fields) => {if (err) {console.log('查询失败:', err)return}// 查看结果console.log(values)// console.log(fields) })
mysql2-预处理语句
const mysql = require('mysql2')// 1.创建一个连接 const connection = mysql.createConnection({host: 'localhost',port: 3306,database: 'music_db',user: 'root',password: 'Coderwhy123.' })// 2.执行一个SQL语句: 预处理语句 const statement = 'SELECT * FROM `products` WHERE price > ? AND score > ?;' connection.execute(statement, [1000, 8], (err, values) => {console.log(values) })// connection.destroy()
mysql2-连接池使用
const mysql = require('mysql2')// 1.创建一个连接 const connectionPool = mysql.createPool({host: 'localhost',port: 3306,database: 'music_db',user: 'root',password: 'Coderwhy123.',// connectionLimit用来限制连接数量的connectionLimit: 5 })// 2.执行一个SQL语句: 预处理语句 const statement = 'SELECT * FROM `products` WHERE price > ? AND score > ?;' connectionPool.execute(statement, [1000, 8], (err, values) => {console.log(values) })
mysql2-Promise写法
const mysql = require('mysql2')// 1.创建一个连接 const connectionPool = mysql.createPool({host: 'localhost',port: 3306,database: 'music_db',user: 'root',password: 'Coderwhy123.',connectionLimit: 5 })// 2.执行一个SQL语句: 预处理语句 const statement = 'SELECT * FROM `products` WHERE price > ? AND score > ?;'connectionPool.promise().execute(statement, [1000, 9]).then((res) => {const [values, fields] = resconsole.log('-------------------values------------------')console.log(values)console.log('-------------------fields------------------')console.log(fields) }).catch(err => {console.log(err) })
