public class DBCLASS//一个强大的类 { public string sqlstr = "Data Source=192.168.132.205;Initial Catalog=XuanKeManage;Integrated Security=false;User ID = sa; Password=123;Max Pool Size=512;"; private SqlConnection cnn; public DBCLASS() { cnn = new SqlConnection(sqlstr); cnn.Open(); } public DataSet getreturnsql(string sql)//返回查询到的表 { using (SqlCommand cnd = cnn.CreateCommand()) { cnd.CommandText = sql; SqlDataAdapter sad = new SqlDataAdapter(cnd); DataSet ds = new DataSet(); sad.Fill(ds, "tablename"); return ds; } } public int returnsqlhang(string sql)//返回当前受影响的行 { using (SqlCommand cmd = cnn.CreateCommand()) { cmd.CommandText = sql; cmd.CommandType = CommandType.Text; int n = cmd.ExecuteNonQuery(); return n; } } public DataSet getreturnprocssql(string procname, params SqlParameter[] list) { using (SqlCommand cmd = cnn.CreateCommand()) { cmd.CommandText = procname; cmd.Parameters.AddRange(list); cmd.CommandType = CommandType.StoredProcedure; SqlDataAdapter sda = new SqlDataAdapter(); DataSet ds = new DataSet(); sda.Fill(ds, "proctablename"); return ds; } } public int getreturnprocrows(string procname, params SqlParameter[] list) { SqlParameter[] para = list; using (SqlCommand cmd = cnn.CreateCommand()) { cmd.CommandText = procname; cmd.Parameters.AddRange(para); cmd.CommandType = CommandType.StoredProcedure; int n = cmd.ExecuteNonQuery(); return n; } }
}
