1. this.app.mysql.get("data_options", {value: "xxx"}); // 查询一个内容
  2. this.app.mysql.insert("i18n_config", [{...}]); // 批量添加
  3. this.app.mysql.select("i18n_config", {
  4.   where: {
  5.     id: 10000
  6.   }                                      
  7. });
  9. await this.app.mysql.update('i18n_comment', {
  10.   id: i18nComment.id, // 修改时，一定需要id作为索引进行修改
  11.   comment,
  12.   en_unique_md5,
  13.   cn_value: cnValue,
  14. });
  17. await this.app.mysql.select("select * from i18n_config_status_data where id = ?", [1000]),

事务

  1. const conn = yield app.mysql.beginTransaction();
  3. try {
  4.   yield conn.insert(table, row1);
  5.   yield conn.update(table, row2);
  6.   yield conn.commit();
  7. } catch (err) {
  8.   // error, rollback
  9.   yield conn.rollback(); // rollback call won't throw err
  10.   throw err;
  11. }
  14. const result = yield app.mysql.beginTransactionScope(function* (conn) {
  15.   // don't commit or rollback by yourself
  16.   yield conn.insert(table, row1);
  17.   yield conn.update(table, row2);
  18.   return { success: true };
  19. }, ctx); // ctx is the context of current request, access by `this.ctx`.
  20. // if error throw on scope, will auto rollback