namespace myCom//把所有代码写到相应的命名空间内
{
    //每一个接口一个GUID号
    [Guid( "549047DE-9F3B-4781-A1F6-F3C852091FC9" )]
    //接口类型ComInterfaceType.InterfaceIsDual接示接口需要双重公开给COM+
    //这个属性是接口的属性
    [InterfaceType( ComInterfaceType.InterfaceIsDual )]
    //定义接口
    public interface Add
   
    {
        接口内的方法返回布尔值有一个整型参数
        bool AddData( int d );
       
        bool AddDataM( int d );
    }
    //实现这个接口
    //事务属性表示需要新事务
    //这个属性用来记录类是否支持事务有车个选项同VB中类的属性相同
    [Transaction( TransactionOption.RequiresNew)]
    //在类中实现这个接口必须要继承System.EnterpriseServices;命名空间的ServicedComponent类
    //在后面继承前面所定义的接口如果有多个可以用“,”分开
    public class myClass:ServicedComponent,Add
    {
        //  public myCom.myClass   error =new ErrorsLibrary.Class1( );
       
        //定认字符变量用来存放数据库连接字符串
        private static string strConnect ="Provider=MSDAORA.1;Password=erpii;User ID=erpii;Data Source=erpii;Persist Security Info=True";
        //创建这个连接
        private OleDbConnection conConnection = new OleDbConnection (strConnect) ;
       
       
        //实现接口中的查询方法
        public bool AddData( int id )
        {
            try
            {
               
                //string StrSql="insert into    TEST1   values('" + id + "' )";
                string StrSql=" insert into    test_d  values('" + id + "',"
                +"'" + id + "',"
                + "'" + id + "',"
                + "'" + id + "' )";
                //     string StrSql="DELETE FROM TEST1";
                //找开连接
                conConnection.Open( ); // 打开数据连接
                //执行查询
                OleDbCommand cmd = new OleDbCommand (StrSql , conConnection) ;
                cmd.ExecuteNonQuery ( );
                conConnection.Close ( );
               
                //ContextUtil.SetComplete( ) ;
                return true;
            }
            catch ( Exception e )
            {
               
                //error.Description =e.Message;
                //    EnterpriseServices.ContexUtil.
                ContextUtil.SetAbort( );
                return false;
                //   
            }
        }
       
        public bool AddDataM( int id )
        {
            try
            {
                //    string StrSql="insert into    TEST21  values(" + id + "' )";
                //    string StrSql="DELETE FROM TEST2";
                //找开连接
                string StrSql=" insert into    test_m  values('" + id + "',"
                +"'" + id + "',"
                + "'" + id + "',"
                + "'" + id + "' )";
                conConnection.Open( ); // 打开数据连接
                //执行查询
                OleDbCommand cmd = new OleDbCommand (StrSql , conConnection) ;
                cmd.ExecuteNonQuery ( );
                conConnection.Close ( );
                //    System.EnterpriseServices.ContextUtil.SetComplete( ) ;
                return true;
               
            }
            catch ( Exception e )
            {
                //error.Description =e.Message;
                //    EnterpriseServices.ContexUtil.
                //    System.EnterpriseServices.ContextUtil.SetAbort( );
                //    e.Message;
                ContextUtil.SetAbort ( ) ;
                return false;
               
            }
           
        }
       
        //如果在方法或类上使用[AutoComplete]则事务类或方法在没有错误的情状下自动提交事务
        [AutoComplete]
        public bool addRs( )
        {
           
            try
            {
                for ( int i=0;i<100;i++ )
                {
                    ////      
                    if ( !AddData( i ) )
                    {    //事务回滚
                        ContextUtil.SetAbort ( ) ;
      函数返回值
                        return false;
                    }
                    //如函数不等于真则回滚其中(?┫嗟庇赩B中的(NOT)
                    if (!AddDataM( i ) )
                   
                    {
                        ContextUtil.SetAbort ( ) ;
                        return false;
                    }
                   
                }
                   如查成功能提交事务
                ContextUtil.SetComplete( );
                return  true;
               
            }
           
           
            catch ( Exception e )
            {
                //      error.Description =e.Message;
                //    EnterpriseServices.ContexUtil.
                //    ContextUtil.SetAbort( );
                ContextUtil.SetAbort ( ) ;
                return false;
                //   
            }
        }
       
        public myClass( )
        {
            //
            // TODO: 在此处添加构造函数逻辑
            //
        }
    }
}