* db: support postgres enum type

Signed-off-by: neo <1100909+neowu@users.noreply.github.com>

Author: neowu

CHANGELOG.md

@@ -1,5 +1,9 @@
 ## Change log
 
+### 9.2.3 (7/2/2025 - )
+
+* db: support postgres enum type
+
 ### 9.2.2 (5/21/2025 - 6/26/2025)
 
 * http_client: support proxy

build.gradle.kts

@@ -7,7 +7,7 @@ apply(plugin = "project")
 
 subprojects {
     group = "core.framework"
-    version = "9.2.2"
+    version = "9.2.3"
     repositories {
         maven {
             url = uri("https://neowu.github.io/maven-repo/")

core-ng/src/main/java/core/framework/internal/db/DatabaseImpl.java

@@ -314,6 +314,8 @@ void track(long elapsed, int readRows, int writeRows, int queries) {
     }
 
     void validateSQL(String sql) {
+        if (sql.startsWith("CREATE ")) return;  // ignore DDL
+
         // validate asterisk
         // execute() could have select part, e.g. insert into select
         int index = sql.indexOf('*');

core-ng/src/main/java/core/framework/internal/db/DatabaseOperation.java

@@ -217,7 +217,13 @@ private void setParams(PreparedStatement statement, Object... params) throws SQL
     private void setParam(PreparedStatement statement, int index, Object param) throws SQLException {
         switch (param) {
             case String value -> statement.setString(index, value);
-            case Enum<?> value -> statement.setString(index, enumMapper.getDBValue(value));
+            case Enum<?> value -> {
+                if (dialect == Dialect.POSTGRESQL) {
+                    statement.setObject(index, enumMapper.getDBValue(value), Types.OTHER);
+                } else {
+                    statement.setString(index, enumMapper.getDBValue(value));
+                }
+            }
             case LocalDate value -> statement.setObject(index, value, Types.DATE);
             case LocalDateTime value -> statement.setObject(index, value, Types.TIMESTAMP);
             case ZonedDateTime value -> {

core-ng/src/test/java/core/framework/internal/db/DatabaseImplTest.java

@@ -127,6 +127,12 @@ void validateSQL() {
             .hasMessageContaining("sql must not contain single quote(')");
     }
 
+    @Test
+    void validateSQLWithDDL() {
+        database.validateSQL("""
+            CREATE TYPE status AS ENUM ('ACTIVE', 'INACTIVE')""");
+    }
+
     @Test
     void validateSQLWithAsterisk() {
         database.validateSQL("select column * 10 from table");