这是我参与11月更文挑战的第4天，活动详情查看：2021最后一次更文挑战
MySQL事务
事务处理可以用来维护数据库的完整性，保证成批的SQL语句，要么全部执行，要么全部不执行。当批量执行SQL的时候，事务可以保证我们数据的一致性。
下面是完整的执行流程
begin; update user set balance = balance - 100 where id = 1; update user set balance = balance + 100 where id = 2; commit; 复制代码
如果遇到错误，可以不commit，而是使用rollback进行事务回滚。
MySQL锁
1. 添加读锁
设置读锁期间，在没释放锁之前是不能进行写操作的。
lock table user read; update user set username="李四" where id = 3; 复制代码
上面的用法会报错：Table 'user' was locked with a READ lock and can't be updated。
只有解除锁的时候才可以进行写操作。
lock table user read; unlock tables; update user set username="李四" where id = 3; 复制代码
上面的写法是正确的。
2. 添加写锁
只有锁表的用户可以进行读写操作，其他用户即不能读也不能写。只有释放这个锁的时候才可以进行读写，因此在演示的时候，建议开启两个不同的命令行进行演示。
lock table user write; select * from user; update user set username = "333" where id = 3; unlock tables; 复制代码
使用egg-mysql操作MySQL数据库
配置egg-mysql
egg-mysql的插件地址：www.npmjs.com/package/egg…
- 安装插件
npm i egg-mysql 复制代码
- 启用插件
在config/plugin.js中启用这个插件，如果此时已经有了其他的插件，我们可以通过并行的方式进行添加，请看下面的例子。
exports.ejs = { enable: true, package: 'egg-view-ejs' }; exports.mysql = { enable: true, package: 'egg-mysql', }; 复制代码
- 配置数据库的连接
找到config.default.js文件，并在其中添加下面的语句进行配置连接数据库。
exports.mysql = { // database configuration client: { // host host: 'mysql.com', // port port: '3306', // username user: 'test_user', // password password: 'test_password', // database database: 'test', }, // load into app, default is open app: true, // load into agent, default is close agent: false, }; 复制代码
对数据库数据的增删改查
更多关于对数据库的操作方法，请查询网址：eggjs.org/zh-cn/tutor…
读取数据
// 查询一条数据 const result = await this.app.mysql.get('user',{"id": 3}); // 查询全部数据 const all = await this.app.mysql.select('user',{}); // 带限制条件的 const all = await this.app.mysql.select('user',{ where: {"id": 3}， // 升序排列 orders: [["id","asc"]] }); 复制代码
添加数据
const add = await this.app.mysql.insert('user',{username: '秦始皇',balance: '100000'}); 复制代码
修改数据
- 根据主键进行修改
// 根据主键进行修改 const row = { id: 3, username: '王五' } const result = await this.app.mysql.update('user',row); 复制代码
- 通过原生SQL语句来修改数据
const result = await this.app.mysql.query('update user set username=? where id = ?',["皇家礼炮",5]); 复制代码
删除数据
下面的删除方式会把所有符合条件的都删除掉。
const result = await this.app.mysql.delete('user',{ username: '秦始皇' }) 复制代码
操作MySQL事务
使用事务的时候，如果出现错误，不会真正的执行SQL语句，防止造成不同步的问题。
// mysql事务 const conn = await this.app.mysql.beginTransaction(); try { // await conn.insert(table, row1); // await conn.update(table, row2); // 增加数据 await conn.query('update user set username=? where id = ?',["皇家礼炮666",5]); await conn.insert('user',{username: '秦始皇2',balance: '100000'}); await conn.commit(); } catch (err) { // error, rollback await conn.rollback(); // rollback call won't throw err throw err; }
