Skip to content

查询数据的问题

前面我们学习的查询语句,查询到的结果通常是一张表,比如查询手机+品牌信息:

javascript
SELECT * FROM products LEFT JOIN brand ON products.brand_id = brand.id;

image-20240720164636570

将brand转成对象

image-20240720173058322

但是在真实开发中,实际上红色圈起来的部分应该放入到一个对象中,那么我们可以使用下面的查询方式:

这个时候我们要用 JSON_OBJECT;

javascript
SELECT products.id as id, products.title as title, products.price as price, products.score as score, 
	JSON_OBJECT('id', brand.id, 'name', brand.name, 'rank', brand.phoneRank, 'website', brand.website) as brand
FROM products LEFT JOIN brand ON products.brand_id = brand.id;

image-20240720164730645

多对多转成数组

image-20240720173122475

在多对多关系中,我们希望查询到的是一个数组:

比如一个学生的多门课程信息,应该是放到一个数组中的;

数组中存放的是课程信息的一个个对象;

这个时候我们要 JSON_ARRAYAGG和JSON_OBJECT结合来使用;

javascript
SELECT stu.id, stu.name, stu.age, 
JSON_ARRAYAGG(JSON_OBJECT('id', cs.id, 'name', cs.name)) as courses 
FROM students stu
LEFT JOIN students_select_courses ssc ON stu.id = ssc.student_id
LEFT JOIN courses cs ON ssc.course_id = cs.id
GROUP BY stu.id;

image-20240720165524373

认识mysql2

前面我们所有的操作都是在GUI工具中,通过执行SQL语句来获取结果的,那真实开发中肯定是通过代码来完成所有的操作的。

那么如何可以在Node的代码中执行SQL语句来,这里我们可以借助于两个库:

mysql:最早的Node连接MySQL的数据库驱动;

mysql2:在mysql的基础之上,进行了很多的优化、改进;

目前相对来说,我更偏向于使用mysql2,mysql2兼容mysql的API,并且提供了一些附加功能

更快/更好的性能;

Prepared Statement(预编译语句):

  • 提高性能:将创建的语句模块发送给MySQL,然后MySQL编译(解析、优化、转换)语句模块,并且存储它但是不执行,

    之后我们在真正执行时会给?提供实际的参数才会执行;就算多次执行,也只会编译一次,所以性能是更高的;

  • 防止SQL注入:之后传入的值不会像模块引擎那样就编译,那么一些SQL注入的内容不会被执行;or 1 = 1不会被执行;

支持Promise,所以我们可以使用async和await语法

等等....

所以后续的学习中我会选择mysql2在node中操作数据。

使用mysql2

安装mysql2

javascript
npm install mysql2

mysql2的使用过程如下:

第一步:创建连接(通过createConnection),并且获取连接对象;

第二步:执行SQL语句即可(通过query);

image-20240720171131437

javascript
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
connection.query(statement, (err, values, fields) => {
  if (err) {
    console.log('查询失败:', err)
    return
  }

  // 查看结果
  console.log(values)
  // console.log(fields)
})

Prepared Statement

Prepared Statement(预编译语句):

提高性能:将创建的语句模块发送给MySQL,然后MySQL编译(解析、优化、转换)语句模块,并且存储它但是不执行,之

后我们在真正执行时会给?提供实际的参数才会执行;就算多次执行,也只会编译一次,所以性能是更高的;

image-20240720173155926

防止SQL注入:之后传入的值不会像模块引擎那样就编译,那么一些SQL注入的内容不会被执行;or 1 = 1不会被执行;

image-20240720173220788

image-20240720172951428
javascript
const mysql = require('mysql2')

// 1.创建一个连接
const connection = mysql.createConnection({
  host: 'localhost',
  port: 3306,
  database: 'music_db',
  user: 'root',
  password: 'Coderwhy123.'
})

// 2.执行一个SQL语句: 预处理语句 execute
const statement = 'SELECT * FROM `products` WHERE price > ? AND score > ?;'
connection.execute(statement, [1000, 8], (err, values) => {
  console.log(values)
})

// connection.destroy()

Connection Pools

前面我们是创建了一个连接(connection),但是如果我们有多个请求的话,该连接很有可能正在被占用,那么我们是否需要

每次一个请求都去创建一个新的连接呢?

事实上,mysql2给我们提供了连接池(connection pools);

连接池可以在需要的时候自动创建连接,并且创建的连接不会被销毁,会放到连接池中,后续可以继续使用;

我们可以在创建连接池的时候设置LIMIT,也就是最大创建个数;

image-20240720174228173

javascript
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.execute(statement, [1000, 8], (err, values) => {
  console.log(values)
})

Promise方式

目前在JavaScript开发中我们更习惯Promise和await、async的方式,mysql2同样是支持的:

image-20240720174701248
javascript
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] = res
  console.log('-------------------values------------------')
  console.log(values)
  console.log('-------------------fields------------------')
  console.log(fields)
}).catch(err => {
  console.log(err)
})