sqldbbaseconnection.cs

高校 学籍管理、成绩、收费、网上教学

        public void CommandDispose()
        {
            if (command != null)
            {
                SqlConnection connection = command.Connection;
                Debug.Assert(connection != null);
                command.Dispose();
                command = null;
                //connection.Dispose();
            }
        }
    }
}


/*
 public class SqlDBBaseConnection
    {
        private string dlConnectionString;
        public SqlConnection conn;
        public SqlTransaction objTranse;
        public SqlCommand command;

        public SqlDBBaseConnection()
        {
            conn = null;
            objTranse = null;
        }

        public SqlDBBaseConnection(SqlConnection conn)
        {
            this.conn = conn;
            objTranse = null;
        }

        public SqlDBBaseConnection(SqlConnection conn, SqlTransaction objTranse)
        {
            if (conn != null && objTranse !=null)
            {
                this.conn = conn;
                this.objTranse = objTranse;
            }
           
        }

        /// <summary>
        /// 定义连接字符串
        /// </summary>
        public string DLConnctionString
        {
            get
            {

               // return dlConnectionString = ConfigurationManager.AppSettings["Deaiedu.Server.ConnectionStrings.Sql"];
                return dlConnectionString = "Data Source=192.168.1.200;Initial Catalog=Student;User ID=sa;pwd=123";
            }
        }

        /// <summary>
        /// 打开数据库连接
        /// </summary>
        public SqlConnection Connection()
        {
            try
            {
                if (conn == null)
                {
                    conn = new SqlConnection(this.DLConnctionString);
                    conn.Open();
                }
            }
            catch (Exception ex)
            {

                throw ex;
            }
            return conn;
        }

        /// <summary>
        /// 开始事务
        /// </summary>
        public void BeginTranse()
        {
            objTranse = conn.BeginTransaction();
        }

        /// <summary>
        /// 提交事务
        /// </summary>
        public void CommitTranse()
        {
            if (objTranse != null)
            {
                if (objTranse.Connection != null)
                {
                    objTranse.Commit();
                }
            }
        }

        /// <summary>
        /// Rollback事务
        /// </summary>
        public void RollbackTranse()
        {
            if (objTranse != null)
            {
                if (objTranse.Connection != null)
                {
                    objTranse.Rollback();
                }
            }
        }

        /// <summary>
        /// 释放数据连接
        /// </summary>
        public void CloseConnection()
        {
            try
            {
                if (conn != null)
                {

                    conn.Close();
                    conn.Dispose();
                    conn = null;
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 设置存储过程参数
        /// </summary>
        /// <param name="stroedName">存储过程名字</param>
        /// <param name="parameters">存储过程参数数组</param>
        public void StroedProdedure(string stroedName, SqlParameter[] parameters)
        {
            command = new SqlCommand(stroedName, this.conn, this.objTranse);
            command.CommandType = CommandType.StoredProcedure;
            foreach (SqlParameter parameter in parameters)
            {
                command.Parameters.Add(parameter);
            }
            command.Parameters.Add(new SqlParameter("ReturnValue", SqlDbType.Int, 4,
                ParameterDirection.ReturnValue, false, 4, 5, string.Empty, DataRowVersion.Default, 9));
            //command.Connection.Open();
        }

        //public DataSet ReadTable(string keyName,string tableName)
        //{
        //    //SqlDataReader reader = command.ExecuteReader(CommandBehavior.SchemaOnly);
        //    //DataTable dataTalbeschema = conn.GetSchema(aa,new object[]{null,null,null,"Table"}
        //    DataSet objdataset = new DataSet();
        //    string sqlValue = string.Format("Select * From {0} Where {1} = -1", tableName, keyName);
        //    command = new SqlCommand(sqlValue, this.conn, this.objTranse);
        //    SqlDataAdapter objData = new SqlDataAdapter();
        //    objData.SelectCommand = command;
        //    objData.Fill(objdataset, tableName);
        //    return objdataset;
        //}

        /// <summary>
        /// 执行存储过程,返回标识
        /// </summary>
        /// <returns></returns>
        public int Run()
        {
            if (command == null)
                throw new ObjectDisposedException(GetType().FullName);
            command.ExecuteNonQuery();
            return (int)command.Parameters["ReturnValue"].Value;
        }

        public bool Run(string panduan)
        {
            if (command == null)
                throw new ObjectDisposedException(GetType().FullName);
            command.ExecuteNonQuery();
            return true;
        }
        public object RunSQL(string strSQL)
        {
            SqlCommand cmd = new SqlCommand(strSQL,Connection());
            object obj = cmd.ExecuteScalar();
            cmd.Dispose();
            return obj;
        }

        /// <summary>
        /// 执行存储过程,并填充数据
        /// </summary>
        /// <param name="objDataTable"></param>
        /// <returns></returns>
        public void Run(DataSet objDataSet, string sqlValue, string tableName)
        {
            //			if( command == null )
            //				throw new ObjectDisposedException( GetType().FullName );

            SqlDataAdapter objDataAdapter = new SqlDataAdapter(sqlValue, Connection());
            objDataAdapter.Fill(objDataSet, tableName);

        }
        public DataSet RunDS(string tableName)
        {
            DataSet ds = new DataSet();
            SqlDataAdapter objDataAdapter = new SqlDataAdapter(command);
            objDataAdapter.Fill(ds, tableName);
            return ds;
        }

        public DataSet Run(string sqlValue, string TableName)
        {
            DataSet objdataset = new DataSet();
            command = new SqlCommand(sqlValue,this.conn,this.objTranse);
            SqlDataAdapter objData= new SqlDataAdapter();
            objData.SelectCommand = command;
            objData.Fill(objdataset, TableName);
            return objdataset;
        }

        /// <summary>
        /// 执行SQL语句
        /// </summary>
        /// <param name="sqlValue">SQL命令</param>
        /// <param name="tableName">表名</param>
        /// <returns>执行SQL命令后返回的行数，返回-1表示SQL命令为空</returns>
        public int run(string sqlValue, string tableName)
        {
            if (sqlValue == "" || sqlValue == null)
            {
                //返回-1，表示SQL命令为空
                return -1;
            }
            command = new SqlCommand(sqlValue, this.conn, this.objTranse);
            int rows = command.ExecuteNonQuery();
            
            return rows;
        }

        /// <summary>
        /// 释放command对象
        /// </summary>
        public void CommandDispose()
        {
            if (command != null)
            {
                SqlConnection connection = command.Connection;
                Debug.Assert(connection != null);
                command.Dispose();
                command = null;
                connection.Dispose();
            }
        }
    }
 */