1. 首页
  2. 文章中心
  3. Other

C#将excel数据导入mdb的三种方法（针对5万条数据）

77 阅读 0 评论
我是靠谱客的博主 美丽小馒头，这篇文章主要介绍C#将excel数据导入mdb的三种方法（针对5万条数据），现在分享给大家，希望可以做个参考。

问题描述：将存有5.6万条的excel表数据导入mdb中

解决办法：

1.DAO。优点：速度快，5.6万条数据，也就不到一分钟，缺点：对于我来说，本机编译好的exe不能在其他电脑运行，最后查出来是DAO的问题。

2.用事务。优点：不依赖于DAO，直接靠using System.Data.OleDb;就能解决，速度为5.6万条数据455秒，缺点：速度慢，在所有行插入完之前，mdb中看不到进度情况。

3.用adapter.Update()。优点：不依赖于DAO,直接靠using System.Data.OleDb,DataTable改变，mdb中的表就能跟着改变，速度为5.6万条数据578秒，能在插入过程中看到进度情况，缺点：速度慢，DataTable的改变也是不断插入行才行，曾试图采用DataTable.Merge（datatable），结果mdb不更新。

详细代码：

1.DAO

复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Data.OleDb;
using System.IO;
using OSGeo.GDAL;
using OSGeo.OGR;
using DAO = Microsoft.Office.Interop.Access.Dao;
using System.Collections;
using System.Runtime.InteropServices;
using System.Diagnostics;


//定义
DAO.Database db;

            db = dbEngine.OpenDatabase(filepath);
            string tablename_encoding = "行政编码表";
//dt_excel获取方法与后面两个例子一致
            Recordset rs1 = db.OpenRecordset(tablename_encoding);
            Field[] myfields_1 = new Field[dt_excel.Columns.Count];
            for (int i = 0; i < dt_excel.Columns.Count; i++)
            {
                myfields_1[i] = rs1.Fields[dt_excel.Columns[i].ColumnName];
            }
            for (int i = 0; i < dt_excel.Rows.Count; i++)
            {
                rs1.AddNew();
                for (int j = 0; j < myfields_1.Length; j++)
                {
                    myfields_1[j].Value = dt_excel.Rows[i][j];
                }
                rs1.Update();
            }
            rs1.Close();

2.事务

复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
using System;
using System.Collections;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Data.OleDb;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace 将excel批量插入mdb
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs e)
        {
//设置要导入到mdb的excel路径
            string path_excel = @"C:UsersAdministratorDesktop新建文件夹TestData附件三：河南省行政编码表.xlsx";
//设置要导入的mdb文件路径
            string path_mdb = @"C:UsersAdministratorDesktop新建文件夹TestData00012中华财险保险公司承保数据20200810.mdb";
//读取excel内容到DataTable
            DataTable dt_excel = GetExcelTable(path_excel, "行政编码表");
//建立mdb数据库连接
            OleDbConnection ole_mdb = GetMdb(path_mdb);
            //1.根据dt_excel 在mdb中创建表结构
            string sql = "create table " + "行政编码表" + "(";
            for (int i = 0; i < dt_excel.Columns.Count; i = i + 1)
            {
                sql += dt_excel.Columns[i].ColumnName + " varchar(40),";
            }
            sql = sql.Substring(0, sql.Length - 1);
            sql += ")";
            OleDbCommand cmd = new OleDbCommand(sql, ole_mdb);
            cmd.ExecuteNonQuery();
//计时工具，启动
            int startTime = System.Environment.TickCount;
            //2.批量插入数据
//对于dt_excel中的每一行，写插入语句，并存放在ArrayList 中
            ArrayList sqllist = new ArrayList();
            for (int i=0;i<dt_excel.Rows.Count;i++) {
                sql = "INSERT INTO 行政编码表 (县名称, 管辖区名称, 乡镇名称, 村名称,行政村编码 ) " +"VALUES ("" + dt_excel.Rows[i][0].ToString() + """ +

                              ","" + dt_excel.Rows[i][1].ToString() + """ +

                              ","" + dt_excel.Rows[i][2].ToString() + """ +

                              ","" + dt_excel.Rows[i][3].ToString() + """ +

                              ","" + dt_excel.Rows[i][4].ToString() + "")";
                sqllist.Add(sql);
            }
//用事务挨个插入sqllist中的数据并提交
            insertToStockDataByBatch(sqllist,ole_mdb);
//计时工具，停止
            int endTime = System.Environment.TickCount;
            int runTime = (endTime - startTime) / 1000;
            MessageBox.Show("用时：" + runTime + "秒");
        }
//方法：将excel转为datatable
        public DataTable GetExcelTable(string excelFilename, string tableName)
        {
            //建立与指定Excel文件的连接
            string connectionString = string.Format("Provider=Microsoft.ACE.OLEDB.12.0;Data Source={0};Jet OLEDB:Engine Type=35;Extended Properties=Excel 8.0;Persist Security Info=False", excelFilename);
            DataSet ds = new DataSet();  //数据集
            //using中声明的对象connection，在using语句块结束后会自动释放
            using (System.Data.OleDb.OleDbConnection connection = new System.Data.OleDb.OleDbConnection(connectionString))
            {
                connection.Open();
                //获取数据库架构信息，包括列、主键、表等信息
                DataTable table = connection.GetOleDbSchemaTable(System.Data.OleDb.OleDbSchemaGuid.Tables, null);

                string strExcel = "select * from " + "[" + tableName + "$]";
                //打开数据链接，得到一个数据集
                OleDbDataAdapter adapter = new OleDbDataAdapter(strExcel, connectionString);
                //在数据集中查询表名为tableName的表，然后把其数据在装入数据集ds中
                adapter.Fill(ds, tableName);

                connection.Close();
            }
            return ds.Tables[tableName];//以datatable类型返回数据集ds中表名为tableName的表
        }
//方法：连接到mdb数据库
        public OleDbConnection GetMdb(string filepath)
        {
            try
            {
                string sqlcon = "Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + filepath + "; Persist Security Info =False";
                OleDbConnection ole_mdb = new OleDbConnection(@sqlcon);
                ole_mdb.Open();
                MessageBox.Show(filepath + "--读取成功");
                //db = dbEngine.OpenDatabase(filepath);
                return ole_mdb;
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
                return null;
            }
        }
//方法：打开mdb连接，启动事务，逐行插入，提交事务
public  void insertToStockDataByBatch(ArrayList sqlArray,OleDbConnection oleDb)
        {
            try
            {
                if (oleDb.State==ConnectionState.Closed) { oleDb.Open(); }
                OleDbTransaction transaction = oleDb.BeginTransaction();
                OleDbCommand aCommand = new OleDbCommand();
                aCommand.Connection = oleDb;
                aCommand.Transaction = transaction;
                for (int i = 0; i < sqlArray.Count; i++)
                {
                    aCommand.CommandText = sqlArray[i].ToString();
                    aCommand.ExecuteNonQuery();
                }
                transaction.Commit();
                oleDb.Close();
            }
            catch (Exception e)
            {
                MessageBox.Show(e.Message);
            }

        }
    }
}

 3.adapter.Update()

复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
using System;
using System.Collections;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Data.OleDb;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace 将excel批量插入mdb
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs e)
        {
            string path_excel = @"C:UsersAdministratorDesktop新建文件夹TestData附件三：河南省行政编码表.xlsx";
            string path_mdb = @"C:UsersAdministratorDesktop新建文件夹TestData00012中华财险保险公司承保数据20200810.mdb";
            DataTable dt_excel = GetExcelTable(path_excel, "行政编码表");
            OleDbConnection ole_mdb = GetMdb(path_mdb);
            //开始尝试塞进去
            //1.在mdb中创建表结构
            string sql = "create table " + "行政编码表" + "(";
            for (int i = 0; i < dt_excel.Columns.Count; i = i + 1)
            {
                sql += dt_excel.Columns[i].ColumnName + " varchar(40),";
            }
            sql = sql.Substring(0, sql.Length - 1);
            sql += ")";
            OleDbCommand cmd = new OleDbCommand(sql, ole_mdb);
            cmd.ExecuteNonQuery();
            int startTime = System.Environment.TickCount;

            //2.批量插入数据
            CreateCmdsAndUpdate(ole_mdb, "select * from [行政编码表]", dt_excel);
            int endTime = System.Environment.TickCount;
            int runTime = (endTime - startTime) / 1000;
            MessageBox.Show("用时：" + runTime + "秒");
        }
        public DataTable GetExcelTable(string excelFilename, string tableName)
        {
            //建立与指定Excel文件的连接
            string connectionString = string.Format("Provider=Microsoft.ACE.OLEDB.12.0;Data Source={0};Jet OLEDB:Engine Type=35;Extended Properties=Excel 8.0;Persist Security Info=False", excelFilename);
            DataSet ds = new DataSet();  //数据集
            //using中声明的对象connection，在using语句块结束后会自动释放
            using (System.Data.OleDb.OleDbConnection connection = new System.Data.OleDb.OleDbConnection(connectionString))
            {
                connection.Open();
                //获取数据库架构信息，包括列、主键、表等信息
                DataTable table = connection.GetOleDbSchemaTable(System.Data.OleDb.OleDbSchemaGuid.Tables, null);

                string strExcel = "select * from " + "[" + tableName + "$]";
                //打开数据链接，得到一个数据集
                OleDbDataAdapter adapter = new OleDbDataAdapter(strExcel, connectionString);
                //在数据集中查询表名为tableName的表，然后把其数据在装入数据集ds中
                adapter.Fill(ds, tableName);

                connection.Close();
            }
            return ds.Tables[tableName];//以datatable类型返回数据集ds中表名为tableName的表
        }
        public OleDbConnection GetMdb(string filepath)
        {
            try
            {
                string sqlcon = "Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + filepath + "; Persist Security Info =False";
                OleDbConnection ole_mdb = new OleDbConnection(@sqlcon);
                ole_mdb.Open();
                MessageBox.Show(filepath + "--读取成功");
                //db = dbEngine.OpenDatabase(filepath);
                return ole_mdb;
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
                return null;
            }
        }

//方法：使用update更新datatable
        public DataTable CreateCmdsAndUpdate(OleDbConnection oleDbConnection, string queryString, DataTable dt)
        {
            using (oleDbConnection)
            {
                OleDbDataAdapter adapter = new OleDbDataAdapter();
                adapter.AcceptChangesDuringFill = false;
                adapter.SelectCommand = new OleDbCommand(queryString, oleDbConnection);
                OleDbCommandBuilder builder = new OleDbCommandBuilder(adapter);
                if (oleDbConnection.State == ConnectionState.Closed) { oleDbConnection.Open(); }
                DataTable customers = new DataTable();
                adapter.Fill(customers);

                //code to modify data in DataTable here
//dt表示与mdb数据库关联的表，dt_exel表示存储excel数据的表
//尝试用dt.Merge(dt_excel),运行没问题，但mdb中并未插入数据，失败
//尝试用dt=dt_excel，运行没问题，但mdb中并未插入数据，失败
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    DataRow dr = customers.NewRow();
                    dr["县名称"] = dt.Rows[i][0].ToString();
                    dr["管辖区名称"] = dt.Rows[i][1].ToString();
                    dr["乡镇名称"] = dt.Rows[i][2].ToString();
                    dr["村名称"] = dt.Rows[i][3].ToString();
                    dr["行政村编码"] = dt.Rows[i][4].ToString();
                    customers.Rows.Add(dr);
                }
                adapter.Update(customers);
                return customers;
            }
        }
    }
}

最后

以上就是美丽小馒头最近收集整理的关于C#将excel数据导入mdb的三种方法（针对5万条数据）的全部内容，更多相关C#将excel数据导入mdb内容请搜索靠谱客的其他文章。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
点赞(51)

相关文章

vb.net 读取Excel
vb.net 读取Excel
Excel Ado类模块使用示例
Excel Ado类模块使用示例
如何在 Visual Basic .NET 中使用 ADO.NET 检索和修改 Excel 工作簿中的记录
如何在 Visual Basic .NET 中使用 ADO.NET 检索和修改 Excel 工作簿中的记录
VB读写Excel
VB读写Excel
C#将excel数据导入mdb的三种方法（针对5万条数据）
C#将excel数据导入mdb的三种方法（针对5万条数据）
vb.net向Excel中写入值
vb.net向Excel中写入值
easyExcel 数据导入
easyExcel 数据导入
vb将excel数据导入mysql_用VB做怎么将Excel数据导入SQL数据库中
vb将excel数据导入mysql_用VB做怎么将Excel数据导入SQL数据库中

评论列表共有 0 条评论

立即
投稿
返回
顶部