Skip to content

Commit 4a19161

Browse files
committed
Merge remote-tracking branch 'origin/master' into 4.2
# Conflicts: # hsweb-easy-orm-rdb/src/test/resources/logback.xml
2 parents 524ed01 + 27e2abc commit 4a19161

File tree

7 files changed

+56
-16
lines changed

7 files changed

+56
-16
lines changed
Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
<?xml version="1.0" encoding="utf-8" ?>
2+
<configuration>
3+
<logger name="io.netty" level="warn"/>
4+
<logger name="io.r2dbc" level="warn"/>
5+
<logger name="reactor" level="warn"/>
6+
<logger name="com.github" level="warn"/>
7+
<logger name="dev.miku" level="warn"/>
8+
<logger name="org.testcontainers" level="info"/>
9+
<logger name="org.hswebframework" level="debug"/>
10+
<logger name="org.hswebframework.ezorm" level="info"/>
11+
<logger name="org.apache" level="info"/>
12+
13+
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
14+
<encoder>
15+
         
16+
<pattern>%-4relative [%thread] %-5level %logger{35} - %msg %n</pattern>
17+
     
18+
</encoder>
19+
</appender>
20+
21+
<root level="debug">
22+
 
23+
<appender-ref ref="STDOUT"/>
24+
</root>
25+
</configuration>

hsweb-easy-orm-rdb/src/main/java/org/hswebframework/ezorm/rdb/executor/jdbc/JdbcSqlExecutor.java

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,9 @@ protected int doUpdate(Logger logger, Connection connection, SqlRequest request)
6161
}
6262
}
6363
return count;
64+
}catch (Throwable e) {
65+
logger.error("==> Error: {}", request.toNativeSql(), e);
66+
throw e;
6467
} finally {
6568
if (null != statement) {
6669
releaseStatement(statement);
@@ -96,6 +99,9 @@ protected void doExecute(Logger logger, Connection connection, SqlRequest reques
9699
}
97100
}
98101
}
102+
} catch (Throwable e) {
103+
logger.error("==> Error: {}", request.toNativeSql(), e);
104+
throw e;
99105
} finally {
100106
if (null != statement) {
101107
releaseStatement(statement);
@@ -151,7 +157,7 @@ protected <T, R> R doSelect(Logger logger,
151157

152158
Disposable disposable = () -> {
153159
try {
154-
if(logger.isDebugEnabled()) {
160+
if (logger.isDebugEnabled()) {
155161
logger.debug("==> Cancel: {}", request.toNativeSql());
156162
}
157163
releaseStatement(statement);
@@ -190,6 +196,9 @@ protected <T, R> R doSelect(Logger logger,
190196
logger.debug("==> Results: {}", index);
191197
releaseResultSet(resultSet);
192198
return wrapper.getResult();
199+
} catch (Throwable e) {
200+
logger.error("==> Error: {}", request.toNativeSql(), e);
201+
throw e;
193202
} finally {
194203
releaseStatement(statement);
195204
}

hsweb-easy-orm-rdb/src/main/java/org/hswebframework/ezorm/rdb/mapping/defaults/DefaultRepository.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -184,11 +184,11 @@ protected InsertResultOperator doInsert(E data) {
184184

185185
return EventResultOperator.create(
186186
() -> {
187-
for (Map.Entry<String, String> entry : mapping.getColumnPropertyMapping().entrySet()) {
188-
String column = entry.getKey();
189-
String property = entry.getValue();
190-
insert.value(column, getInsertColumnValue(data, property));
191-
}
187+
insert.columns(getProperties());
188+
insert.values(Stream
189+
.of(getProperties())
190+
.map(property -> getInsertColumnValue(data, property))
191+
.toArray());
192192
return insert.execute();
193193
},
194194
InsertResultOperator.class,

hsweb-easy-orm-rdb/src/main/java/org/hswebframework/ezorm/rdb/mapping/defaults/DefaultSyncRepository.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ public void insert(E data) {
8686

8787
@Override
8888
public int insertBatch(Collection<E> batch) {
89-
if (batch.size() == 0) {
89+
if (batch.isEmpty()) {
9090
return 0;
9191
}
9292
return doInsert(batch).sync();

hsweb-easy-orm-rdb/src/main/java/org/hswebframework/ezorm/rdb/metadata/AbstractTableOrViewMetadata.java

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,10 @@ public void removeColumn(String name) {
130130
if (metadata != null) {
131131
allColumns.remove(metadata.getAlias());
132132
}
133+
metadata = allColumns.remove(name.toUpperCase());
134+
if (metadata != null) {
135+
allColumns.remove(metadata.getAlias());
136+
}
133137
}
134138

135139
@Override
@@ -142,6 +146,9 @@ public RDBSchemaMetadata getSchema() {
142146
public void addColumn(RDBColumnMetadata column) {
143147
columnCache = null;
144148
column.setOwner(this);
149+
if (getDialect().isColumnToUpperCase()) {
150+
allColumns.put(column.getName().toUpperCase(), column);
151+
}
145152
allColumns.put(column.getName(), column);
146153
allColumns.put(column.getAlias(), column);
147154
allColumns.put(column.getRealName(), column);
@@ -196,7 +203,7 @@ public Optional<RDBColumnMetadata> findColumn(String name) {
196203
}
197204
Optional<RDBColumnMetadata> col = this.getColumn(name);
198205

199-
if(col.isPresent()){
206+
if (col.isPresent()) {
200207
return col;
201208
}
202209

@@ -210,7 +217,7 @@ private Optional<RDBColumnMetadata> findNestColumn(String name) {
210217
}
211218

212219
if (name.contains(".")) {
213-
String[] arr = StringUtils.getPlainName(StringUtils.split(name,'.'));
220+
String[] arr = StringUtils.getPlainName(StringUtils.split(name, '.'));
214221
if (arr.length == 2) { //table.name
215222
return findColumnFromSchema(schema, arr[0], arr[1]);
216223

@@ -241,11 +248,11 @@ private Optional<RDBColumnMetadata> findColumnFromSchema(RDBSchemaMetadata schem
241248
Optional<RDBColumnMetadata> col =
242249
schema.getTableOrView(tableName)
243250
.flatMap(meta -> meta.getColumn(column));
244-
if(col.isPresent()){
251+
if (col.isPresent()) {
245252
return col;
246253
}
247254
return getForeignKey(tableName) //查找外键关联信息
248-
.flatMap(key -> key.getTarget().getColumn(column));
255+
.flatMap(key -> key.getTarget().getColumn(column));
249256

250257
}
251258

hsweb-easy-orm-rdb/src/test/resources/logback.xml

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,12 +4,11 @@
44
<logger name="io.r2dbc" level="warn"/>
55
<logger name="reactor" level="warn"/>
66
<logger name="com.github" level="warn"/>
7-
<logger name="dev.miku" level="warn"/>
7+
<logger name="io.asyncer" level="warn"/>
88
<logger name="org.testcontainers" level="info"/>
99
<logger name="org.hswebframework" level="debug"/>
10-
<logger name="org.hswebframework.ezorm" level="info"/>
11-
<logger name="org.apache.commons" level="warn"/>
12-
<logger name="io.asyncer" level="warn"/>
10+
<logger name="org.hswebframework.ezorm" level="debug"/>
11+
<logger name="org.apache" level="info"/>
1312

1413
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
1514
<encoder>

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -256,7 +256,7 @@
256256
<dependency>
257257
<groupId>org.apache.commons</groupId>
258258
<artifactId>commons-lang3</artifactId>
259-
<version>3.14.0</version>
259+
<version>3.18.0</version>
260260
</dependency>
261261

262262
<!-- <dependency>-->

0 commit comments

Comments
 (0)