a__concommand_emp事务_插入.cpp

用ADO进行数据访问的例子

//#pragma warning(disable: 4146)
#import  "c:\Program Files\Common Files\System\ado\Msado15.dll"  no_namespace rename( "EOF", "adoEOF" )

//#pragma warning(default: 4146)
#include <iostream.h>
#include <stdlib.h>
#include <conio.h>
#include <stdio.h>
#include <dos.h>

int main()
{	
	_ConnectionPtr m_pConnection;
	HRESULT hr;
	hr = CoInitialize(0);             //没有初始化COM库，就是不能初始化连接和连接数据库
	if(SUCCEEDED(hr))               
		cout << "com lib init ok"<<endl;
	else
		cout << "com lib init failed"<<endl;
	hr = m_pConnection.CreateInstance("ADODB.Connection");///创建Connection对象
	if(SUCCEEDED(hr)) 
	{	          
		m_pConnection->PutIsolationLevel(adXactSerializable);
		hr = m_pConnection->Open("Provider=EciProvider;Data Source=ORADB","scott","tiger",-1);
	}  //MSDAORA.1
	else
		cout << "init connection object failed!" <<endl;

	if(SUCCEEDED(hr))
		cout <<"连接222成功!"<<endl; 
	else
		cout <<"连接数据库失败!"<<endl;
	
	///////////下面是对数据库的表执行一个SELECT查询语句，并返回和显示结果
	_RecordsetPtr m_pRecordset;
	m_pRecordset.CreateInstance("ADODB.Recordset");
	m_pRecordset->put_CursorLocation(adUseClient);
 
	m_pRecordset->Open("SELECT * FROM emp",_variant_t((IDispatch*)m_pConnection,true),adOpenDynamic,adLockOptimistic,-1);
	_variant_t vENO,vENAME;            //声明
	
	//while(!m_pRecordset->adoEOF)
	int i=5543;
 
	cout<<"------------------------"<<endl;
 
	HRESULT h=m_pRecordset->Supports(adAddNew);
	if(!h)
		 cout<<"not support AddNew!"<<endl;
		else 	 cout<<" support AddNew!"<<endl;
 	for(i=8000;i<9000;i++)
	{	cout<<i<<"--inserting--"<<endl;
		m_pConnection->BeginTrans();
		m_pRecordset->AddNew();
		m_pRecordset->PutCollect("empno",(long )(i));
		m_pRecordset->PutCollect("eName",_variant_t("add"));
		m_pRecordset->PutCollect("JOB",_variant_t("dfs"));
		m_pRecordset->PutCollect("MGR",(long )(1));
		m_pRecordset->PutCollect("SAL",(long )(2));
		m_pRecordset->PutCollect("COMM",(long )(2));
		m_pRecordset->PutCollect("deptno",(long )(20));
		m_pRecordset->Update();
		//m_pConnection->RollbackTrans();
		m_pConnection->CommitTrans();
	}

	return 0;
}