From dba971f0cacd9f699798d1eeff336e3d6fad38a3 Mon Sep 17 00:00:00 2001 From: xyli Date: Mon, 13 Feb 2023 11:26:59 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E4=BF=AE=E6=94=B9BaseDbCommonService.java?= =?UTF-8?q?=E6=96=87=E4=BB=B6=EF=BC=8C=E6=B7=BB=E5=8A=A0insert=E6=96=B9?= =?UTF-8?q?=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mpms/service/h2db/BaseDbCommonService.java | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/src/main/java/mpms/service/h2db/BaseDbCommonService.java b/src/main/java/mpms/service/h2db/BaseDbCommonService.java index f683124..02ed587 100644 --- a/src/main/java/mpms/service/h2db/BaseDbCommonService.java +++ b/src/main/java/mpms/service/h2db/BaseDbCommonService.java @@ -73,4 +73,20 @@ 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); + } + } } -- Gitee From 2be08a749dd861e2b067101dffa2535b1b1763d9 Mon Sep 17 00:00:00 2001 From: xyli Date: Mon, 13 Feb 2023 11:30:21 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E4=BF=AE=E6=94=B9BaseDbCommonService.java?= =?UTF-8?q?=E6=96=87=E4=BB=B6=EF=BC=8C=E6=B7=BB=E5=8A=A0insert=E7=9A=84?= =?UTF-8?q?=E9=87=8D=E8=BD=BD=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/h2db/BaseDbCommonService.java | 21 +++++++++++++++++++ 1 file changed, 21 insertions(+) diff --git a/src/main/java/mpms/service/h2db/BaseDbCommonService.java b/src/main/java/mpms/service/h2db/BaseDbCommonService.java index 02ed587..620c62b 100644 --- a/src/main/java/mpms/service/h2db/BaseDbCommonService.java +++ b/src/main/java/mpms/service/h2db/BaseDbCommonService.java @@ -89,4 +89,25 @@ public abstract class BaseDbCommonService { 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); + } + } + } -- Gitee