using System;using System.Collections.Generic;using System.Text;using System.Data;using System.Data.Common;using System.Configuration;using System.Transactions;namespace BrightData.CellData.CityPlanning.DBUtility{    class DBHelper : IDB    {        String connString = ConfigurationManager.ConnectionStrings["connStr"].ConnectionString;        String providerName = ConfigurationManager.ConnectionStrings["connStr"].ProviderName;        IDbCommand IDB.CreateCommand()        {            return CreateDBCommand();        }        private IDbCommand CreateDBCommand()        {            return CreateDBCommand(null, null);        }        private IDbCommand CreateDBCommand(String[] names, Object[] values)        {            try            {                DbProviderFactory factory = DbProviderFactories.GetFactory(providerName);                IDbConnection iconn = factory.CreateConnection();                iconn.ConnectionString = connString;                IDbCommand icmd = iconn.CreateCommand();                if (names != null && values != null)                {                    for (int i = 0; i < names.Length; i++)                    {                        IDbDataParameter iParameter = icmd.CreateParameter();                        iParameter.ParameterName = ":" + names[i];                        iParameter.Value = values[i];                        icmd.Parameters.Add(iParameter);                    }                }                icmd.Connection.Open();                return icmd;            }            catch (Exception ex)            {                System.IO.File.AppendAllText(@"D:\5.txt", ex.Message);                System.Diagnostics.Trace.WriteLine(ex.Message);                return null;            }        }        /// <summary>        /// 添加，删除，更新        /// </summary>        /// <param name="sql"></param>        /// <returns></returns>        int IDB.ExecuteNonQuery(string sql)        {            IDbCommand icmd = CreateDBCommand();            if (icmd != null)            {                try                {                    //using (TransactionScope sop = new TransactionScope())                    //{                    //    sop.Complete();                    //}                    icmd.CommandText = sql;                    return icmd.ExecuteNonQuery();                }                catch (Exception ex)                {                    System.Diagnostics.Trace.WriteLine(ex.Message);                    return -99;                }                finally                {                    icmd.Connection.Close();                }            }            return -99;        }        IDataReader IDB.ExecuteReader(string sql)        {            Console.WriteLine(sql);            IDbCommand icmd = CreateDBCommand();            if (icmd != null)            {                try                {                    icmd.CommandText = sql;                    return icmd.ExecuteReader(CommandBehavior.CloseConnection);                }                catch (Exception ex)                {                    System.IO.File.AppendAllText(@"D:\1.txt", ex.Message);                    System.Diagnostics.Trace.WriteLine(ex.Message);                    icmd.Connection.Close();                    return null;                }            }            return null;        }        object IDB.ExecuteScalar(string sql)        {            IDbCommand icmd = CreateDBCommand();            if (icmd != null)            {                try                {                    icmd.CommandText = sql;                    return icmd.ExecuteScalar();                }                catch (Exception ex)                {                    System.Diagnostics.Trace.WriteLine(ex.Message);                }                finally                {                    icmd.Connection.Close();                }            }            return null;        }        int IDB.ExecuteNonQuery(string sql, string[] names, object[] values)        {            IDbCommand icmd = CreateDBCommand(names, values);            if (icmd != null)            {                try                {                    icmd.CommandText = sql;                    return icmd.ExecuteNonQuery();                }                catch (Exception ex)                {                    System.Diagnostics.Trace.WriteLine(ex.Message);                    return -99;                }                finally                {                    icmd.Connection.Close();                }            }            return -99;        }        IDataReader IDB.ExecuteReader(string sql, string[] names, object[] values)        {            IDbCommand icmd = CreateDBCommand(names, values);            if (icmd != null)            {                try                {                    icmd.CommandText = sql;                    return icmd.ExecuteReader(CommandBehavior.CloseConnection);                }                catch (Exception ex)                {                    System.Diagnostics.Trace.WriteLine(ex.Message);                    icmd.Connection.Close();                    return null;                }            }            return null;        }                void IDB.setConnString(string conn)        {            connString = conn;        }        void IDB.setConnDrive(string Drive)        {            providerName = Drive;        }    }}