From 7e2072df06a41e717264c621e58378ca3b399572 Mon Sep 17 00:00:00 2001 From: zhouxy108 Date: Fri, 9 May 2025 16:19:28 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E7=AE=80=E5=8C=96=E4=BB=A3?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: 周兴毅 Reviewed-on: http://zhouxy.xyz:3000/ZhouXY108/simple-jdbc/pulls/3 --- .../java/xyz/zhouxy/jdbc/ParamBuilder.java | 25 ++++++------------- .../jdbc/test/SimpleJdbcTemplateTests.java | 6 ++--- 2 files changed, 10 insertions(+), 21 deletions(-) diff --git a/src/main/java/xyz/zhouxy/jdbc/ParamBuilder.java b/src/main/java/xyz/zhouxy/jdbc/ParamBuilder.java index 29b4c14..5d0fded 100644 --- a/src/main/java/xyz/zhouxy/jdbc/ParamBuilder.java +++ b/src/main/java/xyz/zhouxy/jdbc/ParamBuilder.java @@ -26,6 +26,7 @@ import java.util.OptionalInt; import java.util.OptionalLong; import java.util.function.Function; import java.util.stream.Collectors; +import java.util.stream.Stream; import xyz.zhouxy.plusone.commons.collection.CollectionTools; import xyz.zhouxy.plusone.commons.util.ArrayTools; @@ -49,30 +50,18 @@ public class ParamBuilder { if (ArrayTools.isEmpty(params)) { return EMPTY_OBJECT_ARRAY; } - return Arrays.stream(params) - .map(param -> { - if (param instanceof Optional) { - return OptionalTools.orElseNull((Optional) param); - } - if (param instanceof OptionalInt) { - return OptionalTools.toInteger((OptionalInt) param); - } - if (param instanceof OptionalLong) { - return OptionalTools.toLong((OptionalLong) param); - } - if (param instanceof OptionalDouble) { - return OptionalTools.toDouble((OptionalDouble) param); - } - return param; - }) - .toArray(); + return buildParamsFromStream(Arrays.stream(params)); } public static Object[] buildParams(final Collection params) { if (CollectionTools.isEmpty(params)) { return EMPTY_OBJECT_ARRAY; } - return params.stream() + return buildParamsFromStream(params.stream()); + } + + private static Object[] buildParamsFromStream(Stream stream) { + return stream .map(param -> { if (param instanceof Optional) { return OptionalTools.orElseNull((Optional) param); diff --git a/src/test/java/xyz/zhouxy/jdbc/test/SimpleJdbcTemplateTests.java b/src/test/java/xyz/zhouxy/jdbc/test/SimpleJdbcTemplateTests.java index f318d49..703cf38 100644 --- a/src/test/java/xyz/zhouxy/jdbc/test/SimpleJdbcTemplateTests.java +++ b/src/test/java/xyz/zhouxy/jdbc/test/SimpleJdbcTemplateTests.java @@ -175,7 +175,7 @@ class SimpleJdbcTemplateTests { Optional> first = jdbcTemplate .queryFirst("SELECT * FROM sys_account WHERE id = ?", buildParams(id)); log.info("first: {}", first); - assertTrue(!first.isPresent()); + assertFalse(first.isPresent()); } // 没有异常,提交事务 @@ -208,7 +208,7 @@ class SimpleJdbcTemplateTests { Optional> first = jdbcTemplate .queryFirst("SELECT * FROM sys_account WHERE id = ?", buildParams(id)); log.info("first: {}", first); - assertTrue(!first.isPresent()); + assertFalse(first.isPresent()); } // 返回 false,回滚 @@ -223,7 +223,7 @@ class SimpleJdbcTemplateTests { Optional> first = jdbcTemplate .queryFirst("SELECT * FROM sys_account WHERE id = ?", buildParams(id)); log.info("first: {}", first); - assertTrue(!first.isPresent()); + assertFalse(first.isPresent()); } // 返回 true,提交事务