在MFC中利用ADO访问SQL Server 2008怎么使用多线程,插入读取数据

在MFC中利用ADO访问SQL Server 2008如何使用多线程,插入读取数据
我的操作过程如下:

新建一个基于对话框的MFC程序Test
在StdAfx.h中 #include<afxdb.h>  
在StdAfx.h中 #import "C:\Program Files (x86)\Common Files\System\ado\msado15.dll" no_namespace rename("EOF","adoEOF") rename("BOF","adoBOF")
在CTestDlg类的OnInitDialog()中
第一,初始化COM库

AfxOleInit();

第二,定义两个全局的智能指针  

	_ConnectionPtr m_pConnection; 

	_CommandPtr m_pCommand;

下来用m_pConnection连接我的数据库 

CString strSQL;

	HRESULT hr;

	try

	{

		hr=m_pConnection.CreateInstance(__uuidof(Connection));

		//m_pConnection->CursorLocation=adUseClient;

		strSQL="Provider=SQLOLEDB;Server=1104A01\\MSSQLSERVER1104;Database=DCS;UID=sa;PWD=726";

		if(SUCCEEDED(hr))

		{ 

			hr=m_pConnection->Open(_bstr_t(strSQL),"","",adModeUnknown);

		} 

	}


	catch(_com_error e)	//捕捉异常     

	{

		CString errormessage;

		errormessage.Format(_T("连接数据库失败!\r\n错误信息:%s",e.ErrorMessage()));

		AfxMessageBox(errormessage);//显示错误信息


		return FALSE;     

	}

接下来在按钮BUTTON的点击响应函数中开启五个线程,然后在每个线程中向数据库插入数据

void CThreadJJDlg::OnBnClickedBtnThread5()

{

	// TODO: 在此添加控件通知处理程序代码

AfxBeginThread(Thread1,THREAD_PRIORITY_NORMAL,0,0,NULL);

AfxBeginThread(Thread2,THREAD_PRIORITY_NORMAL,0,0,NULL);

AfxBeginThread(Thread3,THREAD_PRIORITY_NORMAL,0,0,NULL);

AfxBeginThread(Thread4,THREAD_PRIORITY_NORMAL,0,0,NULL);

AfxBeginThread(Thread5,THREAD_PRIORITY_NORMAL,0,0,NULL);

}

下面是每个线程的执行过程,在每个线程中,用m_pCommand调用数据库中的一个名为Insert_date_data的存储过程将数据存入表格

UINT Thread1(LPVOID lpParam)

{

    CString str;

    clock_t t_Start , t_End;

//这两个用于计算程序运行的时间,数据插入时间

try

{

    m_pCommand.CreateInstance(__uuidof(Command));

    m_pCommand->ActiveConnection = m_pConnection;

    m_pCommand->CommandText="Insert_date_data";// 制定调用哪个存储过程

    m_pCommand->CommandType=adCmdStoredProc;     // 制定Sql命令类型是存储过程

    m_pCommand->Parameters->Refresh();


    m_pCommand->Parameters->GetItem((long)1)->Value ="2013-03-13 21:34:50";//按存储过程的参数顺序给参数赋值

    m_pCommand->Parameters->GetItem((long)2)->Value =100;


    m_pCommand->Parameters->GetItem((long)3)->Value ="1234567890123456789012345678901234567890";

}


catch(_com_error e)	//捕捉异常     

{

    CString errormessage;

    errormessage.Format(_T("连接数据库失败!\r\n错误信息:%s",e.ErrorMessage()));

    AfxMessageBox(errormessage);//显示错误信息


    return FALSE;     

}

	t_Start = clock();

	m_pConnection->BeginTrans();//开启一个事务

	while(num--)

	{

		m_pCommand->Execute(0,0,adCmdStoredProc);

	}

    m_pConnection->CommitTrans();//执行事务

    t_End = clock();

    str.Format("线程1所用时间为:%d",(t_End - t_Start));

    ::SetDlgItemText(AfxGetMainWnd()->m_hWnd,IDC_EDIT1,str);


	return 0;

}

其余的四个线程和这个是一模一样的,当只开一个线程的时候,程序运行没有问题,为什么当两个线程以上时程序就会报错