From a33f5dcd6f439e2ea3784ea71a182790a056f649 Mon Sep 17 00:00:00 2001 From: redkale Date: Tue, 20 Aug 2024 22:43:50 +0800 Subject: [PATCH] AsyncConnection --- .../java/org/redkale/net/AsyncConnection.java | 22 +++++++++++++-- .../redkale/source/AbstractDataSqlSource.java | 28 +++++++++---------- 2 files changed, 34 insertions(+), 16 deletions(-) diff --git a/src/main/java/org/redkale/net/AsyncConnection.java b/src/main/java/org/redkale/net/AsyncConnection.java index a2b94ceb6..b5cc4dad3 100644 --- a/src/main/java/org/redkale/net/AsyncConnection.java +++ b/src/main/java/org/redkale/net/AsyncConnection.java @@ -224,10 +224,28 @@ public abstract class AsyncConnection implements Channel, AutoCloseable { protected abstract void readImpl(CompletionHandler handler); - // src写完才会回调 + /** + * src写完才会回调 + * + * @see org.redkale.net.AsyncNioConnection#writeImpl(java.nio.ByteBuffer, java.lang.Object, java.nio.channels.CompletionHandler) + * @param A + * @param src ByteBuffer + * @param attachment A + * @param handler CompletionHandler + */ protected abstract void writeImpl(ByteBuffer src, A attachment, CompletionHandler handler); - // srcs写完才会回调 + /** + * srcs写完才会回调 + * + * @see org.redkale.net.AsyncNioConnection#writeImpl(java.nio.ByteBuffer[], int, int, java.lang.Object, java.nio.channels.CompletionHandler) + * @param A + * @param srcs ByteBuffer[] + * @param offset offset + * @param length length + * @param attachment A + * @param handler CompletionHandler + */ protected abstract void writeImpl( ByteBuffer[] srcs, int offset, int length, A attachment, CompletionHandler handler); diff --git a/src/main/java/org/redkale/source/AbstractDataSqlSource.java b/src/main/java/org/redkale/source/AbstractDataSqlSource.java index 79f0ccf44..e26f628a3 100644 --- a/src/main/java/org/redkale/source/AbstractDataSqlSource.java +++ b/src/main/java/org/redkale/source/AbstractDataSqlSource.java @@ -1289,7 +1289,7 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource .toString(); } return String.valueOf(value); - } else if (value != null && value instanceof CharSequence && "postgresql".equals(dbtype)) { + } else if (value instanceof CharSequence && "postgresql".equals(dbtype)) { String s = String.valueOf(value); int pos = s.indexOf('\''); if (pos >= 0) { @@ -1564,7 +1564,7 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource protected String[] deleteSql( final EntityInfo info, String[] tables, final Flipper flipper, final FilterNode node) { - Map joinTabalis = null; + Map joinTabalis; CharSequence join = null; CharSequence where = null; if (node != null) { @@ -3003,24 +3003,24 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource final FilterNode node) { final StringBuilder groupBySqlColumns = new StringBuilder(); if (groupByColumns != null && groupByColumns.length > 0) { - for (int i = 0; i < groupByColumns.length; i++) { + for (String groupByColumn : groupByColumns) { if (groupBySqlColumns.length() > 0) { groupBySqlColumns.append(", "); } - groupBySqlColumns.append(info.getSQLColumn("a", groupByColumns[i])); + groupBySqlColumns.append(info.getSQLColumn("a", groupByColumn)); } } final StringBuilder funcSqlColumns = new StringBuilder(); - for (int i = 0; i < funcNodes.length; i++) { + for (ColumnNode funcNode : funcNodes) { if (funcSqlColumns.length() > 0) { funcSqlColumns.append(", "); } - if (funcNodes[i] instanceof ColumnFuncNode) { + if (funcNode instanceof ColumnFuncNode) { funcSqlColumns.append(info.formatColumnFuncNodeSQLValue( - (Attribute) null, "a", (ColumnFuncNode) funcNodes[i], sqlFormatter)); + (Attribute) null, "a", (ColumnFuncNode) funcNode, sqlFormatter)); } else { funcSqlColumns.append(info.formatColumnExpNodeSQLValue( - (Attribute) null, "a", (ColumnExpNode) funcNodes[i], sqlFormatter)); + (Attribute) null, "a", (ColumnExpNode) funcNode, sqlFormatter)); } } final Map joinTabalis = node == null ? null : node.getJoinTabalis(); @@ -3786,7 +3786,7 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource final Class clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) { if (isAsync()) { return querySheetAsync(true, false, true, clazz, selects, flipper, node) - .thenApply((rs) -> new LinkedHashSet<>(rs.list(true))) + .thenApply(rs -> new LinkedHashSet<>(rs.list(true))) .join(); } else { return new LinkedHashSet<>( @@ -3799,10 +3799,10 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource final Class clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) { if (isAsync()) { return querySheetAsync(true, false, true, clazz, selects, flipper, node) - .thenApply((rs) -> new LinkedHashSet<>(rs.list(true))); + .thenApply(rs -> new LinkedHashSet<>(rs.list(true))); } else { return supplyAsync(() -> querySheet(true, false, true, clazz, selects, flipper, node)) - .thenApply((rs) -> new LinkedHashSet<>(rs.list(true))); + .thenApply(rs -> new LinkedHashSet<>(rs.list(true))); } } @@ -3811,7 +3811,7 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource final Class clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) { if (isAsync()) { return querySheetAsync(true, false, false, clazz, selects, flipper, node) - .thenApply((rs) -> rs.list(true)) + .thenApply(rs -> rs.list(true)) .join(); } else { return querySheet(true, false, false, clazz, selects, flipper, node).list(true); @@ -3823,10 +3823,10 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource final Class clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) { if (isAsync()) { return querySheetAsync(true, false, false, clazz, selects, flipper, node) - .thenApply((rs) -> rs.list(true)); + .thenApply(rs -> rs.list(true)); } else { return supplyAsync(() -> querySheet(true, false, false, clazz, selects, flipper, node)) - .thenApply((rs) -> rs.list(true)); + .thenApply(rs -> rs.list(true)); } }