AccessHelper.cs

Posted 2020-11-25 lingtw

/*
 access 连接工具类
 */


using System;
using System.Collections.Generic;
using System.Text;
using System.Data.SqlClient;
using System.Data;
using System.Configuration.Assemblies;
using System.Text.RegularExpressions;
using System.Data.OleDb;


namespace OleDb
{
    public class AccessHelper
    {

        #region 连接字符串

        //如果异常是：未在本地计算机上注册“Microsoft.Jet.OLEDB.4.0”提供程序。请改变项目的平台为x86。http://www.cnblogs.com/buguge/p/4845997.html

        //mdb数据库
        private static readonly string ConStr =
            string.Format("Provider=Microsoft.Jet.OLEDB.4.0;Data Source={0}",
             "D:\\access.mdb");

        //accdb 数据库
        //private static readonly string ConStr =
        //    string.Format("Provider=Microsoft.ACE.OLEDB.12.0;Data Source={0};Persist Security Info=False;","路径\\db.accdb");
        #endregion

        #region 私有方法


        private string SqlExec(params OleDbCommand[] coms)
        {
            using (OleDbConnection con = new OleDbConnection(ConStr))
            {
                con.Open();
                OleDbTransaction st = con.BeginTransaction();
                string result = "";
                for (int i = 0; i < coms.Length; i++)
                {
                    coms[i].Connection = con;
                    coms[i].Transaction = st;
                }
                try
                {
                    foreach (OleDbCommand cmd in coms)
                    {
                        cmd.ExecuteNonQuery();
                    }
                    st.Commit();
                    result = string.Empty; //代表成功,返回空字符串
                }
                catch (Exception ex)
                {
                    result = ex.Message; //代表失败，返回错误信息
                    st.Rollback();
                }
                finally
                {
                    con.Close();
                }
                return result;

            }
        }




        /// <summary>
        /// 返回多条SQL语句执行后是否全部成功.
        /// </summary>
        /// <param name="sqlstrs">SQL语句</param>
        /// <returns></returns>
        private string GetNum(params String[] sqlstrs)
        {
            using (OleDbConnection con = new OleDbConnection(ConStr))
            {
                con.Open();

                OleDbTransaction st = con.BeginTransaction();
                string result = string.Empty;
                OleDbCommand[] myCommands = new OleDbCommand[sqlstrs.Length];
                for (int i = 0; i < sqlstrs.Length; i++)
                {
                    myCommands[i] = new OleDbCommand(sqlstrs[i], con);
                    myCommands[i].Transaction = st;
                }
                try
                {
                    foreach (OleDbCommand cmd in myCommands)
                    {
                        cmd.ExecuteNonQuery();
                    }
                    st.Commit();
                    result = string.Empty; //代表成功

                }
                catch (Exception ex)
                {
                    result = ex.Message; //代表失败，返回错误信息
                    st.Rollback();
                }
                finally
                {
                    con.Close();
                }
                return result;

            }
        }

        /// <summary>
        /// 分页使用
        /// </summary>
        /// <param name="query"></param>
        /// <param name="passCount"></param>
        /// <returns></returns>
        private static string recordID(string query, int passCount)
        {
            using (OleDbConnection con = new OleDbConnection(ConStr))
            {
                con.Open();
                OleDbCommand cmd = new OleDbCommand(query, con);
                string result = string.Empty;
                using (OleDbDataReader dr = cmd.ExecuteReader())
                {
                    while (dr.Read())
                    {
                        if (passCount < 1)
                        {
                            result += "," + dr.GetInt32(0);
                        }
                        passCount--;
                    }
                }
                con.Close();
                con.Dispose();
                return result.Substring(1);
            }
        }

        /// <summary>
        /// 添加给参数添加
        /// </summary>
        /// <param name="cmd"></param>
        /// <param name="par"></param>
        private static void SetParametersAddA(OleDbCommand cmd, OleDbParameter[] par)
        {
            if (par != null)
            {
                for (int i = 0; i < par.Length; i++)
                {
                    //cmd.Parameters.Add(par[i]);
                    cmd.Parameters.AddWithValue(par[i].ParameterName, par[i].Value); 
                }
            }
        }

        #endregion

        #region 公用方法

        /// <summary>
        /// 获取DataSet的函数
        /// </summary>
        /// <param name="sqlstr">执行查询的Sql语句</param>
        /// <param name="par">参数集合</param>
        /// <returns></returns>
        public DataSet GetDataSet(string sqlstr, params OleDbParameter[] par)
        {
            using (OleDbConnection con = new OleDbConnection(ConStr))
            {
                con.Open();
                using (OleDbCommand cmd = new OleDbCommand(sqlstr))
                {
                    cmd.Connection = con;

                    SetParametersAddA(cmd, par);

                    using (OleDbDataAdapter da = new OleDbDataAdapter(cmd))
                    {
                        DataSet ds = new DataSet();
                        da.Fill(ds);
                        return ds;
                    }
                }
            }
        }


        /// <summary>
        /// 执行sql
        /// </summary>
        /// <param name="sqlstr"></param>
        /// <param name="par"></param>
        /// <returns></returns>
        public string ExecSql(string sqlstr, params OleDbParameter[] par)
        {
            using (OleDbCommand cmd = new OleDbCommand(sqlstr))
            {
                SetParametersAddA(cmd, par);
                return this.SqlExec(cmd);
            }
        }

        public DataTable GetDataTable(string sqlstr, params OleDbParameter[] par)
        {
            return GetDataSet(sqlstr, par).Tables[0];
        }



        /// <summary>
        /// 返回多条SQL语句是否全部执行成功.
        /// </summary>
        /// <param name="Sqlstrs">SQL语句</param>
        /// <returns></returns>
        public string ReturnNum(params String[] Sqlstrs)
        {
            return this.GetNum(Sqlstrs);
        }


        #region ACCESS高效分页

        /// <summary>
        /// ACCESS高效分页
        /// </summary>
        /// <param name="pageIndex">当前页码</param>
        /// <param name="pageSize">分页容量</param>
        /// <param name="strKey">主键</param>
        /// <param name="showString">显示的字段</param>
        /// <param name="queryString">查询字符串，支持联合查询(多表需要加“（）”)</param>
        /// <param name="whereString">查询条件</param>
        /// <param name="par">参数</param>
        /// <param name="orderString">排序规则</param>
        /// <param name="pageCount">传出参数：总页数统计</param>
        /// <param name="recordCount">传出参数：总记录统计</param>
        /// <returns>装载记录的DataTable</returns>
        public static DataSet ExecutePager(int pageIndex, int pageSize, string strKey, string showString, string queryString, string whereString, OleDbParameter[] par, string orderString, out int pageCount, out int recordCount)
        {
            if (pageIndex < 1) pageIndex = 1;
            if (pageSize < 1) pageSize = 10;
            if (string.IsNullOrEmpty(showString)) showString = " * ";
            if (string.IsNullOrEmpty(orderString)) orderString = string.Format("{0} asc ", strKey);
            if (whereString.Length > 0)
            {
                whereString = string.Format(" where {0}" , whereString);
            }

            using (OleDbConnection con = new OleDbConnection(ConStr))
            {
                con.Open();
                string myVw = string.Format("  {0} as tempVw ", queryString);

                OleDbCommand cmdCount = new OleDbCommand(string.Format(" select count(*) as recordCount from {0} {1}", myVw, whereString), con);
                SetParametersAddA(cmdCount, par);

                recordCount = Convert.ToInt32(cmdCount.ExecuteScalar());


                if ((recordCount % pageSize) > 0)
                    pageCount = recordCount / pageSize + 1;
                else
                    pageCount = recordCount / pageSize;


                OleDbCommand cmdRecord;
                if (pageIndex == 1)//第一页
                {
                    cmdRecord = new OleDbCommand(string.Format("select top {0} {1} from {2} {3} order by {4} ", pageSize, showString, myVw, whereString, orderString), con);
                }
                else if (pageIndex > pageCount)//超出总页数
                {
                    cmdRecord = new OleDbCommand(string.Format("select top {0} {1} from {2} {3} order by {4} ", pageSize, showString, myVw, "where 1=2", orderString), con);
                }
                else
                {
                    int pageLowerBound = pageSize * pageIndex;
                    int pageUpperBound = pageLowerBound - pageSize;
                    string recordIDs = recordID(string.Format("select top {0} {1} from {2} {3} order by {4} ", pageLowerBound, strKey, myVw, whereString, orderString), pageUpperBound);
                    cmdRecord = new OleDbCommand(string.Format("select {0} from {1} where {2} in ({3}) order by {4} ", showString, myVw, strKey, recordIDs, orderString), con);
                }

                SetParametersAddA(cmdRecord, par);

                OleDbDataAdapter dataAdapter = new OleDbDataAdapter(cmdRecord);
                DataSet ds = new DataSet();
                dataAdapter.Fill(ds);
                con.Close();
                con.Dispose();
                return ds;
            }
        }

        #endregion


        #endregion

    }

}

#region 调用示例
/*
 //分页调用示例：
 
   private void bind()
        {
            string medcode = textBox3.Text.Trim();
            string keyName = textBox1.Text.Trim();
            string whereStr = " 1=1 ";

            List<OleDbParameter> parList=new List<OleDbParameter>();

            if (keyName.Length > 0)
            {
                whereStr += string.Format(" and (medname like ‘%‘+@medname+‘%‘  or  medname2 like ‘%‘+@medname+‘%‘ ) ");
                parList.Add(new OleDbParameter("medname", keyName));
            }

            if (medcode.Length > 0)
            {
                whereStr += string.Format("  and medcode =@medcode  ", medcode);
                parList.Add(new OleDbParameter("medcode", medcode));
            }


            int pagecount = 0;
            int dataCount = 0;
            DataSet ds = AccessHelper.ExecutePager(pagingControl1.PageIndex, pagingControl1.PageSize, "id", "*",
                "med_main",
               whereStr, parList.ToArray(), "id", out pagecount, out dataCount);

            pagingControl1.BindGird(dataGridView1, ds.Tables[0], dataCount);

        } 
 

 


 
//执行sql示例：
 
   OleDb.AccessHelper helper = new AccessHelper();
            if (string.IsNullOrEmpty(_id)) //添加 
            {
                string sql = string.Format(@"insert into med_main(medname,medcode,mednum,medname2,medcode2,mednum2) 
                                                                    values(@medname,@medcode,@mednum,@medname2,@medcode2,@mednum2) ");
                OleDbParameter[] parameters=
                {
                    new OleDbParameter("medname",medname),
                    new OleDbParameter("medcode",medcode),
                    new OleDbParameter("mednum",txb_num1.Text),
                    new OleDbParameter("medname2",medname2),
                    new OleDbParameter("medcode2",medcode2),
                    new OleDbParameter("mednum2",txb_num2.Text),
                };

                string errorInfo = helper.ExecSql(sql, parameters);
                if (errorInfo.Length == 0)
                {
                    MessageBox.Show("设置成功！");
                    resite();
                }
                else
                {
                    MessageBox.Show("设置失败！" + errorInfo);
                }

            }
*/
#endregion