midway mysql egg-mysql 配置 基礎操作 增删改查

egg-mysql

：GITHUB傳送門

一、配置

1. 安裝

   egg-mysql

   npm install egg-mysql -S
              

2. 在

   src/config/plugin.ts

   添加配置代碼如下

   export default {
     ……
     mysql: {
       enable: true,
       package: 'egg-mysql',
     }
     ……
   } as EggPlugin;
              

3. 在

   src/config/config.default.ts

   添加配置代碼如下

   import { EggAppConfig, EggAppInfo, PowerPartial } from 'midway';
   export type DefaultConfig = PowerPartial<EggAppConfig>
   
   export default (appInfo: EggAppInfo) => {
     const config = <DefaultConfig> {};
     ……
     config.mysql = {
       // database configuration
       client: {
         // host
         host: '127.0.0.1',
         // port
         port: '3306',
         // username
         user: 'root',
         // password
         password: '123456',
         // database
         database: 'yoye',
       },
       //load into app,default is open //加載到應用程式，預設為打開
       app:true,
       //load into agent,default is close //加載到代理中，預設值為“關閉”
       agent:false,
     }
     
   ……
     return config;
   };
              

二、建立測試資料

在這裡我們的

mysql

裡是存在名為

yoye

的資料庫，并且通過

sql

語句建立了

test

表，且存在一個

name

字段，建立資料庫并初始化測試表

SQL

語句如下：

1. 建立資料庫，且編碼為

   utf8

2. 建立資料表，且存在自增主鍵

   id

   、字元串字段

   name

   create table test(
   	id int not null auto_increment primary key,
   	name varchar(100) not null
   );
              

3. 向表中新增一條測試資料

三、注入

在

controller

中注入，代碼如下

import { get, post } from 'midway';
import { Context, controller, inject, provide, plugin } from 'midway';

@provide()
@controller('/auth')
export class AuthController {
  ……
  @plugin()
  mysql;
  ……
}
           

接下來就可以通過

this.mysql

愉快的使用了

四、基礎操作

1. 條件查詢，方法一

   const result = await this.mysql.get("test", { id: 1 })
   if (result != null) {
     console.log(result.name);
   }
              

2. 條件查詢，方法二

   const result = await this.mysql.select("test", {
     where: {
       name: ['yoye', 'test'], // 相當于 in
     },
     order: [['id', 'desc'], ['name', 'desc']]
   })
   if (result.length) {
     console.log(result[0].name);
   }
              

3. 新增
4. 修改，方法一

   const result = await this.mysql.update('test', { id: 2, name: 'ella' });
   console.log(result);
              

5. 修改，方法二

   const result = await this.mysql.query('update test set name = ? where id = ?', ["yooyea", 2]);
   console.log(result);
              

6. 删除

   let result = await this.mysql.delete('test', { id: 2 });
   console.log(result);
              

7. 執行原生SQL

   const sql = 'select * from test limit ?'
   const values = [10]
   this.mysql.query(sql, values).then((res:any)=>{
     console.log(res);
   })    
              

8. Mysql事務

   const conn = await this.mysql.beginTransaction();
   try {
     await conn.insert('test', { 'name': 'lisa' });
     await conn.update('test', { id: 2, name: 'ella' });
     await conn.commit();  //送出事務
     const result = await this.mysql.select("test", {})
     console.log(result);
   } catch (err) {
     await conn.rollback();//復原事務
     throw err;
   }