zoukankan      html  css  js  c++  java
  • c#操作Access[上]

    看到CSDN上不断兄弟姐妹提问关于c#操作Access的问题,于是本人利用闲暇将c#操作Access的方法加以总结,主要解决的问题有:
    创建mdb
    创建table
    读取table内容
    查询table中的内容
    向table中插入数据
    删除table中的记录
    向table中插入照片
    读取table中的照片等。
    另:本人水平有限,不当之处还请斧正。废话少说,开始正题。

    文介绍C#访问操作Access数据库的基础知识,并提供一个相关的例程。C#的ADO.NET还不能通过编程方式创建全新的ACCESS(MDB)数据库,所以还只能使用ADOX这个来自COM的链接库来操作。
    主要知识点如下:
    using System.Data.OleDb;
    using System.Data;
    连接字符串:String connectionString = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=product.mdb";
    建立连接:OleDbConnection connection = new OleDbConnection(connectionString);
    使用OleDbCommand类来执行Sql语句:
    OleDbCommand cmd = new OleDbCommand(sql, connection);
    connection.Open();
    cmd.ExecuteNonQuery();

    1.创建mdb库,例程如下:
    需要注意的是:参数mdbPath是mdb的完整路径(不包含表的名称)。例如:D:\\test.mdb

    view plaincopy to clipboardprint?
    //创建mdb   
     public static bool CreateMDBDataBase(string mdbPath)  
     {  
         try 
         {  
             ADOX.CatalogClass cat = new ADOX.CatalogClass();  
             cat.Create("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + mdbPath + ";");  
             cat = null;  
             return true;  
         }  
         catch { return false; }  
     } 
           //创建mdb
            public static bool CreateMDBDataBase(string mdbPath)
            {
                try
                {
                    ADOX.CatalogClass cat = new ADOX.CatalogClass();
                    cat.Create("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + mdbPath + ";");
                    cat = null;
                    return true;
                }
                catch { return false; }
            }
     

    2.创建具体的表,例程如下:
    通常一个mdb的可以包含n个表。下面的程序主要是创建一个table。
    view plaincopy to clipboardprint?
    //新建mdb的表   
    //mdbHead是一个ArrayList,存储的是table表中的具体列名。   
    public static bool CreateMDBTable(string mdbPath,string tableName, ArrayList mdbHead)  
    {  
        try 
        {  
            ADOX.CatalogClass cat = new ADOX.CatalogClass();  
            string sAccessConnection  
                = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + mdbPath;  
            ADODB.Connection cn = new ADODB.Connection();  
            cn.Open(sAccessConnection, null, null, -1);  
            cat.ActiveConnection = cn;  
     
            //新建一个表   
            ADOX.TableClass tbl = new ADOX.TableClass();  
            tbl.ParentCatalog = cat;  
            tbl.Name = tableName;  
     
            int size = mdbHead.Count;  
            for (int i = 0; i < size; i++)  
            {  
                //增加一个文本字段   
                ADOX.ColumnClass col2 = new ADOX.ColumnClass();  
                col2.ParentCatalog = cat;  
                col2.Name = mdbHead[i].ToString();//列的名称   
                col2.Properties["Jet OLEDB:Allow Zero Length"].Value = false;  
                tbl.Columns.Append(col2, ADOX.DataTypeEnum.adVarWChar, 500);  
            }  
            cat.Tables.Append(tbl);   //这句把表加入数据库(非常重要)   
            tbl = null;  
            cat = null;  
            cn.Close();  
            return true;  
        }  
        catch { return false; }  

            //新建mdb的表
            //mdbHead是一个ArrayList,存储的是table表中的具体列名。
            public static bool CreateMDBTable(string mdbPath,string tableName, ArrayList mdbHead)
            {
                try
                {
                    ADOX.CatalogClass cat = new ADOX.CatalogClass();
                    string sAccessConnection
                        = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + mdbPath;
                    ADODB.Connection cn = new ADODB.Connection();
                    cn.Open(sAccessConnection, null, null, -1);
                    cat.ActiveConnection = cn;

                    //新建一个表
                    ADOX.TableClass tbl = new ADOX.TableClass();
                    tbl.ParentCatalog = cat;
                    tbl.Name = tableName;

                    int size = mdbHead.Count;
                    for (int i = 0; i < size; i++)
                    {
                        //增加一个文本字段
                        ADOX.ColumnClass col2 = new ADOX.ColumnClass();
                        col2.ParentCatalog = cat;
                        col2.Name = mdbHead[i].ToString();//列的名称
                        col2.Properties["Jet OLEDB:Allow Zero Length"].Value = false;
                        tbl.Columns.Append(col2, ADOX.DataTypeEnum.adVarWChar, 500);
                    }
                    cat.Tables.Append(tbl);   //这句把表加入数据库(非常重要)
                    tbl = null;
                    cat = null;
                    cn.Close();
                    return true;
                }
                catch { return false; }
            }

    3.读取mdb内容(完全读取),例程如下:
    本例程返回的是一个DataTable,如需其他格式可以自行转换。
    view plaincopy to clipboardprint?
    // 读取mdb数据   
    public static DataTable ReadAllData(string tableName, string mdbPath,ref bool success)  
    {  
        DataTable dt = new DataTable();  
        try 
        {  
            DataRow dr;  
            //1、建立连接   
            string strConn  
                = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + mdbPath + ";Jet OLEDB:Database Password=haoren";  
            OleDbConnection odcConnection = new OleDbConnection(strConn);  
            //2、打开连接   
            odcConnection.Open();  
            //建立SQL查询   
            OleDbCommand odCommand = odcConnection.CreateCommand();  
            //3、输入查询语句   
            odCommand.CommandText = "select * from " + tableName;  
            //建立读取   
            OleDbDataReader odrReader = odCommand.ExecuteReader();  
            //查询并显示数据   
            int size = odrReader.FieldCount;  
            for (int i = 0; i < size; i++)  
            {  
                DataColumn dc;  
                dc = new DataColumn(odrReader.GetName(i));  
                dt.Columns.Add(dc);  
            }  
            while (odrReader.Read())  
            {  
                dr = dt.NewRow();  
                for (int i = 0; i < size; i++)  
                {  
                    dr[odrReader.GetName(i)] = odrReader[odrReader.GetName(i)].ToString();  
                }  
                dt.Rows.Add(dr);  
            }  
            //关闭连接   
            odrReader.Close();  
            odcConnection.Close();  
            success = true;  
            return dt;  
        }  
        catch 
        {  
            success = false;  
            return dt;  
        }  

            // 读取mdb数据
            public static DataTable ReadAllData(string tableName, string mdbPath,ref bool success)
            {
                DataTable dt = new DataTable();
                try
                {
                    DataRow dr;
                    //1、建立连接
                    string strConn
                        = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + mdbPath + ";Jet OLEDB:Database Password=haoren";
                    OleDbConnection odcConnection = new OleDbConnection(strConn);
                    //2、打开连接
                    odcConnection.Open();
                    //建立SQL查询
                    OleDbCommand odCommand = odcConnection.CreateCommand();
                    //3、输入查询语句
                    odCommand.CommandText = "select * from " + tableName;
                    //建立读取
                    OleDbDataReader odrReader = odCommand.ExecuteReader();
                    //查询并显示数据
                    int size = odrReader.FieldCount;
                    for (int i = 0; i < size; i++)
                    {
                        DataColumn dc;
                        dc = new DataColumn(odrReader.GetName(i));
                        dt.Columns.Add(dc);
                    }
                    while (odrReader.Read())
                    {
                        dr = dt.NewRow();
                        for (int i = 0; i < size; i++)
                        {
                            dr[odrReader.GetName(i)] = odrReader[odrReader.GetName(i)].ToString();
                        }
                        dt.Rows.Add(dr);
                    }
                    //关闭连接
                    odrReader.Close();
                    odcConnection.Close();
                    success = true;
                    return dt;
                }
                catch
                {
                    success = false;
                    return dt;
                }
            }

    4.读取mdb内容(按列读取),例程如下:
    columns数组存储的是你要查询的列名称(必须确保mdb表中存在你要的列)

    view plaincopy to clipboardprint?
    // 读取mdb数据   
    public static DataTable ReadDataByColumns(string mdbPaht,string tableName, string[] columns, ref bool success)  
    {  
        DataTable dt = new DataTable();  
        try 
        {  
            DataRow dr;  
            //1、建立连接   
            string strConn  
                = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + mdbPath + ";Jet OLEDB:Database Password=haoren";  
            OleDbConnection odcConnection = new OleDbConnection(strConn);  
            //2、打开连接   
            odcConnection.Open();  
            //建立SQL查询   
            OleDbCommand odCommand = odcConnection.CreateCommand();  
            //3、输入查询语句   
            string strColumn = "";  
            for (int i = 0; i < columns.Length; i++)  
            {  
                strColumn += columns[i].ToString() + ",";  
            }  
            strColumn = strColumn.TrimEnd(',');  
            odCommand.CommandText = "select "+strColumn+" from " + tableName;  
            //建立读取   
            OleDbDataReader odrReader = odCommand.ExecuteReader();  
            //查询并显示数据   
            int size = odrReader.FieldCount;  
            for (int i = 0; i < size; i++)  
            {  
                DataColumn dc;  
                dc = new DataColumn(odrReader.GetName(i));  
                dt.Columns.Add(dc);  
            }  
     
            while (odrReader.Read())  
            {  
                dr = dt.NewRow();  
                for (int i = 0; i < size; i++)  
                {  
                    dr[odrReader.GetName(i)] = odrReader[odrReader.GetName(i)].ToString();  
                }  
                dt.Rows.Add(dr);  
            }  
            //关闭连接   
            odrReader.Close();  
            odcConnection.Close();  
            success = true;  
            return dt;  
        }  
        catch 
        {  
            success = false;  
            return dt;  
        }  

            // 读取mdb数据
            public static DataTable ReadDataByColumns(string mdbPaht,string tableName, string[] columns, ref bool success)
            {
                DataTable dt = new DataTable();
                try
                {
                    DataRow dr;
                    //1、建立连接
                    string strConn
                        = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + mdbPath + ";Jet OLEDB:Database Password=haoren";
                    OleDbConnection odcConnection = new OleDbConnection(strConn);
                    //2、打开连接
                    odcConnection.Open();
                    //建立SQL查询
                    OleDbCommand odCommand = odcConnection.CreateCommand();
                    //3、输入查询语句
                    string strColumn = "";
                    for (int i = 0; i < columns.Length; i++)
                    {
                        strColumn += columns[i].ToString() + ",";
                    }
                    strColumn = strColumn.TrimEnd(',');
                    odCommand.CommandText = "select "+strColumn+" from " + tableName;
                    //建立读取
                    OleDbDataReader odrReader = odCommand.ExecuteReader();
                    //查询并显示数据
                    int size = odrReader.FieldCount;
                    for (int i = 0; i < size; i++)
                    {
                        DataColumn dc;
                        dc = new DataColumn(odrReader.GetName(i));
                        dt.Columns.Add(dc);
                    }

                    while (odrReader.Read())
                    {
                        dr = dt.NewRow();
                        for (int i = 0; i < size; i++)
                        {
                            dr[odrReader.GetName(i)] = odrReader[odrReader.GetName(i)].ToString();
                        }
                        dt.Rows.Add(dr);
                    }
                    //关闭连接
                    odrReader.Close();
                    odcConnection.Close();
                    success = true;
                    return dt;
                }
                catch
                {
                    success = false;
                    return dt;
                }
            }
     

    今天就简单写到这里,以后我会将内容补充完整。

    补充一句:转载的朋友请一定注明出处谢谢!半支烟阿杰 http://blog.csdn.net/gisfarmer/

  • 相关阅读:
    字符串_操作
    Error: Cannot find module 'webpack-cli/bin/config-yargs'
    ElementUI-Table 表头无法编辑问题
    ElementUI-Cascader组件同时支持懒加载和选择任意一级 问题踩坑
    vue强制刷新子组件
    footer部分,当页面主题内容不满一屏时,始终位于页面底部
    未知宽高的元素水平垂直居中方法总结
    fix元素居中
    link和@import引入css的区别
    Jquery拓展方法
  • 原文地址:https://www.cnblogs.com/chengulv/p/1787031.html
Copyright © 2011-2022 走看看