1. 反射数据适配器对象.

Type m_AdapterType = typeof(SqlDataAdapter);

IDbDataAdapter m_Adapter = (IDbDataAdapter)Activator.CreateInstance(m_AdapterType);

MethodInfo m_AddToBatch = m_AdapterType.GetMethod("AddToBatch", BindingFlags.NonPublic | BindingFlags.Instance);

MethodInfo m_ClearBatch = m_AdapterType.GetMethod("ClearBatch", BindingFlags.NonPublic | BindingFlags.Instance);

MethodInfo m_InitializeBatching = m_AdapterType.GetMethod("InitializeBatching", BindingFlags.NonPublic | BindingFlags.Instance);

MethodInfo m_ExecuteBatch = m_AdapterType.GetMethod("ExecuteBatch", BindingFlags.NonPublic | BindingFlags.Instance);

2.初始化适配器

IDbCommand cmd = Connection.CreateCommand();

 //事务

cmd.Transaction = Transaction;

switch (bcmd)//命令的类型, 枚举

{

case BatchCommandType.Insert:

m_Adapter.InsertCommand = cmd;

 break;

case BatchCommandType.Update:

 m_Adapter.UpdateCommand = cmd;

break;

case BatchCommandType.Delete:

m_Adapter.DeleteCommand = cmd;

break;

}

m_InitializeBatching.Invoke(m_Adapter, null);

3.将命令遍历, 添加到适配器中.

foreach (object parameter in parameterObjects)

{

//创建命令

IDbCommand mycmd = ........................

//添加到批命令

m_AddToBatch.Invoke(m_Adapter, new object[1] { mycmd });

}

4. 执行命令

OpenConnection();

//执行批处理

rows = (int)m_ExecuteBatch.Invoke(m_Adapter, null);

 5.关闭

m_ClearBatch.Invoke(m_Adapter, null);

 IDisposable dis = m_Adapter as IDisposable;

if (dis != null)

dis.Dispose();

m_Adapter = null;

ok;