From 3bd880b0617ad15c119fadb1c23beefa399ca0a5 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Thu, 23 Feb 2017 15:29:04 +0800
Subject: [PATCH]
---
.../redkale/convert/bson/BsonByteBufferWriter.java | 14 ++++----------
.../redkale/convert/json/JsonByteBufferWriter.java | 10 ++--------
src/org/redkale/source/FilterJoinNode.java | 7 ++-----
src/org/redkale/source/FilterNode.java | 7 ++-----
src/org/redkale/source/FilterNodeBean.java | 7 ++-----
src/org/redkale/util/AnyValue.java | 13 ++-----------
test/org/redkale/test/rest/HelloService2.java | 2 +-
7 files changed, 15 insertions(+), 45 deletions(-)
diff --git a/src/org/redkale/convert/bson/BsonByteBufferWriter.java b/src/org/redkale/convert/bson/BsonByteBufferWriter.java
index 7807c098a..e0dbca8c8 100644
--- a/src/org/redkale/convert/bson/BsonByteBufferWriter.java
+++ b/src/org/redkale/convert/bson/BsonByteBufferWriter.java
@@ -7,6 +7,7 @@ package org.redkale.convert.bson;
import java.nio.*;
import java.util.function.*;
+import org.redkale.util.Utility;
/**
*
@@ -77,21 +78,14 @@ public class BsonByteBufferWriter extends BsonWriter {
ByteBuffer buffer = this.buffers[index];
if (!buffer.hasRemaining()) {
buffer.flip();
- buffer = supplier.get();
- ByteBuffer[] bufs = new ByteBuffer[this.buffers.length + 1];
- System.arraycopy(this.buffers, 0, bufs, 0, this.buffers.length);
- bufs[this.buffers.length] = buffer;
- this.buffers = bufs;
+ buffer = supplier.get();
+ this.buffers = Utility.append(this.buffers, buffer);
this.index++;
}
int len = buffer.remaining();
int size = 0;
while (len < byteLength) {
- buffer = supplier.get();
- ByteBuffer[] bufs = new ByteBuffer[this.buffers.length + 1];
- System.arraycopy(this.buffers, 0, bufs, 0, this.buffers.length);
- bufs[this.buffers.length] = buffer;
- this.buffers = bufs;
+ this.buffers = Utility.append(this.buffers, buffer);
len += buffer.remaining();
size++;
}
diff --git a/src/org/redkale/convert/json/JsonByteBufferWriter.java b/src/org/redkale/convert/json/JsonByteBufferWriter.java
index 16b795ed7..89f8f8be8 100644
--- a/src/org/redkale/convert/json/JsonByteBufferWriter.java
+++ b/src/org/redkale/convert/json/JsonByteBufferWriter.java
@@ -84,20 +84,14 @@ public class JsonByteBufferWriter extends JsonWriter {
if (!buffer.hasRemaining()) {
buffer.flip();
buffer = supplier.get();
- ByteBuffer[] bufs = new ByteBuffer[this.buffers.length + 1];
- System.arraycopy(this.buffers, 0, bufs, 0, this.buffers.length);
- bufs[this.buffers.length] = buffer;
- this.buffers = bufs;
+ this.buffers = Utility.append(this.buffers, buffer);
this.index++;
}
int len = buffer.remaining();
int size = 0;
while (len < byteLength) {
buffer = supplier.get();
- ByteBuffer[] bufs = new ByteBuffer[this.buffers.length + 1];
- System.arraycopy(this.buffers, 0, bufs, 0, this.buffers.length);
- bufs[this.buffers.length] = buffer;
- this.buffers = bufs;
+ this.buffers = Utility.append(this.buffers, buffer);
len += buffer.remaining();
size++;
}
diff --git a/src/org/redkale/source/FilterJoinNode.java b/src/org/redkale/source/FilterJoinNode.java
index 71c63f3d9..c8bfee478 100644
--- a/src/org/redkale/source/FilterJoinNode.java
+++ b/src/org/redkale/source/FilterJoinNode.java
@@ -10,7 +10,7 @@ import java.util.*;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.function.*;
import static org.redkale.source.FilterExpress.EQUAL;
-import org.redkale.util.Attribute;
+import org.redkale.util.*;
/**
*
@@ -94,10 +94,7 @@ public class FilterJoinNode extends FilterNode {
return this;
}
if (or == signor || this.column == null) {
- FilterNode[] newsiblings = new FilterNode[nodes.length + 1];
- System.arraycopy(nodes, 0, newsiblings, 0, nodes.length);
- newsiblings[nodes.length] = node;
- this.nodes = newsiblings;
+ this.nodes = Utility.append(this.nodes, node);
if (this.column == null) this.or = signor;
return this;
}
diff --git a/src/org/redkale/source/FilterNode.java b/src/org/redkale/source/FilterNode.java
index 867ddaa83..ce174bbb7 100644
--- a/src/org/redkale/source/FilterNode.java
+++ b/src/org/redkale/source/FilterNode.java
@@ -10,7 +10,7 @@ import java.lang.reflect.Array;
import java.util.*;
import java.util.function.*;
import static org.redkale.source.FilterExpress.*;
-import org.redkale.util.Attribute;
+import org.redkale.util.*;
/**
* 注意:
@@ -150,10 +150,7 @@ public class FilterNode { //FilterNode 不能实现Serializable接口, 否则
return this;
}
if (or == signor) {
- FilterNode[] newsiblings = new FilterNode[nodes.length + 1];
- System.arraycopy(nodes, 0, newsiblings, 0, nodes.length);
- newsiblings[nodes.length] = node;
- this.nodes = newsiblings;
+ this.nodes = Utility.append(this.nodes, node);
return this;
}
FilterNode newnode = new FilterNode(this.column, this.express, this.itemand, this.value);
diff --git a/src/org/redkale/source/FilterNodeBean.java b/src/org/redkale/source/FilterNodeBean.java
index f29ecea76..1b2498c87 100644
--- a/src/org/redkale/source/FilterNodeBean.java
+++ b/src/org/redkale/source/FilterNodeBean.java
@@ -11,7 +11,7 @@ import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import javax.persistence.Transient;
import static org.redkale.source.FilterExpress.*;
-import org.redkale.util.Attribute;
+import org.redkale.util.*;
/**
*
@@ -117,10 +117,7 @@ public final class FilterNodeBean implements Comparable