BS架构数据库操作必备

using System;

using System.Collections.Generic;

using System.Linq;

using System.Web;

using System.Text;

using System.Data.SqlClient;

using System.Data;

using System.Web.UI.WebControls;

using System.Windows.Forms;

using System.Collections;

//using System.Windows.Forms;

namespace Test.Utility

{

    public static class DbOperation

    {

        private static string connStr = "Data Source=58.57.32.11,1347;Initial Catalog=CRM;Persist Security Info=True;User ID=sa;Password=521777yesu!#%@$^";
public static string DbQueryCount(string cmdStr)

        {
string result = "";

            SqlConnection conn = new SqlConnection(connStr);

            conn.Open();

            SqlDataAdapter myAdap = new SqlDataAdapter(cmdStr, conn);

            DataSet myDatset = new DataSet();

            myAdap.Fill(myDatset);
myAdap.Dispose();
int a = 0;

            int b = 0;

            a = myDatset.Tables[0].Rows.Count;

            b = myDatset.Tables[0].Columns.Count;
for (int i = 0; i < a; i++)

            {

                for (int j = 0; j < b; j++)

                {

                    result = result + myDatset.Tables[0].Rows[i][j].ToString();

                    result = result + "   ";

                }

                result = result + "\n";

            }
return result;
}
//public static void checkListBind(string cmdStr, ref CheckedListBox clb)

        //{
//    SqlConnection conn = new SqlConnection(connStr);

        //    conn.Open();

        //    SqlDataAdapter myAdap = new SqlDataAdapter(cmdStr, conn);

        //    DataSet myDatset = new DataSet();

        //    myAdap.Fill(myDatset);
//    for (int i = 0; i < myDatset.Tables[0].Rows.Count; i++)

        //        clb.Items.Add(myDatset.Tables[0].Rows[i][0].ToString());
//    //clb.SelectedIndex = 0;
//    myAdap.Dispose();

        //}
public static void ComboxBind(string cmdStr,string ViewName,string UserName, ref DropDownList dl)

        {
int myCount = 0;

            SqlConnection conn = new SqlConnection(connStr);

            conn.Open();

            SqlDataAdapter myAdap = new SqlDataAdapter(cmdStr, conn);

            myAdap.SelectCommand.CommandType = CommandType.StoredProcedure;
SqlParameter spt1 = new SqlParameter("@MyCount", SqlDbType.VarChar, 20);
spt1.Direction = ParameterDirection.Output;
spt1.Value = myCount;
myAdap.SelectCommand.Parameters.Add(spt1);
SqlParameter spt2 = new SqlParameter("@ViewName", SqlDbType.VarChar, 20);
spt2.Direction = ParameterDirection.Input;
spt2.Value = ViewName;
myAdap.SelectCommand.Parameters.Add(spt2);
SqlParameter spt3 = new SqlParameter("@UserName", SqlDbType.VarChar, 20);
spt3.Direction = ParameterDirection.Input;
if (UserName == "")

            {

                dl.Visible = false;

                return;

            }
spt3.Value = UserName;
myAdap.SelectCommand.Parameters.Add(spt3);
DataSet myDatset = new DataSet();

            myAdap.Fill(myDatset);
dl.Items.Clear();

            for (int i = 0; i < myDatset.Tables[0].Rows.Count; i++)

                dl.Items.Add(myDatset.Tables[0].Rows[i][0].ToString());
dl.SelectedIndex = 0;
myAdap.Dispose();

        }
//用于查询并绑定到datagridview

        public static void DbQuery(string cmdStr, string myParameter, ref GridView dv)

        {
SqlConnection conn = new SqlConnection(connStr);

            conn.Open();

            SqlDataAdapter myAdap = new SqlDataAdapter(cmdStr, conn);

            myAdap.SelectCommand.CommandType = CommandType.StoredProcedure;
if (myParameter != "")

            {
SqlDataAdapter myAdap1 = new SqlDataAdapter("GetPara", conn);

                int myCount = 0;

                myAdap1.SelectCommand.CommandType = CommandType.StoredProcedure;

                SqlParameter spt1 = new SqlParameter("@Para_Count", SqlDbType.VarChar, 20);
spt1.Direction = ParameterDirection.Output;
spt1.Value = myCount;
myAdap1.SelectCommand.Parameters.Add(spt1);
SqlParameter spt2 = new SqlParameter("@Sp_Name", SqlDbType.VarChar, 20);
spt2.Direction = ParameterDirection.Input;
spt2.Value = cmdStr;
myAdap1.SelectCommand.Parameters.Add(spt2);
DataSet myDataSet1 = new DataSet();

                myAdap1.Fill(myDataSet1);
string[] myArray = myParameter.Split(‘@‘);
SqlParameter[] myList = new SqlParameter[myDataSet1.Tables[0].Rows.Count];

                for (int i = 0; i < myDataSet1.Tables[0].Rows.Count; i++)

                {
//myList[i].ParameterName = myDataSet1.Tables[0].Rows[i][0].ToString();

                    //MessageBox.Show("" + myDataSet1.Tables[0].Rows[i][0].ToString());

                    myList[i] = new SqlParameter();

                    myList[i].ParameterName = myDataSet1.Tables[0].Rows[i][0].ToString();

                    myList[i].SqlDbType = SqlDbType.NVarChar;

                    myList[i].Size = 256;

                    myList[i].Direction = ParameterDirection.Input;

                    myList[i].Value = myArray[i];
myAdap.SelectCommand.Parameters.Add(myList[i]);

                }

            }

            DataSet myDatset = new DataSet();

            myAdap.Fill(myDatset);
if (myDatset.Tables.Count == 0)

            {

                return;

            }

            dv.DataSource = myDatset.Tables[0].DefaultView;
dv.DataBind();

            //dv.Columns[1].HeaderStyle.Width = new Unit("124");

            myAdap.Dispose();
}

        //用于查询并绑定到datagridview
public static string DbReturn(string cmdStr)

        {

            string returnStr = "";
SqlConnection conn = new SqlConnection(connStr);

            conn.Open();

            SqlCommand myCmd = new SqlCommand(cmdStr, conn);

            if (myCmd.ExecuteScalar() != null)

                returnStr = myCmd.ExecuteScalar().ToString();

            else

                returnStr = "";
return returnStr;

        }
public static DataTable DbQueryTable(string cmdStr)

        {
SqlConnection conn = new SqlConnection(connStr);

            conn.Open();

            SqlDataAdapter myAdap = new SqlDataAdapter(cmdStr, conn);

            DataSet myDatset = new DataSet();

            myAdap.Fill(myDatset);
myAdap.Dispose();

            return myDatset.Tables[0];
}
public static long DbCount(string cmdStr)

        {

            int myCount = 0;
SqlConnection conn = new SqlConnection(connStr);

            conn.Open();

            SqlCommand mycmd = new SqlCommand(cmdStr, conn);

            myCount = (int)mycmd.ExecuteScalar();

            conn.Close();
return myCount;

        }
public static void DbEdit(string editStr)

        {
SqlConnection conn = new SqlConnection(connStr);

            conn.Open();

            SqlCommand mycmd = new SqlCommand(editStr, conn);

            mycmd.ExecuteScalar();

            conn.Close();

        }

        //过滤非法字符

        public static string FilterSpecial(string str)

        {

            if (str == "")

            {

                return str;

            }

            else

            {

                str = str.Replace("‘", "");

                str = str.Replace("<", "");

                str = str.Replace(">", "");

                str = str.Replace("%", "");

                str = str.Replace("‘delete", "");

                str = str.Replace("‘drop", "");

                str = str.Replace("‘alter", "");

                str = str.Replace("‘add", "");

                str = str.Replace("‘‘", "");

                str = str.Replace("\"\"", "");

                str = str.Replace(",", "");

                str = str.Replace(".", "");

                str = str.Replace(">=", "");

                str = str.Replace("=<", "");

                str = str.Replace("-", "");

                str = str.Replace("_", "");

                str = str.Replace(";", "");

                str = str.Replace("||", "");

                str = str.Replace("[", "");

                str = str.Replace("]", "");

                str = str.Replace("&", "");

                str = str.Replace("#", "");

                str = str.Replace("/", "");

                str = str.Replace("-", "");

                str = str.Replace("|", "");

                str = str.Replace("?", "");

                str = str.Replace(">?", "");

                str = str.Replace("?<", "");

                //str = str.Replace(" ", "");

                return str;

            }

        }

    }

}

BS架构数据库操作必备,布布扣,bubuko.com