|
sp; } else /// if something went wrong rollback { switch( command ) { case COMMAND.DELETE: dbDeleteCommand.Transaction.Rollback(); break; case COMMAND.INSERT: dbInsertCommand.Transaction.Rollback(); break; case COMMAND.UPDATE: dbUpdateCommand.Transaction.Rollback(); break; } //trans.Rollback();
bReturn = false; } } }
return bReturn; }
#region select functions
/// <summary> /// Get the Select reader from the select command /// </summary> private SqlDataReader SelectReader { get { if( dbDataReader != null ) { if( dbDataReader.IsClosed == false ) { dbDataReader.Close(); dbDataReader = null; } }
dbDataReader = dbSelectCommand.ExecuteReader(); return dbDataReader; } }
/// <summary> /// Get the Update reader from the update command /// </summary> private SqlDataReader UpdateReader { get { if( dbDataReader.IsClosed == false ) dbDataReader.Close();
dbDataReader = dbSelectCommand.ExecuteReader(); return dbDataReader; } }
/// <summary> /// Get the Insert Reader from the Insert Command /// </summary> private SqlDataReader InsertReader { get { if( dbDataReader.IsClosed == false ) dbDataReader.Close();
dbDataReader = dbSelectCommand.ExecuteReader(); return dbDataReader; } }
/// <summary> /// Get the Delete Reader from the Delete Command /// </summary> private SqlDataReader DeleteReader { get { if( dbDataReader != null ) { if( dbDataReader.IsClosed == false ) { dbDataReader.Close(); dbDataReader = null; } }
dbDataReader = dbSelectCommand.ExecuteReader(); return dbDataReader; } }
#endregion
/// <summary> /// Standard Constructor /// </summary> public DBAccess() { /// NOTE That we are not setting the commands up the way the wizard would /// but building them more generically
// create the command variables dbDataAdapter = new SqlDataAdapter(); dbConnection = new SqlConnection(); dbSelectCommand = new SqlCommand(); dbDeleteCommand = new SqlCommand(); dbUpdateCommand = new SqlCommand(); dbInsertCommand = new SqlCommand();
/// set up the adapter dbDataAdapter.DeleteCommand = dbDeleteCommand; dbDataAdapter.InsertCommand = dbInsertCommand; dbDataAdapter.SelectCommand = dbSelectCommand; dbDataAdapter.UpdateCommand = dbUpdateCommand;
/// make sure everyone knows what conection to use dbSelectCommand.Connection = dbConnection; dbDeleteCommand.Connection = dbConnection; dbUpdateCommand.Connection = dbConnection; dbInsertCommand.Connection = dbConnection;
command = COMMAND.NONE; dbDataReader = null;
dbSelectCommandofAdapter = new SqlCommand(); dataAdapterCommand = new SqlDataAdapter(); dataAdapterCommand.SelectCommand = dbSelectCommandofAdapter; }
public void Open() { /// set up the connection string StringBuilder strBuild = new StringBuilder();
//Connection的属性从配置文件读取 strBuild.AppendFormat(ConfigurationSettings.AppSettings["DBConnection"]); dbConnection.ConnectionString = strBuild.ToString();
try { dbConnection.Open(); bOpen = true; } catch (Exception exp) { error = exp.Message; }
}
/// <summary> /// Close the currently open connection /// </summary> public void Close() { if (dbDataReader != null) { if( dbDataReader.IsClosed == false ) { dbDataReader.Close(); dbDataReader = null; } }
dbConnection.Close(); }
}
使用示例:
Insert操作,新建用户:
public bool NewUser() { DBAccess newUserDBAcce 上一页 [1] [2] [3] [4] 下一页 [办公软件]在sybase中插入图片、PDF、文本文件 [办公软件]安装Sybase ASE [办公软件]linux指令大全(完整篇) [办公软件]Linux新手入门常用命令大全 [办公软件]在RedHat Linux 9里安装gaim0.80 [办公软件]浅谈Linux 下Java 1.5 汉字方块问题解决方法 [办公软件]Linux程序员必读:中文化与GB18030标准 [办公软件]linux指令大全 [办公软件]制作Linux启动盘的四种方法 [办公软件]Linux文件系统的反删除方法
|