update src with build date 2022.05.20

Author: tradercjz

README.md

@@ -60,8 +60,6 @@ To run DolphinDB script in C#:
 conn.run("<SCRIPT>");
 ```
 
-Note that the maximum allowed length of the script is 65,535 bytes.
-
 If the script contains only one statement, such as an expression, DolphinDB returns the result of the statement. If the script contains more than one statement, the result of the last statement will be returned. If the script contains an error or there is a network problem, it throws an IOException.
 
 ### 4. Call DolphinDB functions
@@ -245,7 +243,7 @@ public void test_save_TableInsert(string[] strArray, int[] intArray, long[] tsAr
 }
 ```
 
-The example above uses partial application in DolphinDB to embed a table in `tableInsert{sharedTable}` as a function. For details about partial application, please refer to [Partial Application Documentation](https://www.dolphindb.com/help/PartialApplication.html).
+The example above uses partial application in DolphinDB to embed a table in `tableInsert{sharedTable}` as a function. For details about partial application, please refer to [Partial Application Documentation](https://www.dolphindb.com/help/Functionalprogramming/PartialApplication.html).
 
 ##### 7.1.3 Use function `tableInsert` to save a table object
 ```
@@ -344,7 +342,7 @@ C# API provides objects that correspond to DolphinDB data types. They are usuall
 The majority of DolphinDB data types can be constructed from corresponding C# data types. For examples, INT in DolphinDB from 'new BasicInt(4)', DOUBLE in DolphinDB from 'new BasicDouble(1.23)'. The following DolphinDB data types, however, need to be constructed in different ways: 
 - CHAR type: as the CHAR type in DolphinDB is stored as a byte, we can use the BasicByte type to construct CHAR in C# API, for example 'new BasicByte((byte)'c')'.
 - SYMBOL type: the SYMBOL type in DolphinDB is stored as INT to improve the efficiency of storage and query of strings. C# doesn't have this data type, so C# API does not provide BasicSymbol. SYMBOL type can be processed directly with BasicString. 
-- Temporal types: temporal data types are stored as INT or LONG in DolphinDB. DolphinDB provides 9 temporal data types: date, month, time, minute, second, datetime, timestamp, nanotime and nanotimestamp. For detailed description, please refer to [DolphinDB Temporal Type and Conversion] (https://www.dolphindb.com/help/TemporalTypeandConversion.html). Since C# also provides data types such as LocalDate, LocalTime, LocalDateTime and YearMonth, C# API provides conversion functions in the Utils class between all C# temporal types and INT or LONG.
+- Temporal types: temporal data types are stored as INT or LONG in DolphinDB. DolphinDB provides 9 temporal data types: date, month, time, minute, second, datetime, timestamp, nanotime and nanotimestamp. For detailed description, please refer to [DolphinDB Temporal Type and Conversion](https://www.dolphindb.com/help/DataManipulation/TemporalObjects/TemporalTypeandConversion.html). Since C# also provides data types such as LocalDate, LocalTime, LocalDateTime and YearMonth, C# API provides conversion functions in the Utils class between all C# temporal types and INT or LONG.
 
 The following script shows the correspondence between DolphinDB temporal types and C# native temporal types:
 

README_CN.md

@@ -3,9 +3,11 @@ Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio 15
 VisualStudioVersion = 15.0.26430.15
 MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "dolphindb_csharpapi", "dolphindb_csharpapi\dolphindb_csharpapi.csproj", "{F744DA92-D9F2-49BB-9783-F89E825CB307}"
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "dolphindb_csharpapi", "src\dolphindb_csharpapi.csproj", "{F744DA92-D9F2-49BB-9783-F89E825CB307}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "dolphindb_csharpapi_test", "dolphindb_csharpapi_test\dolphindb_csharpapi_test.csproj", "{9297EF6F-E380-423B-BA64-FE2907226FF8}"
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "dolphindb_csharpapi_test", "test\dolphindb_csharpapi_test.csproj", "{9297EF6F-E380-423B-BA64-FE2907226FF8}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "longTimeTask", "longTimeTask\longTimeTask.csproj", "{AA834560-396D-42E6-9D5D-9DE41AA1482F}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -41,8 +43,23 @@ Global
 		{9297EF6F-E380-423B-BA64-FE2907226FF8}.Release|x64.Build.0 = Release|Any CPU
 		{9297EF6F-E380-423B-BA64-FE2907226FF8}.Release|x86.ActiveCfg = Release|Any CPU
 		{9297EF6F-E380-423B-BA64-FE2907226FF8}.Release|x86.Build.0 = Release|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Debug|x64.Build.0 = Debug|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Debug|x86.Build.0 = Debug|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Release|Any CPU.Build.0 = Release|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Release|x64.ActiveCfg = Release|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Release|x64.Build.0 = Release|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Release|x86.ActiveCfg = Release|Any CPU
+		{AA834560-396D-42E6-9D5D-9DE41AA1482F}.Release|x86.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
 	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {BD8FB1DE-3841-4F68-A643-A686A14E10BC}
+	EndGlobalSection
 EndGlobal

bin/dolphindb_csharpapi.dll

@@ -0,0 +1,171 @@
+using dolphindb;
+using dolphindb.data;
+using System;
+using System.Collections.Generic;
+using System.IO;
+
+public class DFSTableWriting
+{
+    private static DBConnection conn;
+    public static string HOST = "localhost";
+    public static int PORT = 8848;
+
+    private BasicTable createBasicTable()
+    {
+        List<string> colNames = new List<string>();
+        colNames.Add("cbool");
+        colNames.Add("cchar");
+        colNames.Add("cshort");
+        colNames.Add("cint");
+        colNames.Add("clong");
+        colNames.Add("cdate");
+        colNames.Add("cmonth");
+        colNames.Add("ctime");
+        colNames.Add("cminute");
+        colNames.Add("csecond");
+        colNames.Add("cdatetime");
+        colNames.Add("ctimestamp");
+        colNames.Add("cnanotime");
+        colNames.Add("cnanotimestamp");
+        colNames.Add("cfloat");
+        colNames.Add("cdouble");
+        colNames.Add("csymbol");
+        colNames.Add("cstring");
+        List<IVector> cols = new List<IVector>();
+
+
+        //boolean
+        byte[] vbool = new byte[] { 1, 0 };
+        BasicBooleanVector bbv = new BasicBooleanVector(vbool);
+        cols.Add(bbv);
+        //char
+        byte[] vchar = new byte[] { (byte)'c', (byte)'a' };
+        BasicByteVector bcv = new BasicByteVector(vchar);
+        cols.Add(bcv);
+        //cshort
+        short[] vshort = new short[] { 32767, 29 };
+        BasicShortVector bshv = new BasicShortVector(vshort);
+        cols.Add(bshv);
+        //cint
+        int[] vint = new int[] { 2147483647, 483647 };
+        BasicIntVector bintv = new BasicIntVector(vint);
+        cols.Add(bintv);
+        //clong
+        long[] vlong = new long[] { 2147483647, 483647 };
+        BasicLongVector blongv = new BasicLongVector(vlong);
+        cols.Add(blongv);
+        //cdate
+        int[] vdate = new int[] { Utils.countDays(new DateTime(2018,2,14)), Utils.countDays(new DateTime(2018,8,15)) };
+        BasicDateVector bdatev = new BasicDateVector(vdate);
+        cols.Add(bdatev);
+        //cmonth
+        int[] vmonth = new int[] { Utils.countMonths(new DateTime(2018,2,6)), Utils.countMonths(new DateTime(2018,8,11)) };
+        BasicMonthVector bmonthv = new BasicMonthVector(vmonth);
+        cols.Add(bmonthv);
+        //ctime
+        int[] vtime = new int[] { Utils.countMilliseconds(16, 46, 05, 123), Utils.countMilliseconds(18, 32, 05, 321) };
+        BasicTimeVector btimev = new BasicTimeVector(vtime);
+        cols.Add(btimev);
+        //cminute
+        int[] vminute = new int[] { Utils.countMinutes(new TimeSpan(16,30,00)), Utils.countMinutes(new TimeSpan(9,30,00)) };
+        BasicMinuteVector bminutev = new BasicMinuteVector(vminute);
+        cols.Add(bminutev);
+        //csecond
+        int[] vsecond = new int[] { Utils.countSeconds(new TimeSpan(16,30,00)), Utils.countSeconds(new TimeSpan(16, 30, 50)) };
+        BasicSecondVector bsecondv = new BasicSecondVector(vsecond);
+        cols.Add(bsecondv);
+        //cdatetime
+        int[] vdatetime = new int[] { Utils.countSeconds(new DateTime(2018, 9, 8, 9, 30, 01)), Utils.countSeconds(new DateTime(2018, 11, 8, 16, 30, 01)) };
+        BasicDateTimeVector bdatetimev = new BasicDateTimeVector(vdatetime);
+        cols.Add(bdatetimev);
+        //ctimestamp
+        long[] vtimestamp = new long[] { Utils.countMilliseconds(2018, 11, 12, 9, 30, 01, 123), Utils.countMilliseconds(2018, 11, 12, 16, 30, 01, 123) };
+        BasicTimestampVector btimestampv = new BasicTimestampVector(vtimestamp);
+        cols.Add(btimestampv);
+        //cnanotime
+        long[] vnanotime = new long[] { Utils.countNanoseconds(new TimeSpan(9, 30, 05, 1234567)), Utils.countNanoseconds(new TimeSpan(16, 30, 05, 9876543)) };
+        BasicNanoTimeVector bnanotimev = new BasicNanoTimeVector(vnanotime);
+        cols.Add(bnanotimev);
+        //cnanotimestamp
+        long[] vnanotimestamp = new long[] { Utils.countNanoseconds(new DateTime(2018, 11, 12, 9, 30, 05, 123)), Utils.countNanoseconds(new DateTime(2018, 11, 13, 16, 30, 05, 987)) };
+        BasicNanoTimestampVector bnanotimestampv = new BasicNanoTimestampVector(vnanotimestamp);
+        cols.Add(bnanotimestampv);
+        //cfloat
+        float[] vfloat = new float[] { 2147.483647f, 483.647f };
+        BasicFloatVector bfloatv = new BasicFloatVector(vfloat);
+        cols.Add(bfloatv);
+        //cdouble
+        double[] vdouble = new double[] { 214.7483647, 48.3647 };
+        BasicDoubleVector bdoublev = new BasicDoubleVector(vdouble);
+        cols.Add(bdoublev);
+        //csymbol
+        String[] vsymbol = new String[] { "GOOG", "MS" };
+        BasicStringVector bsymbolv = new BasicStringVector(vsymbol);
+        cols.Add(bsymbolv);
+        //cstring
+        String[] vstring = new String[] { "", "test string" };
+        BasicStringVector bstringv = new BasicStringVector(vstring);
+        cols.Add(bstringv);
+        BasicTable t1 = new BasicTable(colNames, cols);
+        return t1;
+    }
+
+    public void writeDfsTable()
+    {
+        BasicTable table1 = createBasicTable();
+        conn.login("admin", "123456", false);
+        conn.run("t = table(10000:0,`cbool`cchar`cshort`cint`clong`cdate`cmonth`ctime`cminute`csecond`cdatetime`ctimestamp`cnanotime`cnanotimestamp`cfloat`cdouble`csymbol`cstring,[BOOL,CHAR,SHORT,INT,LONG,DATE,MONTH,TIME,MINUTE,SECOND,DATETIME,TIMESTAMP,NANOTIME,NANOTIMESTAMP,FLOAT,DOUBLE,SYMBOL,STRING])\n");
+        conn.run("if(existsDatabase('dfs://testDatabase')){dropDatabase('dfs://testDatabase')}");
+        conn.run("db = database('dfs://testDatabase',RANGE,2018.01.01..2018.12.31)");
+        conn.run("db.createPartitionedTable(t,'tb1','cdate')");
+        conn.run("def saveData(data){ loadTable('dfs://testDatabase','tb1').tableInsert(data)}");
+        List<IEntity> args = new List<IEntity>(1);
+        args.Add(table1);
+        conn.run("saveData", args);
+        BasicTable dt = (BasicTable)conn.run("select * from loadTable('dfs://testDatabase','tb1')");
+        if (dt.rows() != 2) {
+            Console.WriteLine("failed");
+        }
+    }
+
+
+    public static void Main(string[] args)
+    {
+        conn = new DBConnection();
+        if (args.Length == 2)
+        {
+            try
+            {
+                HOST = args[0];
+                PORT = int.Parse(args[1]);
+            }
+            catch (Exception)
+            {
+                Console.WriteLine("Wrong arguments");
+            }
+        }
+        else if (args.Length != 2 && args.Length != 0)
+        {
+            Console.WriteLine("wrong arguments");
+            return;
+        }
+        try
+        {
+            conn.connect(HOST, PORT);
+        }
+        catch (IOException e)
+        {
+            Console.WriteLine("Connection error");
+            Console.WriteLine(e.ToString());
+            Console.Write(e.StackTrace);
+        }
+        try
+        {
+            (new DFSTableWriting()).writeDfsTable();
+        }
+        catch (IOException)
+        {
+            Console.WriteLine("Writing error");
+        }
+    }
+}

dolphindb_csharpapi.sln

@@ -0,0 +1,38 @@
+using System;
+using System.Collections.Generic;
+using dolphindb.data;
+using dolphindb;
+using dolphindb.route;
+
+namespace DolphinDB
+{
+    class DFSTableWritingMultiThread
+    {
+        static void Main(string[] args)
+        {
+            IDBConnectionPool pool = new ExclusiveDBConnectionPool("localhost", 8848, "admin", "123456", 5, true, true);
+            IDBTask conn = new BasicDBTask("dbPath = \"dfs://demohash\";if(existsDatabase(dbPath))    dropDatabase(dbPath); db = database(dbPath, HASH,[STRING, 2]);t= table(100:0,`id`value,[STRING,INT]);pt=db.createPartitionedTable(t,`pt,`id);");
+            pool.execute(conn);
+
+
+            PartitionedTableAppender appender = new PartitionedTableAppender("dfs://demohash", "pt", "id", pool);
+            List<String> colNames = new List<String>(2);
+            colNames.Add("id");
+            colNames.Add("value");
+            List<IVector> cols = new List<IVector>(2);
+            BasicStringVector id = new BasicStringVector(3);
+            id.setString(0, "ORCA");
+            id.setString(1, "YHOO");
+            id.setString(2, "Ford");
+            cols.Add(id);
+
+            BasicIntVector value = new BasicIntVector(3);
+            value.setInt(0, 10);
+            value.setInt(1, 11);
+            value.setInt(2, 12);
+            cols.Add(value);
+
+            int res = appender.append(new BasicTable(colNames, cols));
+        }
+    }
+}

examples/DFSTableWriting.cs

@@ -0,0 +1,70 @@
+## DolphinDB C# API例子
+
+### 1. 概述
+目前已有2个C# API的例子，如下表所示：
+
+| 例子主题        | 文件名称          |
+|:-------------- |:-------------|
+|数据库写入|DFSTableWriting.cs|
+|流数据写入和订阅|StreamingData.cs|
+
+本文下面对每个例子分别进行简单的说明，包括运行和使用帮助等。
+### 2. 数据库写入例子
+
+本例实现了用C# API往分布式数据库写入数据的功能。例子中的目标数据库是一个按日期分区的分布式数据库。
+
+#### 2.1 代码说明
+主要有2个函数：
+* createBasicTable函数 : 定义写入的数据，该函数创建了一个本地的表对象BasicTable。
+* writeDfsTable函数 : 通过API在DolphinDB创建待写入的分布式表，并用`run("tableInsert",args)`函数将C#端的BasicTable上传和写入分布式表。
+#### 2.2 运行
+将代码编译成xxx.exe 执行 
+```
+xxx.exe [serverIP] [serverPort]
+```
+若不传入serverIP和serverPort参数，默认serverIP="localhost"，serverPort==8848
+
+### 3. 流数据写入和订阅例子
+C# API提供了ThreadedClient、ThreadPooledClient和PollingClient三种订阅模式订阅流表的数据。三种模式的主要区别在于收取数据的方式：
+
+ThreadedClient单线程执行，并且对收到的消息直接执行用户定义的handler函数进行处理；
+
+ThreadPooledClient多线程执行，对收到的消息进行多线程并行调用用户定义的handler函数进行处理；
+
+PollingClient返回一个消息队列，用户可以通过轮询队列的方式获取和处理数据。
+
+在本例流数据订阅的源代码中，选择用ThreadedClient，PollingClient两种方式。ThreadPooledClient可以参照ThreadedClient使用方式。
+
+#### 3.1 代码说明
+本例实现了流数据表的写入和流数据订阅的功能，订阅服务端发布的数据并在C#应用端打印出来，主要有5个函数和类如下：
+* createStreamTable函数 ：用于在DolphinDB中创建流数据表。
+* pollingClient类 ：用PollingClient订阅模式订阅流表的数据，并在主线程中获取的数据展示出来。
+* ThreadedClient类 ：用ThreadedClient订阅模式订阅流表的数据。
+* SampleMessageHandler类 ： 处理ThreadedClient订阅的流表数据，将获取的数据展示出来。
+
+#### 3.2 运行
+将代码编译成xxx.exe 执行 
+```
+xxx.exe [serverIP] [serverPort] [subscribePort] [subscribeMethod]
+```
+subscribeMethod有2个选项：
+* 'T'，用ThreadedClient开启订阅。
+* 'P'，用PollingClient开启订阅。
+
+若不传入参数，默认serverIP="localhost"，serverPort==8848，subscribePort=8892，subscribeMethod='P'.
+
+程序运行之后，Server端流表被创建，客户端处于等待流数据的状态。在DolphinDB 服务端运行以下脚本发布数据(持续100秒)：
+```
+for(x in 0:1000){
+    time =time(now())
+    sym= rand(`S`M`MS`GO, 1)
+    qty= rand(1000..2000,1)
+    price = rand(2335.34,1)
+    insert into Trades values(x, time,sym, qty, price)
+    sleep(100)
+}
+```
+在PollingClient订阅时，若需要中途停止订阅，可以向流表写入 id = -1的记录，示例程序会停止运行
+```
+insert into Trades values(-1,time(now()),`a, 0, 0)
+```