sqldata.cs.svn-base

大学英语学习系统

    //
    public bool updateRow(String TableName, String[] UpdateCloumn, String[] UpdateStr, int NumOfColumn, String WhereCloumn, String WhereStr)
    {
        //UPDATE PASS1.TAB_PASSINFO SET PASSNAME = 'PASSNAME', ISSITE = :ISSITE, PASSPIC = :PASSPIC, ISUSEFUL = :ISUSEFUL, SIGN1 = :SIGN1, SIGN2 = :SIGN2, SIGN3 = :SIGN3 WHERE (PASSNO = :PASSNO)
        try
        {
            String conString = "UPDATE " + TableName + " SET ";
            for (int i = 0; i < NumOfColumn; i++)
            {
                if (i != NumOfColumn - 1)
                {
                    conString += UpdateCloumn[i] + "='" + UpdateStr[i] + "',";
                }
                else
                {
                    conString += UpdateCloumn[i] + "='" + UpdateStr[i] + "'";
                }
            }
            conString += " WHERE " + WhereCloumn + "='" + WhereStr + "'";
            myConnection.Open();
            SqlCommand Command = new SqlCommand(conString, myConnection);
            Command.CommandType = CommandType.Text;
            Command.ExecuteNonQuery();
            return true;
        }
        catch (SqlException E)
        {
            return false;
        }
    }
    //
    //主要功能:更新TableName中列为WhereCloumn[]=WhereStr[]，某行多列UpdateCloumn[]的基本字符串集合为UpdateStr[],NumOfColumn为表的列数
    //主要作用;更新多个主键为WhereCloumn=WhereStr的整行数据
    //
    public bool updateRow(String TableName, String[] UpdateCloumn, String[] UpdateStr, int NumOfColumn, String[] WhereCloumn, String[] WhereStr)
    {
        //UPDATE PASS1.TAB_PASSINFO SET PASSNAME = 'PASSNAME', ISSITE = :ISSITE, PASSPIC = :PASSPIC, ISUSEFUL = :ISUSEFUL, SIGN1 = :SIGN1, SIGN2 = :SIGN2, SIGN3 = :SIGN3 WHERE (PASSNO = :PASSNO)
        try
        {
            String conString = "UPDATE " + TableName + " SET ";
            for (int i = 0; i < NumOfColumn; i++)
            {
                if (i != NumOfColumn - 1)
                {
                    conString += UpdateCloumn[i] + "='" + UpdateStr[i] + "',";
                }
                else
                {
                    conString += UpdateCloumn[i] + "='" + UpdateStr[i] + "'";
                }
            }
            conString += "WHERE " + WhereCloumn[0] + "='" + WhereStr[0] + "' AND " + WhereCloumn[1] + "='" + WhereStr[1] + "'";
            myConnection.Open();
            SqlCommand Command = new SqlCommand(conString, myConnection);
            Command.CommandType = CommandType.Text;
            Command.ExecuteNonQuery();
            return true;
        }
        catch (SqlException E)
        {
            return false;
        }
    }
    //
    //主要功能:更新TableName中列为WhereCloumn=WhereStr，某行多列UpdateCloumn[]的基本字符串集合为UpdateObject[],NumOfColumn为表的列数
    //主要作用;更新一个主键为WhereCloumn=WhereStr的整行数据，而且更新数据中存在列的属性不为String,而是为int这些属性的
    //
    public bool updateRow(String TableName, String[] UpdateCloumn, object[] UpdateObject, int NumOfColumn, String[] WhereCloumn, String[] WhereStr)
    {
        try
        {
            String conString = "UPDATE " + TableName + " SET ";
            for (int i = 0; i < NumOfColumn; i++)
            {
                if (UpdateObject[i].GetType().ToString().ToLower() == "system.string")
                {
                    if (i != NumOfColumn - 1)
                    {
                        conString += UpdateCloumn[i] + "='" + UpdateObject[i] + "',";
                    }
                    else
                    {
                        conString += UpdateCloumn[i] + "='" + UpdateObject[i] + "'";
                    }
                }
                else
                {
                    if (i != NumOfColumn - 1)
                    {
                        conString += UpdateCloumn[i] + "=" + UpdateObject[i] + ",";
                    }
                    else
                    {
                        conString += UpdateCloumn[i] + "=" + UpdateObject[i];
                    }
                }
            }
            conString += "WHERE " + WhereCloumn[0] + "='" + WhereStr[0] + "' AND " + WhereCloumn[1] + "='" + WhereStr[1] + "'";
            myConnection.Open();
            SqlCommand Command = new SqlCommand(conString, myConnection);
            Command.CommandType = CommandType.Text;
            Command.ExecuteNonQuery();
            return true;
        }
        catch (SqlException E)
        {
            return false;
        }
    }

    //
    //主要功能:删除TableName表中列CloumnName=WhereStr的所有行
    //
    //

    public bool DeleteRow(String TableName, String CloumnName, String WhereStr)
    {
        try
        {
            String DeleteString = "DELETE FROM " + TableName + " WHERE " + CloumnName + "='" + WhereStr + "'";
            myConnection.Open();
            SqlCommand Command = new SqlCommand(DeleteString, myConnection);
            Command.CommandType = CommandType.Text;
            Command.ExecuteNonQuery();
            return true;
        }
        catch (SqlException E)
        {
            return false;
        }
    }

    //
    //主要功能:删除TableName表中列CloumnName[]=WhereStr[]的所有行
    //
    //
    public bool DeleteRow(String TableName, String[] CloumnName, String[] WhereStr, int NumOfCloumn)
    {
        try
        {
            String DeleteString = "DELETE FROM " + TableName + " WHERE ";
            for (int i = 0; i < NumOfCloumn; i++)
            {
                if (i == NumOfCloumn - 1)
                {
                    DeleteString += CloumnName[i] + "='" + WhereStr[i] + "'";
                }
                else
                {
                    DeleteString += CloumnName[i] + "='" + WhereStr[i] + "' AND ";
                }
            }
            myConnection.Open();
            SqlCommand Command = new SqlCommand(DeleteString, myConnection);
            Command.CommandType = CommandType.Text;
            Command.ExecuteNonQuery();
            return true;
        }
        catch (SqlException E)
        {
            return false;
        }
    }
    //
    //返回一个所要查找的数据库的字符串
    //
    public string FindString(String TableName, String CloumnName,String ReturnCloumn,String Str)
    {
        try
        {
            SqlConnection myConnection = new SqlConnection(ConnectionString);
            String conString = "SELECT * FROM " + TableName + " where " + CloumnName + "='" + Str + "'";
            SqlDataAdapter myAdapter = new SqlDataAdapter(conString, myConnection);
            myAdapter.MissingSchemaAction = MissingSchemaAction.AddWithKey;
            DataSet myDataSet = new DataSet();
            myAdapter.Fill(myDataSet, TableName);
            DataTable userInfo = myDataSet.Tables[0];
            DataRow row = userInfo.Rows[0];
            string ReturnStr = row[ReturnCloumn].ToString();
            return ReturnStr;
        }
        catch (SqlException E)
        {
            return "";
        }
    }
    public DataRow FindRow(String TableName, String CloumnName, String Str)
    {
        try
        {
            SqlConnection myConnection = new SqlConnection(ConnectionString);
            String conString = "SELECT * FROM " + TableName + " where " + CloumnName + "='" + Str + "'";
            SqlDataAdapter myAdapter = new SqlDataAdapter(conString, myConnection);
            myAdapter.MissingSchemaAction = MissingSchemaAction.AddWithKey;
            DataSet myDataSet = new DataSet();
            myAdapter.Fill(myDataSet, TableName);
            DataTable userInfo = myDataSet.Tables[0];
            if(userInfo.Rows.Count==1)
            {
               DataRow row = userInfo.Rows[0];
                return row;
            }
            else{
                return null;
            }
        }
        catch (SqlException E)
        {
            return null;
        }
    }
}