using System; using System.Data; using System.Data.SqlClient; using System.Windows.Forms; namespace 学生课程 { /// <summary> /// Sqlserver类:增、删、查结果集、查单个字段、改功能 /// </summary> class Sqlserver { #region 成员变量声明 //连接字符串 private static string _strConnectionString = @"server=localhost; database=StuCourse;uid=sa;pwd=tianshi520"; //SqlCommand对象,用于执行操作数据库命令 private static SqlCommand _sqlCmd = null; //SqlDataReader对象,用于读行 private static SqlDataReader _sqlDR = null; //SqlConnection对象,用于连接数据库 public static SqlConnection _sqlConnection = new SqlConnection(_strConnectionString); #endregion #region 使用update,delete,insert语句,返回受影响行数 public static int GetNonQueryResult(string strSql) { try { _sqlCmd = new SqlCommand(strSql, _sqlConnection); _sqlCmd.Connection.Open(); //打开连接 //执行操作,返回受影响行数 int rs = _sqlCmd.ExecuteNonQuery(); if (rs == 0) return 0; else return 1; } catch { return -1; } finally { //关闭连接 _sqlCmd.Connection.Close(); } } #endregion #region 使用SELECT语句查询,返回结果集 //在调用完之后,要手动调用SqlDataReader //和_strConnection对象关闭连接 public static SqlDataReader GetSelectResult(string strSql) { try { //生成命令对象 _sqlCmd = new SqlCommand(strSql, _sqlConnection); //建立连接 _sqlConnection.Open(); //执行查询,返回结果集 _sqlDR = _sqlCmd.ExecuteReader(); return _sqlDR; } catch { //如果操作异常,则返回null return null; } } #endregion #region 使用SELECT语句查询,返回单个object字段 public static object GetSelectScalar(string strSql) { try { _sqlCmd = new SqlCommand(strSql, _sqlConnection); _sqlConnection.Open(); //返回结果集中的第一行第一列 return _sqlCmd.ExecuteScalar(); } catch (System.Exception ex) { MessageBox.Show(ex.Message); return null; } finally { _sqlConnection.Close(); } } #endregion }//Sqlserver类 }//SqlConn命名空间
时间: 2024-10-02 18:22:34