using System; using System.Collections.Generic; using System.Text; using System.Data.SqlClient; using System.Data; namespace MyChat
{
//数据库操作类
public class Sql { private string str = null; //数据库连接字符串 public SqlConnection Con; //sql数据连接组件实例化 public SqlCommand command = new SqlCommand(); //初始化一个SQL命令对象 public Sql() //类初始化,初始化数据连接 { string path = @"C:\Documents and Settings\Administrator\桌面\tools\ mychat1.0\Chat"; //数据库连接字符串 str="Data Source=.\\SQLEXPRESS;AttachDbFilename=\"" + path + "\\app_data\\chat.mdf\"; Integrated Security=True;User Instance=True"; Con = new SqlConnection(str); }
#region SQL语句操作
// 执行只读数据信息的提取,返回一个datareader
public SqlDataReader GetReader(string search) { SqlDataReader Reader; if(Con.State != ConnectionState.Open) Con.Open(); //打开数据库连接 SqlCommand Com = new SqlCommand(search, Con); Reader = Com.ExecuteReader(); //执行SQL语句 return Reader; //返回一个reader }
// 输入查询字符串,返回dataset
public DataSet getMyDataSet(string sql) { command.Connection = Con; //配置command对象 command.CommandText = sql; //赋予要执行的语句 DataSet dt = new DataSet(); //初始化一个数据返回集合 SqlDataAdapter da = new SqlDataAdapter(command); Con.Open(); //打开连接 da.Fill(dt); //执行语句 command.Connection.Close(); //关闭连接 return dt; }
// 执行非查询SQL语句
public void ExecuteSql(string sql) { if(Con.State != ConnectionState.Open) Con.Open(); //如果数据连接关闭,则打开 SqlCommand Com = new SqlCommand(sql, Con); Com.ExecuteNonQuery(); //执行非查询SQL语句 Con.Close(); }
// 执行非查询数据库操作,是否关闭数据库连接 可以选择
public void ExecuteSql(string sql, bool closeConnection) { if(Con.State != ConnectionState.Open) Con.Open(); //如果未打开连接,则打开 SqlCommand Com = new SqlCommand(sql, Con); Com.ExecuteNonQuery(); if (closeConnection) Con.Close(); //如果需要关闭,则关闭连接 }
#endregion #region 执行存储过程的代码
//输入存储过程名称,执行查询存储过程 public DataSet getDataSet(string produreName) { command.Connection = Con; //赋予连接对象 //执行的类型为存储过程 command.CommandType = CommandType.StoredProcedure ; command.CommandText = produreName; //赋予执行的存储过程名字 DataSet dt = new DataSet(); SqlDataAdapter da = new SqlDataAdapter(command); Con.Open(); //打开连接 da.Fill(dt); //填充数据 command.Connection.Close(); return dt; //返回数据集 }
//输入存储过程名,执行非查询存储过程
public bool exec(string produreName) { bool flag = false; //任务是否正确执行,初始化为false command.Connection = Con; //赋予command对象以数据连接 command.CommandType = CommandType.StoredProcedure; command.CommandText = produreName; //存储过程名称 try { command.ExecuteNonQuery(); //执行存储过程 flag = true; //正确完成任务 }
finally { command.Connection.Close(); //关闭连接 } return flag; //返回成功与否的标志 } #endregion } } |