db.cs

来自「VS2003+sqlserver 开发的客户关系管理系统,已有公司在使用,上传的」· CS 代码 · 共 127 行

using System;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
using System.Windows.Forms;
using System.IO;

namespace WindowsApplication1
{
///<sumarry>
///用于系统数据访问
///</sumarry>
///
	
	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;
			}  
		}
	

	}
}