使用egg-mysql操作MySQL数据库

作者阿里云代理 文章分类 分类:windows视频教程 阅读次数 已被围观 317

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…

  1. 安装插件
npm i egg-mysql 复制代码
  1. 启用插件

在config/plugin.js中启用这个插件,如果此时已经有了其他的插件,我们可以通过并行的方式进行添加,请看下面的例子。

exports.ejs = {  enable: true,  package: 'egg-view-ejs' }; exports.mysql = {  enable: true,  package: 'egg-mysql', }; 复制代码
  1. 配置数据库的连接

找到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'}); 复制代码

修改数据

  1. 根据主键进行修改
// 根据主键进行修改 const row = {  id: 3,  username: '王五' } const result = await this.app.mysql.update('user',row); 复制代码
  1. 通过原生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; }
本公司销售:阿里云、腾讯云、百度云、天翼云、金山大米云、金山企业云盘!可签订合同,开具发票。

我有话说: