的属性从配置文件读取
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 newUserDBAccess = new DBAccess();
StringBuilder sqlStr = new StringBuilder();
sqlStr.Append( "Insert into userTable(usrName,pwd,name,depart,role,available) values(");
sqlStr.Append( "''''" + usrName + "'''',");
sqlStr.Append( "''''" + pwd + "'''',");
sqlStr.Append( "''''" + name + "'''',");
sqlStr.Append( "''''" + depart + "'''',");
sqlStr.Append( "''''" + role + "'''',");
sqlStr.Append(1);
sqlStr.Append( ")");
newUserDBAccess.InsertCommand = sqlStr.ToString();
newUserDBAccess.Open();
try
{
if (!newUserDBAccess.ExecuteCommand())
{
errMsg = newUserDBAccess.ErrorMessage;
return false;
}
else
{
return true;
}
}
finally
{
newUserDBAccess.Close();
}
}
Update操作，修改用户信息：
public bool ModifyUser()
{
DBAccess modifyUserDBAccess = new DBAccess();
StringBuilder sqlStr = new StringBuilder();
sqlStr.Append( "update userTable set ");
sqlStr.Append( " usrName = ");
sqlStr.Append( "''''" + usrName + "'''',");
sqlStr.Append( " name =");
sqlStr.Append( "''''" + name + "'''',");
sqlStr.Append( " pwd =");
sqlStr.Append( "''''" + pwd + "'''',");
sqlStr.Append( " depart =");
sqlStr.Append( "''''" + depart + "'''',");
sqlStr.Append( " role =");
sqlStr.Append( "''''" + role + "''''");
sqlStr.Append( " where usrID = ");
sqlStr.Append(id);
modifyUserDBAccess.UpdateCommand = sqlStr.ToString();
modifyUserDBAccess.Open();
try
{
if (!modifyUserDBAccess.ExecuteCommand())
{
errMsg = modifyUserDBAccess.ErrorMessage;
return false;
}
else
{
return true;
}
}
finally
{
modifyUserDBAccess.Close();
}
}
Delete操作，删除用户：
public static bool DelUser(int usrID)
{
DBAccess delUserDBAccess = new DBAccess();
StringBuilder sqlStr = new StringBuilder();
sqlStr.Append( "update userTable set ");
sqlStr.Append( " available =");
sqlStr.Append(0);
sqlStr.Append( " where usrID = ");
sqlStr.Append(usrID);
delUserDBAccess.UpdateCommand = sqlStr.ToString();
delUserDBAccess.Open();
try
{
if (!delUserDBAccess.ExecuteCommand())
{
return false;
}
else
{
return true;
}
}
finally
{
delUserDBAccess.Close();
}
}
上一页 [1] [2] [3] [4] | 
注：本站部分文章源于互联网，版权归原作者所有！如有侵权，请原作者与本站联系，本站将立即删除！ 本站文章除特别注明外均可转载，但需注明出处！ [MinTao学以致用网] 