com.jfinal.plugin.activerecord.Db类的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(165)

本文整理了Java中com.jfinal.plugin.activerecord.Db类的一些代码示例,展示了Db类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Db类的具体详情如下:
包路径:com.jfinal.plugin.activerecord.Db
类名称:Db

Db介绍

[英]Db. Powerful database query and update tool box.
[中]Db。强大的数据库查询和更新工具箱。

代码示例

代码示例来源:origin: jfinal/jfinal

public static int update(Connection conn, String sql, Object... paras) throws SQLException {
  return Db.update(DbKit.config, conn, sql, paras);
}

代码示例来源:origin: JpressProjects/jpress

@Override
public boolean deleteById(Object id) {
  return Db.tx(() -> {
    boolean delOk = ArticleServiceProvider.super.deleteById(id);
    if (delOk == false) {
      return false;
    }
    List<Record> records = Db.find("select * from article_category_mapping where article_id = ? ", id);
    if (records == null || records.isEmpty()) {
      return true;
    }
    Db.update("delete from article_category_mapping where article_id = ?", id);
    records.stream().forEach(record -> {
      categoryService.updateCount(record.get("category_id"));
    });
    return true;
  });
}

代码示例来源:origin: JpressProjects/jpress

@Override
public void doUpdateCategorys(long articleId, Long[] categoryIds) {
  Db.tx(() -> {
    Db.update("delete from article_category_mapping where article_id = ?", articleId);
    if (categoryIds != null && categoryIds.length > 0) {
      List<Record> records = new ArrayList<>();
      for (long categoryId : categoryIds) {
        Record record = new Record();
        record.set("article_id", articleId);
        record.set("category_id", categoryId);
        records.add(record);
      }
      Db.batchSave("article_category_mapping", records, records.size());
    }
    return true;
  });
}

代码示例来源:origin: JpressProjects/jpress

@Override
@CacheEvict(name = "user_role", key = "*")
public boolean deleteById(Object id) {
  return Db.tx(() -> {
    Db.update("delete from user_role_mapping where role_id = ? ", id);
    Db.update("delete from role_permission_mapping where role_id = ? ", id);
    return RoleServiceProvider.super.deleteById(id);
  });
}

代码示例来源:origin: yjjdick/sdb-mall

@Override
public Boolean updateByGrouponId(String grouponId,Integer status) {
  SqlPara sqlPara = Db.getSqlPara("order.updateByGrouponId", Kv.by("orderStatus", status).set("grouponId", grouponId));
  return Db.update(sqlPara) > 0;
}

代码示例来源:origin: jfinal/jfinal

public static List<Record> find(Connection conn, String sql, Object... paras) throws SQLException {
  return Db.find(DbKit.config, conn, sql, paras);
}

代码示例来源:origin: yjjdick/sdb-mall

@Override
  public List<FavoriteGoodsDTO> list(String userId) {
    SqlPara sqlPara =  Db.getSqlPara("favoriteGoods.list", Kv.by("userId", userId));
    List<Record> recordList = Db.find(sqlPara);
    List<FavoriteGoodsDTO> favoriteGoodsDTOList = RecordUtils.converModel(recordList, FavoriteGoodsDTO.class);
    return favoriteGoodsDTOList;
  }
}

代码示例来源:origin: 94fzb/zrlog

public boolean updateByKV(String name, Object value) {
  if (Db.queryInt("select siteId from " + TABLE_NAME + " where name=?", name) != null) {
    Db.update("update " + TABLE_NAME + " set value=? where name=?", value, name);
  } else {
    Db.update("insert " + TABLE_NAME + "(`value`,`name`) value(?,?)", value, name);
  }
  return true;
}

代码示例来源:origin: jfinal/jfinal

public static <T> List<T> query(Connection conn, String sql, Object... paras) throws SQLException {
  return Db.query(DbKit.config, conn, sql, paras);
}

代码示例来源:origin: JpressProjects/jpress

@Override
public void run() {
  if (utmList.isEmpty()) {
    return;
  }
  List<Utm> tempUtmList = new ArrayList<>(utmList);
  utmList.clear();
  Db.batchSave(tempUtmList, 1000);
}

代码示例来源:origin: JpressProjects/jpress

@Override
@CachesEvict({
    @CacheEvict(name = "user_role", key = "user_roles:#(userId)"),
    @CacheEvict(name = "user_permission", key = "*")
})
public boolean doResetUserRoles(long userId, Long... RoleIds) {
  if (RoleIds == null || RoleIds.length == 0) {
    return Db.delete("delete from user_role_mapping where user_id = ? ", userId) > 0;
  }
  return Db.tx(() -> {
    Db.delete("delete from user_role_mapping where user_id = ? ", userId);
    List<Record> records = new ArrayList<>();
    for (Long roleId : RoleIds) {
      Record record = new Record();
      record.set("user_id", userId);
      record.set("role_id", roleId);
      records.add(record);
    }
    Db.batchSave("user_role_mapping", records, records.size());
    return true;
  });
}

代码示例来源:origin: JpressProjects/jpress

@Override
public int findCountByStatus(String status) {
  return Db.queryInt("select count(*) from user where status = ?", status);
}

代码示例来源:origin: ticktack/kungfu

public int saveOrUpdate(List<? extends Model<?>> list, boolean flag) {
  if (flag) {
    return Db.batchSave(list, list.size()).length;
  }
  else {
    return Db.batchUpdate(list, list.size()).length;
  }
}

代码示例来源:origin: pkanyue/jboot-admin

@Override
public boolean auth(Long id, String resIds) {
  List<RoleRes> roleResList = new ArrayList<RoleRes>();
  return Db.tx(new IAtom() {
    @Override
    public boolean run() throws SQLException {
      roleResService.deleteByRoleId(id);
      if (StrKit.notBlank(resIds)) {
        String[] ress = resIds.split(",");
        for (String resId : ress) {
          RoleRes roleRes = new RoleRes();
          roleRes.setRoleId(id);
          roleRes.setResId(Long.parseLong(resId));
          roleResList.add(roleRes);
        }
        int[] rets = Db.batchSave(roleResList, roleResList.size());
        for (int ret : rets) {
          if (ret < 1) {
            return false;
          }
        }
      }
      return true;
    }
  });
}

代码示例来源:origin: yjjdick/sdb-mall

@Override
@JFinalTx
public void updateValueByKey(String key, String value) {
  SqlPara sqlPara = Db.getSqlPara("sysConfig.updateValueByKey", Kv.by("paramValue", value).set("paramKey", key));
  Db.update(sqlPara);
  sysConfigRedis.delete(key);
}

代码示例来源:origin: jfinal/jfinal

public static List<Record> find(String configName, Connection conn, String sql, Object... paras) throws SQLException {
  return Db.find(DbKit.getConfig(configName), conn, sql, paras);
}

代码示例来源:origin: JpressProjects/jpress

@Override
@CacheEvict(name = "user_role", key = "*")
public boolean deleteByIds(Object... ids) {
  return Db.tx(() -> {
    Db.update("delete from user_role_mapping where role_id in  " + SqlUtils.buildInSqlPara(ids));
    Db.update("delete from role_permission_mapping where role_id in  " + SqlUtils.buildInSqlPara(ids));
    return Db.update("delete from role where id in " + SqlUtils.buildInSqlPara(ids)) > 0;
  });
}

代码示例来源:origin: yjjdick/sdb-mall

@Override
  public List<CartDTO> listDetail(String userId) {
    SqlPara sqlPara =  Db.getSqlPara("cart.listDetail", Kv.by("userId", userId));
    List<Record> recordList = Db.find(sqlPara);
    List<CartDTO> cartDTOList = RecordUtils.converModel(recordList, CartDTO.class);
    return cartDTOList;
  }
}

代码示例来源:origin: jfinal/jfinal

public static <T> List<T> query(String configName, Connection conn, String sql, Object... paras) throws SQLException {
  return Db.query(DbKit.getConfig(configName), conn, sql, paras);
}

代码示例来源:origin: pkanyue/jboot-admin

@Override
  public int[] batchSave(List<RoleRes> list) {
    return  Db.batchSave(list, list.size());
  }
}

相关文章