|
} command1.ExecuteNonQuery(); command1.Dispose(); } else { this.m_objCommand.CommandText = strSQL; this.m_objCommand.ExecuteNonQuery(); } } public int FillDataSet(ref DataSet objDataSet, string strSQL) { OleDbCommand command1 = new OleDbCommand(strSQL, this.m_objConn); if (this.m_Timeout >= 30) { command1.CommandTimeout = this.m_Timeout; } OleDbDataAdapter adapter1 = new OleDbDataAdapter(command1); int num1 = adapter1.Fill(objDataSet); command1.Dispose(); adapter1.Dispose(); return num1; } public int FillDataSet(ref DataSet objDataSet, string strSQL, string strTable) { OleDbCommand command1 = new OleDbCommand(strSQL, this.m_objConn); if (this.m_Timeout >= 30) { command1.CommandTimeout = this.m_Timeout; } OleDbDataAdapter adapter1 = new OleDbDataAdapter(command1); int num1 = adapter1.Fill(objDataSet, strTable); command1.Dispose(); adapter1.Dispose(); return num1; } ~CDBConn() { } public bool Lock(string[] strArrTableName) { return true; // return this.m_objSync.Lock(strArrTableName); } public void Open() { if (this.m_objConn.State != ConnectionState.Open) { this.m_objConn.Open(); } } public void Rollback() { if (this.m_bIsInTransaction) { this.m_objTransaction.Rollback(); this.m_bIsInTransaction = false; this.m_objCommand.Dispose(); } } public void Update(string strSelectSQL, DataSet objDataSet) { OleDbDataAdapter adapter1; OleDbCommandBuilder builder1; if (!this.m_bIsInTransaction) { OleDbCommand command1 = new OleDbCommand(strSelectSQL, this.m_objConn); if (this.m_Timeout >= 30) { command1.CommandTimeout = this.m_Timeout; } adapter1 = new OleDbDataAdapter(command1); builder1 = new OleDbCommandBuilder(adapter1); adapter1.InsertCommand = builder1.GetInsertCommand(); adapter1.DeleteCommand = builder1.GetDeleteCommand(); adapter1.UpdateCommand = builder1.GetUpdateCommand(); adapter1.Update(objDataSet); builder1.Dispose(); command1.Dispose(); adapter1.Dispose(); } else { adapter1 = new OleDbDataAdapter(this.m_objCommand); builder1 = new OleDbCommandBuilder(adapter1); adapter1.InsertCommand = builder1.GetInsertCommand(); adapter1.DeleteCommand = builder1.GetDeleteCommand(); adapter1.UpdateCommand = builder1.GetUpdateCommand(); adapter1.Update(objDataSet); builder1.Dispose(); adapter1.Dispose(); } } // Properties public ConnectionState State { get { return this.m_objConn.State; } }
public int Timeout { get { return this.m_Timeout; } set { if (value < 1) { this.m_Timeout = 1; } else { this.m_Timeout = value; } } } // Fields private bool m_bIsInTransaction; private OleDbCommand m_objCommand; private OleDbConnection m_objConn; private OleDbTransaction m_objTransaction; private int m_Timeout; } }
----------------------------------------------------------------------- 欢迎交流.net开发经验. qq: 32660346 msn: njbaige@hotmail.com Mial:njbaige@126.com 原著文章,如果有转载请告知,谢谢。 大家有好的文章可以发邮件给我,互相学习,共同进步! -----------------------------------------------------------------------
上一页 [1] [2] [办公软件]在sybase中插入图片、PDF、文本文件 [办公软件]安装Sybase ASE [办公软件]linux指令大全(完整篇) [办公软件]Linux新手入门常用命令大全 [办公软件]在RedHat Linux 9里安装gaim0.80 [办公软件]浅谈Linux 下Java 1.5 汉字方块问题解决方法 [办公软件]Linux程序员必读:中文化与GB18030标准 [办公软件]linux指令大全 [办公软件]制作Linux启动盘的四种方法 [办公软件]Linux文件系统的反删除方法
|