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] 下一页 | 
注：本站部分文章源于互联网，版权归原作者所有！如有侵权，请原作者与本站联系，本站将立即删除！ 本站文章除特别注明外均可转载，但需注明出处！ [MinTao学以致用网] 