dataoperater.cs

c#的多线程采集源代码

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.OleDb;
using Microsoft.ApplicationBlocks.OleDb;
//该代码下载自 ：http://i.aspx1.com (asp.net学习社区)
namespace DataFactory
{
    public class DataOperater
    {
        public static string ConnString = System.Configuration.ConfigurationManager.AppSettings["DBConnectionString"].ToString();

        public DataOperater()
        {

        }

        /// <summary>
        /// 根据传过来的存储过程名称返回OleDbDataReader数据集
        /// </summary>
        /// <param name="ProcName">存储过程名称</param>
        /// <returns>OleDbDataReader</returns>
        public OleDbDataReader RunProc_DataReader(string ProcName)
        {
            OleDbDataReader dr;

            dr = OleDbHelper.ExecuteReader(ConnString, CommandType.StoredProcedure, ProcName, null);

            return dr;
        }

        /// <summary>
        /// 根据传过来的存储过程名称返回DataSet数据集
        /// </summary>
        /// <param name="ProcName">存储过程名称</param>
        /// <returns>DataSet</returns>
        public DataSet RunProc_DataSet(string ProcName)
        {
            DataSet ds = new DataSet();

            ds = OleDbHelper.ExecuteDataset(ConnString, CommandType.StoredProcedure, ProcName, null);

            return ds;
        }

        /// <summary>
        /// 根据传过来的查询语句名称返回OleDbDataReader数据集
        /// </summary>
        /// <param name="strsql">查询语句</param>
        /// <returns>OleDbDataReader</returns>
        public OleDbDataReader RunSql_DataReader(string strsql)
        {
            OleDbDataReader dr;

            dr = OleDbHelper.ExecuteReader(ConnString, CommandType.Text, strsql);

            return dr;
        }

        /// <summary>
        /// 根据传过来的"查询语句"返回DataSet数据集
        /// </summary>
        /// <param name="strsql">查询语句</param>
        /// <returns>DataSet</returns>
        public DataSet RunSql_DataSet(string strsql)
        {
            DataSet ds = new DataSet();

            ds = OleDbHelper.ExecuteDataset(ConnString, CommandType.Text, strsql);

            return ds;
        }

        /// <summary>
        /// 根据传过来的"存储过程名称"和"值/集合"返回OleDbDataReader数据集
        /// </summary>
        /// <param name="ProcName">存储过程名称</param>
        /// <param name="parameters">值/集合</param>
        /// <returns>OleDbDataReader</returns>
        public OleDbDataReader RunParaMeters_DataReader(string ProcName, params OleDbParameter[] parameters)
        {
            OleDbDataReader dr;

            dr = OleDbHelper.ExecuteReader(ConnString, CommandType.StoredProcedure, ProcName, parameters);

            return dr;
        }


        /// <summary>
        /// 根据传过来的"存储过程名称"和"值/集合"返回DataSet数据集
        /// </summary>
        /// <param name="ProcName">存储过程名称</param>
        /// <param name="parameters">值/集合</param>
        /// <returns>DataSet</returns>
        public DataSet RunParaMeters_DataSet(string ProcName, params OleDbParameter[] parameters)
        {
            DataSet ds = new DataSet();

            ds = OleDbHelper.ExecuteDataset(ConnString, CommandType.StoredProcedure, ProcName, parameters);

            parameters = null;

            return ds;
        }

        /// <summary>
        /// 根据传过来的"存储过程名称"和"值/集合"返回[Int]数值
        /// </summary>
        /// <param name="ProcName">存储过程名称</param>
        /// <param name="parameters">值/集合</param>
        /// <returns>int</returns>
        public int RunParaMeters_Int(string ProcName, OleDbParameter[] parameters)
        {
            int Count = 0;

            using (OleDbConnection conn = new OleDbConnection(ConnString))
            {
                conn.Open();
                using (OleDbTransaction trans = conn.BeginTransaction())
                {
                    try
                    {
                        Count = OleDbHelper.ExecuteNonQuery(trans, CommandType.StoredProcedure, ProcName, parameters);
                        trans.Commit();
                    }
                    catch
                    {
                        trans.Rollback();
                        throw;
                    }
                }

                conn.Close();
            }

            return Count;
        }
        /// <summary>
        /// 根据传过来的存储过程名称,返回Int数值
        /// </summary>
        /// <param name="ProcName">存储过程名称</param>
        /// <returns>Int</returns>
        public int RunProc_Int(string ProcName)
        {
            int Count = 0;

            using (OleDbConnection conn = new OleDbConnection(ConnString))
            {
                conn.Open();
                using (OleDbTransaction trans = conn.BeginTransaction())
                {
                    try
                    {
                        Count = OleDbHelper.ExecuteNonQuery(trans, CommandType.StoredProcedure, ProcName);
                        trans.Commit();
                    }
                    catch
                    {
                        trans.Rollback();
                        throw;
                    }
                }

                conn.Close();
            }

            return Count;
        }


        /// <summary>
        /// 根据传过来的查询语句,执行查询结果返回
        /// </summary>
        /// <param name="strOleDb">查询语句</param>
        /// <param name="bl">标识作用</param>
        /// <returns>Int</returns>
        public int RunSql_Int(string strsql)
        {
            int Count = 0;

            using (OleDbConnection conn = new OleDbConnection(ConnString))
            {
                conn.Open();
                using (OleDbTransaction trans = conn.BeginTransaction())
                {
                    try
                    {
                        Count = OleDbHelper.ExecuteNonQuery(trans, CommandType.Text, strsql);
                        trans.Commit();
                    }
                    catch
                    {
                        trans.Rollback();
                        throw;
                    }
                }

                conn.Close();
            }

            return Count;
        }

        /// <summary>
        /// 返回strSQL执行后结果集中的repeatestr1至repeatestr2的记录集DataSet
        /// </summary>
        /// <param name="strSQL">查询语句</param>
        /// <param name="repeatestr1">索引值1</param>
        /// <param name="repeatestr2">索引值2</param>
        /// <param name="tablename">DataSet表名</param>
        /// <returns>返回strSQL执行后结果集中的repeatestr1至repeatestr2的记录集DataSet</returns>
        public DataSet ExecuteSqlDsReapter(string strSQL, int repeatestr1, int repeatestr2, string tablename)
        {
            OleDbConnection myConn = new OleDbConnection(ConnString);
            OleDbCommand myCmd = new OleDbCommand(strSQL, myConn);
            try
            {
                myConn.Open();
                OleDbDataAdapter myDa = new OleDbDataAdapter(myCmd);
                DataSet dsReapter = new DataSet();
                myDa.Fill(dsReapter, repeatestr1, repeatestr2, tablename);
                return dsReapter;
            }
            catch 
            {
                //throw new Exception(e.Message);
                return null;
            }
            finally
            {
                myConn.Close();
            }
        }

        /// <summary>
        /// 返回strSQL执行后结果集DataSet
        /// </summary>
        /// <param name="strSQL"></param>
        /// <param name="tablename"></param>
        /// <returns></returns>
        public DataSet ExecuteSqlDsReapter(string strSQL, string tablename)
        {
            OleDbConnection myConn = new OleDbConnection(ConnString);
            OleDbCommand myCmd = new OleDbCommand(strSQL, myConn);
            try
            {
                myConn.Open();
                OleDbDataAdapter myDa = new OleDbDataAdapter(myCmd);
                DataSet dsReapter = new DataSet();
                myDa.Fill(dsReapter, tablename);
                return dsReapter;
            }
            catch
            {
                //throw new Exception(e.Message);
                return null;
            }
            finally
            {
                myConn.Close();
            }
        }

        /// <summary>
        /// 返回strSQL语句执行结果的第一个数值
        /// </summary>
        /// <param name="strSQL">Select Count(*) from Table</param>
        /// <returns>Count(*)</returns>
        public int ExecuteSqlDsReapter(string strSQL)
        {
            try
            {
                OleDbDataReader dr;
                dr = OleDbHelper.ExecuteReader(ConnString, CommandType.Text, strSQL);
                if (dr.Read())
                    return int.Parse(dr[0].ToString());
                else
                    return 0;
            }
            catch
            {
                //throw new Exception(e.Message);
                return 0;
            }
        }

        /// <summary>
        /// 数据库数据集更新
        /// </summary>
        /// <param name="strSql"></param>
        /// <param name="changedDataSet"></param>
        /// <returns></returns>
        public DataSet UpdateDataSet(string strSql,DataSet changedDataSet)
        {
            using (OleDbConnection connection = new OleDbConnection(ConnString))
            {
                using (OleDbDataAdapter da = new OleDbDataAdapter(strSql, connection))
                {
                    using (OleDbCommandBuilder CmdBld = new OleDbCommandBuilder(da))
                    {
                        try
                        {
                            da.Update(changedDataSet);
                            return changedDataSet;
                        }
                        catch
                        {
                            connection.Close();
                            //throw new Exception(e.Message);
                            return null;
                        }
                    }
                }
            }

        }

        /// <summary>
        /// 据传过来的查询语句和参数,执行查询结果返回
        /// </summary>
        /// <param name="strsql"></param>
        /// <param name="parameters">参数</param>
        /// <returns></returns>
        public int RunSql_Int(string strsql, OleDbParameter[] parameters)
        {
            int Count = 0;

            using (OleDbConnection conn = new OleDbConnection(ConnString))
            {
                conn.Open();
                using (OleDbTransaction trans = conn.BeginTransaction())
                {
                    try
                    {
                        Count = OleDbHelper.ExecuteNonQuery(trans, CommandType.Text, strsql, parameters);
                        trans.Commit();
                    }
                    catch
                    {
                        trans.Rollback();
                        throw;
                    }
                }

                conn.Close();
            }

            return Count;
        } 
    }
}