fix 300.2.3

Author: dolphindb-jffu

src/BasicDBTask.cs

@@ -0,0 +1,103 @@
+//-------------------------------------------------------------------------------------------
+//	Copyright © 2021 DolphinDB Inc.
+//	Date   : 2021.01.21
+//  Author : zhikun.luo
+//-------------------------------------------------------------------------------------------
+
+using dolphindb.data;
+using System.Collections.Generic;
+using System;
+using System.Threading;
+using dolphindb.io;
+
+namespace dolphindb
+{
+    public class BasicDBTask:IDBTask
+    {
+        private IEntity result = null;
+        private string errMsg = null;
+        private bool successful = false;
+        private string script;
+        private List<IEntity> args;
+        private bool clearMemory_;
+        private int priority_;
+        private int parallelism_;
+        private DBConnection conn;
+        private WaitHandle waitHandle = new AutoResetEvent(false);
+        private Semaphore semaphore = new Semaphore(1,1);
+
+        public void waitFor()
+        {
+            semaphore.WaitOne();
+        }
+        public void finish()
+        {
+            semaphore.Release();
+        }
+        public BasicDBTask(string script, List<IEntity> args, int priority = 4, int parallelism = 64, bool clearMemory = false)
+        {
+            semaphore.WaitOne();
+            this.script = script;
+            this.args = args;
+            this.clearMemory_ = clearMemory;
+            this.priority_ = priority;
+            this.parallelism_ = parallelism;
+        }
+        public BasicDBTask(string script, int priority = 4, int parallelism = 64, bool clearMemory = false)
+        {
+            semaphore.WaitOne();
+            this.script = script;
+            this.clearMemory_ = clearMemory;
+            this.priority_ = priority;
+            this.parallelism_ = parallelism;
+        }
+        public IEntity call()
+        {
+            try
+            {
+                if (args != null)
+                    result = conn.run(script, args, priority_, parallelism_, 0, clearMemory_);
+                else
+                    result = conn.run(script, priority_, parallelism_, 0, clearMemory_);
+                errMsg = null;
+                successful = true;
+                return result;
+            }
+            catch(Exception t)
+            {
+                successful = false;
+                result = null;
+                errMsg = t.Message;
+                return null;
+            }
+        }
+        public void setDBConnection(DBConnection conn)
+        {
+            this.conn = conn;
+        }
+        public IEntity getResults()
+        {
+            return result;
+        }
+        public string getErrorMsg()
+        {
+            return errMsg;
+        }
+        public bool isSuccessful()
+        {
+            return successful;
+        }
+
+        public bool isFinished()
+        {
+            if(successful || errMsg != null)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
+    }
+}

src/EntityBlockReader.cs

@@ -0,0 +1,168 @@
+                                                                                                                                                                                                                                        //-------------------------------------------------------------------------------------------
+//	Copyright © 2021 DolphinDB Inc.
+//	Date   : 2021.01.15
+//  Author : zhikun.luo
+//-------------------------------------------------------------------------------------------
+
+
+using System;
+using dolphindb.io;
+using dolphindb.data;
+using System.Data;
+
+namespace dolphindb
+{
+    public class EntityBlockReader:IEntity
+    {
+        private IEntity currentValue;
+        private int size;
+        private int currentIndex = 0;
+        private ExtendedDataInput instream;
+
+        public EntityBlockReader(ExtendedDataInput input) 
+        {
+            int rows = input.readInt();
+            int cols = input.readInt();
+            size = rows * cols;
+            currentIndex = 0;
+            instream = input;
+        }
+
+        public object getObject() 
+        {
+            BasicEntityFactory factory = new BasicEntityFactory();
+            if (currentIndex>=size) return null;
+
+            short flag = instream.readShort();
+            int form = flag >> 8;
+            int type = flag & 0xff;
+            bool extended = type >= 128;
+            if (type >= 128)
+                type -= 128;
+            currentValue = factory.createEntity((DATA_FORM)form, (DATA_TYPE)type, instream, extended);
+            currentIndex++;
+            return currentValue;
+        }
+
+        public void skipAll()
+        {
+             BasicEntityFactory factory = new BasicEntityFactory();
+             for (int i = currentIndex; i < size; i++)
+             {
+                 short flag = instream.readShort();
+                 int form = flag >> 8;
+                 int type = flag & 0xff;
+                bool extended = type >= 128;
+                if (type >= 128)
+                    type -= 128;
+                currentValue = factory.createEntity((DATA_FORM)form, (DATA_TYPE)type, instream, extended);
+                 currentIndex++;
+             }
+        }
+
+        public DataTable toDataTable()
+        {
+            throw new NotImplementedException();
+        }
+        public Boolean hasNext()
+{
+    return currentIndex < size;
+}
+
+
+    public DATA_FORM getDataForm()
+{
+    return DATA_FORM.DF_TABLE;
+}
+
+
+    public DATA_CATEGORY getDataCategory()
+{
+    return DATA_CATEGORY.MIXED;
+}
+
+
+    public DATA_TYPE getDataType()
+{
+    return DATA_TYPE.DT_ANY;
+}
+
+
+    public int rows()
+{
+    return 0;
+}
+
+
+    public int columns()
+{
+    return 0;
+}
+
+
+    public String getString()
+{
+    return null;
+}
+
+
+    public void write(ExtendedDataOutput output)
+{
+
+}
+
+
+    public bool isScalar()
+{
+    return false;
+}
+
+
+    public bool isVector()
+{
+    return false;
+}
+
+
+    public bool isPair()
+{
+    return false;
+}
+
+
+    public bool isTable()
+{
+    return true;
+}
+
+
+    public bool isMatrix()
+{
+    return false;
+}
+
+
+    public bool isDictionary()
+{
+    return false;
+}
+
+
+    public bool isChart()
+{
+    return false;
+}
+
+
+    public bool isChunk()
+{
+    return false;
+}
+
+        public void writeCompressed(ExtendedDataOutput output)
+        {
+            throw new NotImplementedException();
+        }
+    }
+
+}