C# 读取本地mdb文件

骑猪看日落 2022-09-05 04:29 233阅读 0赞

## 1.添加工具类MDBHelp.cs ##

using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Data;
    using System.Data.OleDb;
    namespace CPKFLandCheck.src.utils
    {
        public class MDBHelp
        {
            private string _fileName;
            private string _connectionString;
            private OleDbConnection _odcConnection;
    
    
            /// <summary>
            /// 构建函数
            /// </summary>
            /// <param name="fileName">MDB文件（含完整路径）</param>
            public MDBHelp(string fileName)
            {
                this._fileName = fileName;
                this._connectionString = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + fileName + ";";
            }
    
            public MDBHelp()
            {
                string fileName = "src//db//db.mdb";
                this._fileName = fileName;
                this._connectionString = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + fileName + ";";
            }
    
    
            /// <summary>
            /// 建立连接（打开数据库文件）
            /// </summary>
            public void Open()
            {
                try
                {
                    // 建立连接
                    this._odcConnection = new OleDbConnection(this._connectionString);
                    // 打开连接
                    this._odcConnection.Open();
                }
                catch (Exception)
                {
                    throw new Exception("尝试打开 " + this._fileName + " 失败, 请确认文件是否存在！");
                }
            }
    
    
            /// <summary>
            /// 断开连接（关闭据库文件）
            /// </summary>
            public void Close()
            {
                this._odcConnection.Close();
            }
    
    
            /// <summary>
            /// 根据sql命令返回一个DataSet
            /// </summary>
            /// <param name="sql">sql命令</param>
            /// <returns>以DataTable形式返回数据</returns>
            public DataSet GetDataSet(string sql)
            {
                Open();//打开连接
                DataSet ds = new DataSet();
                try
                {
                    OleDbDataAdapter adapter = new OleDbDataAdapter(sql, this._odcConnection);
                    adapter.Fill(ds);
                }
                catch (Exception ex)
                {
                    throw new Exception("sql语句： " + sql + " 执行失败！");
                }
                Close();//关闭连接
                return ds;
            }
        }    
    }

## 2.工具类的使用 ##

MDBHelp mdbHelp = new MDBHelp();
     var db = mdbHelp.GetDataSet("select ERROR_CODE,ERROR_REQUIRE from CPKF_ERROR where ERROR_REQUIRE_CONTENT is null order by ID");
    
     foreach (DataTable dt in db.Tables)
     {
         foreach (DataRow dr in dt.Rows) //遍历所有的行
         {
             String ErrorCode = dr.ItemArray[0].ToString();
             String ErrorRequire = dr.ItemArray[1].ToString();
             var node = new TreeNode(ErrorCode + " " + ErrorRequire);
             treeView.Nodes.Add(node);
         }
     }