C#批量插入Sybase資料庫,Anywhere 8

資料庫版本是Adaptive Server Anywhere 8

1、添加引用，程式集 iAnywhere.Data.AsaClient。這個和SQLServer的System.Data.SqlClient類似，一般方法和用法都差不多。

2、對于批量插入SqlClient提供了BulkCopy方法，很友善。可惜AsaClient裡面沒有。但和SqlClient一樣的是，可以使用adapter.Update(datatable)方法進行批量插入。

3、注意點：在建構帶參數的sql語句時，Asa的參數前面是加“：”，而SqlServer是加“@”。其他的寫法都是一毛一樣。

示例：

1、資料庫建表sql語句

if exists(select id from sysobjects where type='U' and name='FloatValue')
drop table FloatValue
go 
create table FloatValue(
    vid integer not null,
    value_f float,
    time_v datetime,
    foreign key (vid) references Node (id)
)

2、建構和表結構相同的Datatable，column名和資料庫表的列名相同。

1         public static DataTable GetTableSchema() 
2         {
3             DataTable dt = new DataTable();
4             dt.Columns.Add("vid");
5             dt.Columns.Add("value_f");
6             dt.Columns.Add("time_v");
7             return dt;
8         }

3、寫在helper類的方法

1         public static int BulkToASA(string sql,AsaParameter[]ps, DataTable dt) 
 2         {
 3             using (AsaConnection conn=new AsaConnection(connStr))
 4             {
 5                 using (AsaCommand cmd = new AsaCommand(sql, conn))
 6                 {
 7                     if (ps != null)
 8                     {
 9                         for (int i = 0; i < ps.Length; i++)
10                         {
11                             cmd.Parameters.Add(ps[i]);
12                         }
13                     }
14                     AsaDataAdapter adapter = new AsaDataAdapter();
15                     AsaCommandBuilder ab = new AsaCommandBuilder(adapter);
16                     adapter.InsertCommand = cmd;
17                     
18                     return adapter.Update(dt);
19                 }
20             }
21         }

4、調用方法

1         public static int InsertDatatable(DataTable dt) 
2         {
3             string sql = @"insert into FloatValue (vid,value_f,time_v) values(:id,:value,:time)";
4             AsaParameter[] ps = { new AsaParameter("id", AsaDbType.Integer,8,"vid"), new AsaParameter("value",AsaDbType.Float,15,"value_f"), new AsaParameter("time", AsaDbType.DateTime,30,"time_v") };
5             return SqlHelperForASA.BulkToASA(sql, ps,dt);            
6         }

這個插入速度至少每秒2000條以上（我測試的一個datatable裡面就隻有2000條，實際應該更快吧）。

posted on 2019-05-30 10:55 沛蒼冥閱讀(...) 評論(...) 編輯收藏