Nodejs中koa2连接mysql的实现示例

目录

将查询结果转为对象或者数组mysql2的使用

Prepared Statement(预处理语句)Connection Pools(连接池)Promise方式

sequelize

Sequelize的使用Sequelize的单表操作Sequelize的一对多操作Sequelize的多对多操作

将查询结果转为对象或者数组

在真实开发中，实际上某些查询结果应该放入到一个对象中
JSON_OBJECT：（）中是key-value的形式

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

复制代码

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

比如一个学生的多门课程信息，应该是放到一个数组中的；数组中存放的是课程信息的一个个对象；这个时候我们要JSON_ARRAYAGG和JSON_OBJECT结合来使用；

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

复制代码

mysql2的使用

安装mysql2:

1. npm install mysql2

复制代码

简单使用：

1. const mysql = require('mysql2');
3. // 1.创建数据库连接
4. const connection = mysql.createConnection({
5.   host: 'localhost',
6.   port: 3306,
7.   database: 'coderhub',
8.   user: 'root',
9.   password: 'Coderwhy888.'
10. });
12. // 2.执行SQL语句
13. const statement = `
14.   SELECT * FROM products WHERE price > 6000;
15. `
16. connection.query(statement, (err, results, fields) => {
17.   console.log(results);
18. });

复制代码

如果我们想要在拿到数据后停止服务，可以在回调函数中写上：

1. connection.end()

复制代码

完整代码：

1. connection.query(statement, (err, results, fields) => {
2.   console.log(results);
3.   connection.end();
4. });

复制代码

Prepared Statement(预处理语句)

提高性能：将创建的语句模块发送给MySQL，然后MySQL编译（解析、优化、转换）语句模块，并且存储
它但是不执行，之后我们在真正执行时会给?提供实际的参数才会执行；就算多次执行，也只会编译一次，所以性能是更高的；
强调：如果再次执行该语句，它将会从LRU（Least Recently Used） Cache中获取获取，省略了编译statement的时间来提高性能。

1. // 2.执行SQL语句: 使用 ？来对参数进行占位
2. const statement = `
3.   SELECT * FROM products WHERE price > ? AND score > ?;
4. `
5. connection.execute(statement, [6000, 7], (err, results) => {
6.   console.log(results);
7. });

复制代码

Connection Pools(连接池)

前面我们是创建了一个连接（connection），但是如果我们有多个请求的话，该连接很有可能正在被占用，那么我们是否需要每次一个请求都去创建一个新的连接呢？

事实上，mysql2给我们提供了连接池（connection pools）；连接池可以在需要的时候自动创建连接，并且创建的连接不会被销毁，会放到连接池中，后续可以继续使用；我们可以在创建连接池的时候设置LIMIT，也就是最大创建个数；

判断是否连接成功

1. const mysql = require('mysql2');
3. // 1.创建连接池
4. const connections = mysql.createPool({
5.   host: 'localhost',
6.   port: 3306,
7.   database: 'coderhub',
8.   user: 'root',
9.   password: 'Coderwhy888.',
10.   connectionLimit: 10
11. });
13. connections.getConnection((err, conn) => {
14.   conn.connect((err) => {
15.     if(err){
16.       console.log('连接失败：',err)
17.     } else {
18.       console.log('数据库连接成功~')
19.     }
20.   })
21. })

复制代码

简单使用数据库

1. const mysql = require('mysql2');
3. // 1.创建连接池
4. const connections = mysql.createPool({
5.   host: 'localhost',
6.   port: 3306,
7.   database: 'coderhub',
8.   user: 'root',
9.   password: 'Coderwhy888.',
10.   connectionLimit: 10
11. });
13. // 2.使用连接池
14. const statement = `
15.   SELECT * FROM products WHERE price > ? AND score > ?;
16. `
17. connections.execute(statement, [6000, 7], (err, results) => {
18.   console.log(results);
19. });

复制代码

Promise方式

1. const mysql = require('mysql2');
3. // 1.创建连接池
4. const connections = mysql.createPool({
5.   host: 'localhost',
6.   port: 3306,
7.   database: 'coderhub',
8.   user: 'root',
9.   password: 'Coderwhy888.',
10.   connectionLimit: 10
11. });
13. // 2.使用连接池
14. const statement = `
15.   SELECT * FROM products WHERE price > ? AND score > ?;
16. `
17. connections.promise().execute(statement, [6000, 7]).then(([results,fields]) => {
18.   console.log(results);
19. }).catch(err => {
20.   console.log(err);
21. });

复制代码

sequelize

对象关系映射(ORM):是一种程序设计的方案：

从效果上来讲，它提供了一个可在编程语言中，使用虚拟对象数据库的效果；

Node当中的ORM我们通常使用的是sequelize;

Sequelize是用于Postgres，MySQL，MariaDB，SQLite和Microsoft SQL Server的基于Node.js 的ORM；它支持非常多的功能；

如果我们希望将Sequelize和MySQL一起使用，那么我们需要先安装两个东西：

mysql2：sequelize在操作mysql时使用的是mysql2；sequelize：使用它来让对象映射到表中；

1. npm install sequelize mysql2

复制代码

Sequelize的使用

Sequelize的连接数据库：
第一步：创建一个Sequelize的对象，并且指定数据库、用户名、密码、数据库类型、主机地址等；
第二步：测试连接是否成功；

1. const { Sequelize } = require('sequelize');
3. const sequelize = new Sequelize('coderhub', 'root', 'Coderwhy888.', {
4.   host: 'localhost',
5.   dialect: 'mysql'//连接的数据库类型：mysql，mongoose
6. });
8. sequelize.authenticate().then(() => {
9.   console.log("连接数据库成功~");
10. }).catch(err => {
11.   console.log("连接数据库失败~", err);
12. });

复制代码

Sequelize的单表操作

1. const { Sequelize, DataTypes, Model, Op } = require('sequelize');
3. const sequelize = new Sequelize("coderhub", 'root', 'Coderwhy888.', {
4.   host: 'localhost',
5.   dialect: 'mysql'
6. })
8. //1.首先我们需要将数据库中的一张表映射成一个class类
9. class Product extends Model {}
10. Product.init({
11.   id: {
12.     type: DataTypes.INTEGER,
13.     primaryKey: true,//主键
14.     autoIncrement: true//自动增长
15.   },
16.   title: {
17.     type: DataTypes.STRING,
18.     allowNotNull: false//是否可以为空
19.   },
20.   price: DataTypes.DOUBLE,
21.   score: DataTypes.DOUBLE
22. }, {//与数据库的表进行映射的配置
23.   tableName: 'products',
24.   createdAt: false,
25.   updatedAt: false,
26.   sequelize
27. });
29. //存放操作数据库的代码
30. async function queryProducts() {
31.   //1.查询数据库中product表中所有的内容
32.   const result1 = await Product.findAll({
33.     where: {//在这里配置条件
34.       price: {
35.         [Op.gte]: 5000//意思是价格大于等于5000
36.         //gte:大于等于，gt:大于，lt:小于，lte:小于等于
37.       }
38.     }
39.   });
40.   console.log(result1);
42.   // 2.插入数据
43.   const result2 = await Product.create({
44.     title: "三星Nova",
45.     price: 8888,
46.     score: 5.5
47.   });
48.   console.log(result2);
50.   // 3.更新数据
51.   const result3 = await Product.update({
52.     price: 3688
53.   }, {
54.     where: {
55.       id: 1
56.     }
57.   });
58.   console.log(result3);
59. }
61. queryProducts();//执行这个函数可以实现对数据库的操作

复制代码

Sequelize的一对多操作

1. const { Sequelize, DataTypes, Model, Op } = require('sequelize');
3. const sequelize = new Sequelize("coderhub", 'root', 'Coderwhy888.', {
4.   host: 'localhost',
5.   dialect: 'mysql'
6. });
8. //数据库的第一个表: 主表
9. class Brand extends Model {};
10. Brand.init({
11.   id: {
12.     type: DataTypes.INTEGER,
13.     primaryKey: true,
14.     autoIncrement: true
15.   },
16.   name: {
17.     type: DataTypes.STRING,
18.     allowNotNull: false
19.   },
20.   website: DataTypes.STRING,
21.   phoneRank: DataTypes.INTEGER
22. }, {
23.   tableName: 'brand',
24.   createdAt: false,
25.   updatedAt: false,
26.   sequelize
27. });
29. //数据库的第二个表：附表
30. class Product extends Model {}
31. Product.init({
32.   id: {
33.     type: DataTypes.INTEGER,
34.     primaryKey: true,
35.     autoIncrement: true
36.   },
37.   title: {
38.     type: DataTypes.STRING,
39.     allowNotNull: false
40.   },
41.   price: DataTypes.DOUBLE,
42.   score: DataTypes.DOUBLE,
43.   brandId: {
44.     field: 'brand_id',
45.     type: DataTypes.INTEGER,
46.     references: {//这张表使用了Brand的id作为外键
47.       model: Brand,//product这张表使用了Brand这个表，所以product必须放在下面
48.       key: 'id'
49.     }
50.   }
51. }, {
52.   tableName: 'products',
53.   createdAt: false,
54.   updatedAt: false,
55.   sequelize
56. });
58. // 将两张表联系在一起
59. Product.belongsTo(Brand, {
60.   foreignKey: 'brandId'//外键
61. });
63. async function queryProducts() {
64.   const result = await Product.findAll({
65.     include: { //这里是联合查询：意思是包含别的表的信息
66.       model: Brand
67.     }
68.   });
69.   console.log(result);
70. }
72. queryProducts();

复制代码

Sequelize的多对多操作

1. const { Sequelize, DataTypes, Model, Op } = require('sequelize');
3. const sequelize = new Sequelize("coderhub", 'root', 'Coderwhy888.', {
4.   host: 'localhost',
5.   dialect: 'mysql'
6. });
8. // Student表
9. class Student extends Model {}
10. Student.init({
11.   id: {
12.     type: DataTypes.INTEGER,
13.     primaryKey: true,
14.     autoIncrement: true
15.   },
16.   name: {
17.     type: DataTypes.STRING,
18.     allowNotNull: false
19.   },
20.   age: DataTypes.INTEGER
21. }, {
22.   tableName: 'students',
23.   createdAt: false,
24.   updatedAt: false,
25.   sequelize
26. });
28. // Course表
29. class Course extends Model {}
30. Course.init({
31.   id: {
32.     type: DataTypes.INTEGER,
33.     primaryKey: true,
34.     autoIncrement: true
35.   },
36.   name: {
37.     type: DataTypes.STRING,
38.     allowNotNull: false
39.   },
40.   price: DataTypes.DOUBLE
41. }, {
42.   tableName: 'courses',
43.   createdAt: false,
44.   updatedAt: false,
45.   sequelize
46. });
48. // StudentCourse表：关系表
49. class StudentCourse extends Model {}
50. StudentCourse.init({
51.   id: {
52.     type: DataTypes.INTEGER,
53.     primaryKey: true,
54.     autoIncrement: true
55.   },
56.   studentId: {//与Student表建立关系
57.     type: DataTypes.INTEGER,
58.     references: {
59.       model: Student,
60.       key: 'id'
61.     },
62.     field: 'student_id'
63.   },
64.   courseId: {//与Course表建立关系
65.     type: DataTypes.INTEGER,
66.     references: {
67.       model: Course,
68.       key: 'id'
69.     },
70.     field: 'course_id'
71.   }
72. }, {
73.   tableName: 'students_select_courses',
74.   createdAt: false,
75.   updatedAt: false,
76.   sequelize
77. });
79. // 多对多关系的联系：Student StudentCourse Course
80. Student.belongsToMany(Course, {
81.   through: StudentCourse,
82.   foreignKey: 'studentId',//这里是Student与StudentCourse，所以外键是studentId
83.   otherKey: 'courseId'//StudentCourse与Course，所以外键是courseId
84. });
86. //与上面类似
87. Course.belongsToMany(Student, {
88.   through: StudentCourse,
89.   foreignKey: 'courseId',
90.   otherKey: 'studentId'
91. });
93. async function queryProducts() {
94.   const result = await Student.findAll({
95.     include: {//所有学生的选课情况
96.       model: Course
97.     }
98.   });
99.   console.log(result);
100. }
102. queryProducts();

复制代码

到此这篇关于Nodejs中koa2连接mysql的实现示例的文章就介绍到这了,更多相关koa2连接mysql内容请搜索中国红客联盟以前的文章或继续浏览下面的相关文章希望大家以后多多支持中国红客联盟！