KingbaseES Kdbndp使用指南

关键词

Kdbndp、net core

1. Kdbndp简介

Kdbndp是完全使用C#语言实现，完全兼容ADO.NET，其API应该与其他.NET数据库驱动程序几乎完全相同。

2. 支持版本

netstandard2.0

3. 连接串参数解析
3.1. 标准(通常使用)

1. Server=127.0.0.1;Port=5432;Database=myDataBase;User Id=myUsername;Password=myPassword;

复制代码

3.2. 使用Windows安全性验证

1. Server=127.0.0.1;Port=5432;Database=myDataBase;Integrated Security=true;

复制代码

3.3. 设置命令超时

1. Server=127.0.0.1;Port=5432;Database=myDataBase;User Id=myUsername;Password=myPassword;CommandTimeout=20;

复制代码

参数以秒为单位进行测量，并控制在抛出错误之前等待命令完成的时间。

3.4. 设置连接超时

1. Server=127.0.0.1;Port=5432;Database=myDataBase;User Id=myUsername;Password=myPassword;Timeout=15;

复制代码

参数以秒为单位进行测量，并控制在抛出错误之前等待连接打开的时间。

3.5. 指定协议版本

1. Server=127.0.0.1;Port=5432;Database=myDataBase;User Id=myUsername;Password=myPassword;Protocol=3;

复制代码

密钥协议的有效值为2或3。

3.6. SSL已激活

1. Server=127.0.0.1;Port=5432;Database=myDataBase;Userid=myUsername;Password=myPassword;Protocol=3;SSL=true;SslMode=Require;

复制代码

3.7. 没有SSL

1. Server=127.0.0.1;Port=5432;Database=myDataBase;Userid=myUsername;Password=myPassword;Protocol=3;SSL=false;SslMode=Disable;

复制代码

3.8. 使用连接池

1. Server=127.0.0.1;Port=5432;Database=myDataBase;Userid=myUsername;Password=myPassword;Protocol=3;Pooling=true;MinPoolSize=1;MaxPoolSize=20;ConnectionLifeTime=15；

复制代码

MaxPoolSize的值介于0到1024,默认值100，ConnectionLifeTime为连接池中连接数超过MaxPoolSize后关闭未使用连接等待的时间。

4. 在.net core中使用Kdbndp.dll
4.1. 创建项目
- 打开 Visual Studio 2017；
- “文件”>“新建”>“项目...”；
- 从左侧菜单中选择“已安装”>“Visual C#”->“.NET core”；
- 选择“控制台应用(.NET Core)”项目模板；
- 将项目命名为 Kdbndp_net_core (项目名)，并单击“确定”；
4.2. 添加引用以及依赖包

添加依赖包System.Runtime.CompilerServices.Unsafe，在Nuget控制台输入以下命令

1. cd kdbndp_net_core
   
2. dotnet add package  System.Runtime.CompilerServices.Unsafe

复制代码

执行完成后会看到“依赖项”->“Nuget”下有如下引用：

添加Kdbndp.dll的引用：“依赖项”->“添加引用”添加Kdbndp.dll

4.3. 简单用例

引用命名空间

1. using Kdbndp;
   
2. using KdbndpTypes;
   
3. 用例函数
   
4. static void TestKdbndp()
   
5. {
   
6.             const string ConnectionString = "Server=192.168.28.212;User ID=SYSTEM;Password=MANAGER;Database=KDBNDP_TESTS;Port=54328";
   
7.      var conn = new KdbndpConnection(ConnectionString);
   
8. 
   
9.      try
   
10.      {
    
11.          conn.Open();
    
12. 
    
13.         // create table
    
14.          const string createTable =
    
15.                  @"CREATE TABLE PERSON3 (
    
16.                  person_id serial PRIMARY KEY NOT NULL,
    
17.                  person_uuid uuid NOT NULL
    
18.                  ) WITH(OIDS=FALSE);";
    
19.           var command = new KdbndpCommand(createTable, conn);
    
20.           command.ExecuteNonQuery();
    
21. 
    
22.           var uuidDbParam = new KdbndpParameter(":param1", KdbndpDbType.Uuid);
    
23.           uuidDbParam.Value = Guid.NewGuid();
    
24. 
    
25.           // add data
    
26.           command = new KdbndpCommand(@"INSERT INTO PERSON3 (person_uuid) VALUES (:param1);", conn);
    
27.           command.Parameters.Add(uuidDbParam);
    
28.           command.ExecuteNonQuery();
    
29. 
    
30.           //select data
    
31.           command = new KdbndpCommand("SELECT person_uuid::uuid FROM PERSON3", conn);
    
32. 
    
33.           using (var reader = command.ExecuteReader())
    
34.           {
    
35.               if (reader.Read())
    
36.               {
    
37.                   Console.WriteLine(reader.GetFieldValue<Guid>(0));
    
38.               }
    
39.           }
    
40. 
    
41.           // update data
    
42.           uuidDbParam = new KdbndpParameter(":param2", KdbndpDbType.Uuid);
    
43.           uuidDbParam.Value = Guid.NewGuid();
    
44. 
    
45.           command = new KdbndpCommand(@"update PERSON3 set person_uuid=:param2;", conn);
    
46.           command.Parameters.Add(uuidDbParam);
    
47.           command.ExecuteNonQuery();
    
48. 
    
49.           //after update,select data
    
50.           command = new KdbndpCommand("SELECT person_uuid::uuid FROM PERSON3", conn);
    
51. 
    
52.           using (var reader = command.ExecuteReader())
    
53.           {
    
54.               if (reader.Read())
    
55.               {
    
56.                    Console.WriteLine(reader.GetFieldValue<Guid>(0));
    
57.               }
    
58.           }
    
59. 
    
60.           //delete data
    
61.           command = new KdbndpCommand(@"delete from  PERSON3;", conn);
    
62.           command.ExecuteNonQuery();
    
63. 
    
64.           //after delete,select data
    
65.           command = new KdbndpCommand("SELECT person_uuid::uuid FROM PERSON3", conn);
    
66. 
    
67.           using (var reader = command.ExecuteReader())
    
68.           {
    
69.                if (reader.Read())
    
70.                {
    
71.                   Console.WriteLine(reader.GetFieldValue<Guid>(0));
    
72.                }
    
73.           }
    
74. 
    
75.      }
    
76.      catch (KingbaseException e)
    
77.      {
    
78.          if (e.SqlState == "3D000")
    
79.              Console.Write("Please create a database kdbndp_tests, owned by user kdbndp_tests");
    
80.          else if (e.SqlState == "28P01")
    
81.              Console.Write("Please create a user kdbndp_tests as follows: create user kdbndp_tests with password 'kdbndp_tests'");
    
82.           else
    
83.              throw;
    
84.     }
    
85. 
    
86. conn.Close();
    
87. }

复制代码

5. 在.net Framework中使用Kdbndp.dll

只需引用Kdbndp.dll即可，.net core中测试函数可使用