www.pudn.com > CRM.rar > db.cs

using System; 
using System.Data; 
using System.Data.SqlClient; 
using System.Configuration; 
using System.Windows.Forms; 
using System.IO; 
 
namespace WindowsApplication1 
{ 
/// 
///用于系统数据访问 
/// 
/// 
	 
	public class dbaccess 
	{ 
		 
		private string constrread() 
		{ 
			string constr=Application.StartupPath +"/service.ini"; 
			using (StreamReader sr = new StreamReader(constr) ) 
			{ 
				string[] line; 
				String sl; 
				line=new string[3]; 
				int i=0; 
				// Read and display lines from the file until the end of  
				// the file is reached. 
				while ((sl = sr.ReadLine()) != null)  
				{ 
					line[i]=sl; 
					i++; 
				} 
				constr="data source=" + line[0] +"; uid=" + line[1]+"; pwd=" + line[2] + "; DataBase=CRM;"; 
				return constr;				 
			} 
		} 
	 
    public SqlConnection con; 
		public dbaccess() 
		{ string constr=constrread(); 
			con=new SqlConnection(constr); 
		} 
		public  string[] usercheck(string username,string pwd) 
		{ 
		string[] result; 
			string constr=constrread(); 
		con=new SqlConnection(constr); 
			SqlCommand cmd=new SqlCommand("proc_logon",con); 
			cmd.CommandType =CommandType.StoredProcedure; 
			cmd.Parameters.Add(new SqlParameter("@user",SqlDbType.VarChar,50)); 
			cmd.Parameters.Add(new SqlParameter("@pwd",SqlDbType.VarChar,50)); 
			cmd.Parameters.Add(new SqlParameter("@result",SqlDbType.VarChar,50)); 
			cmd.Parameters.Add(new SqlParameter("@class",SqlDbType.TinyInt,1)); 
			cmd.Parameters.Add(new SqlParameter("@userid",SqlDbType.VarChar,1)); 
			cmd.Parameters["@user"].Value=username; 
			cmd.Parameters["@pwd"].Value=pwd; 
			cmd.Parameters["@result"].Direction=ParameterDirection.Output; 
			cmd.Parameters["@class"].Direction=ParameterDirection.Output; 
			cmd.Parameters["@userid"].Direction=ParameterDirection.Output; 
			con.Open(); 
			cmd.ExecuteNonQuery(); 
			 
			result=new string[4]; 
			result[0]=cmd.Parameters["@result"].Value.ToString().Trim(); 
	result[2]=cmd.Parameters["@class"].Value.ToString(); 
result[3]=cmd.Parameters["@userid"].Value.ToString(); 
					if (result[0]=="noacount") 
			{ 
				result[1]="此用户不存在!"; 
			} 
			else if (result[0]=="usererr"){result[1]="用户名错误!";} 
			else if (result[0]=="passworderr"){result[1]="密码错误!";} 
			else if (result[0]=="pass"){result[1]="成功登陆!";} 
             
			con.Close(); 
			con.Dispose(); 
			cmd.Dispose(); 
return result; 
		} 
		public DataSet ds_return (string tablename,string query) 
		{ 
			string constr=constrread(); 
SqlConnection conn=new SqlConnection(constr); 
			conn.Open(); 
			SqlCommand cmd=new SqlCommand(); 
			cmd.CommandType=CommandType.StoredProcedure; 
			cmd.CommandText="query"; 
			cmd.Connection=conn; 
			cmd.Parameters.Add(new SqlParameter("@tablename",SqlDbType.VarChar,50)); 
			cmd.Parameters.Add(new SqlParameter("@query",SqlDbType.VarChar,50)); 
cmd.Parameters["@tablename"].Value=tablename; 
			cmd.Parameters["@query"].Value=query; 
SqlDataAdapter myada =new SqlDataAdapter(cmd); 
DataSet ds =new DataSet(); 
			myada.Fill(ds,tablename); 
			conn.Close(); 
			conn.Dispose(); 
			cmd.Dispose(); 
			myada.Dispose(); 
			return ds; 
 
		} 
		public DataSet UpdateDs(string query,DataSet changedDs,string tableName) 
		{ 
				try 
			{ 
				SqlDataAdapter da = new SqlDataAdapter(query,con); 
			SqlCommandBuilder sqlCmdBuilder = new SqlCommandBuilder(da); 
				da.Update(changedDs,tableName); 
				changedDs.AcceptChanges(); 
				return changedDs;//返回更新了的数据库表 
					//da.Dispose(); 
					//sqlCmdBuilder.Dispose(); 
 
			} 
			catch (Exception ex)  
			{  
				MessageBox.Show(ex.Message,"数据库更新失败"); 
				throw; 
			}   
		} 
	 
 
	} 
}