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]