实现数据库异步化

lealone · Mar 17, 2016 · d294227 · d294227
1 parent ebd5344
commit d294227
Show file tree

Hide file tree

Showing 63 changed files with 2,262 additions and 988 deletions.
diff --git a/lealone-client/pom.xml b/lealone-client/pom.xml
@@ -31,7 +31,7 @@
     <dependencies>
         <dependency>
             <groupId>org.lealone</groupId>
-            <artifactId>lealone-common</artifactId>
+            <artifactId>lealone-net</artifactId>
             <version>${project.version}</version>
         </dependency>
     </dependencies>

diff --git a/lealone-client/src/main/java/org/lealone/client/ClientBatchCommand.java b/lealone-client/src/main/java/org/lealone/client/ClientBatchCommand.java
@@ -25,8 +25,8 @@
 import org.lealone.db.Command;
 import org.lealone.db.CommandParameter;
 import org.lealone.db.result.Result;
-import org.lealone.db.value.Transfer;
 import org.lealone.db.value.Value;
+import org.lealone.net.Transfer;
 
 public class ClientBatchCommand implements Command {
     private ClientSession session;
@@ -96,7 +96,7 @@ public int update() {
                 transfer.writeInt(size);
                 for (int i = 0; i < size; i++)
                     transfer.writeString(batchCommands.get(i));
-                session.done(transfer);
+                transfer.flush();
 
                 for (int i = 0; i < size; i++)
                     result[i] = transfer.readInt();
@@ -114,7 +114,7 @@ public int update() {
                     for (int m = 0; m < len; m++)
                         transfer.writeValue(values[m]);
                 }
-                session.done(transfer);
+                transfer.flush();
 
                 for (int i = 0; i < size; i++)
                     result[i] = transfer.readInt();
@@ -159,4 +159,13 @@ public Result getMetaData() {
     public int[] getResult() {
         return result;
     }
+
+    @Override
+    public Command prepare() {
+        return this;
+    }
+
+    @Override
+    public void setConnectionId(int connectionId) {
+    }
 }