diff --git a/src/main/java/mpms/service/h2db/BaseDbCommonService.java b/src/main/java/mpms/service/h2db/BaseDbCommonService.java index f683124e947a828d4b789802b495e337eca188c5..620c62b059001602a64ab679bb65a9fb3f5a6be0 100644 --- a/src/main/java/mpms/service/h2db/BaseDbCommonService.java +++ b/src/main/java/mpms/service/h2db/BaseDbCommonService.java @@ -73,4 +73,41 @@ public abstract class BaseDbCommonService { protected String getKey() { return key; } + + /** + * 插入数据 + * + * @param t 数据 + */ + public void insert(T t) { + Db db = Db.use(); + db.setWrapper((Character) null); + try { + Entity entity = this.dataBeanToEntity(t); + db.insert(entity); + } catch (SQLException e) { + throw new LinuxRuntimeException("数据库异常", e); + } + } + + /** + * 插入数据 + * + * @param t 数据 + */ + public void insert(Collection t) { + if (!DbConfig.getInstance().isInit() || CollUtil.isEmpty(t)) { + // ignore + return; + } + Db db = Db.use(); + db.setWrapper((Character) null); + try { + List entities = t.stream().map(this::dataBeanToEntity).collect(Collectors.toList()); + db.insert(entities); + } catch (SQLException e) { + throw new LinuxRuntimeException("数据库异常", e); + } + } + }