简介本资源是一份面向VB.NET初学者与数据迁移开发者的实战型代码示例包聚焦解决Windows平台下连接MySQL数据库并批量导入CSV文件的核心需求适用于教学演示、小型数据处理系统开发及数据库对接实训场景。压缩包共29个文件含6个核心VB源码.vb、1个Visual Studio解决方案.sln、1个项目配置文件.vbproj、3个可执行程序.exe及配套资源文件.resx/.xml/.dll等完整呈现从连接建立、CSV解析、SQL插入到异常捕获与事务控制的全流程实现。资源体积仅75KB轻量易部署结构清晰便于逐模块理解ADO.NET与MySql.Data驱动协同机制。目前已有193人学习下载读者可直接复用项目框架快速掌握VB.NET操作MySQL的关键API调用、TextFieldParser文本解析技巧、批处理导入优化策略及典型错误处理范式。1. VB.NET 连接 MySQL 并导入 CSV为什么“双击运行就报错”是绝大多数新手的第一道墙你手头有个.zip文件解压后是MYSQL_connect_csv_h.vbproj或类似命名的 VB.NET 工程目标很明确用 Windows 桌面程序读取本地 CSV 文件比如data.csv把每一行数据塞进远程或本机的 MySQL 表里。但双击exe就弹窗“未找到提供程序”“连接字符串无效”“Could not load file or assembly MySql.Data”甚至 CSV 读到一半就卡死在带中文、逗号、换行符的字段上——这不是你代码写错了而是 VB.NET MySQL CSV 这个三角组合从环境链路、字符编码、驱动版本到 CSV 解析逻辑存在四层隐性断点。它不考验算法深度但极度考验工程落地的完整链路意识。本文面向两类人一是刚从 C# 转 VB.NET、对 ADO.NET 基础尚可但没碰过 MySQL 驱动的开发者二是被业务催着“今天必须把这 5000 行销售数据导进系统”的一线实施工程师。我们不讲抽象的 ConnectionString 构造原理只聚焦怎么让 ZIP 包里的代码在你 Win10/Win11 机器上不改一行源码就能跑通第一笔数据。核心就三件事装对驱动、写对连接串、绕开 CSV 的“玄学字段分隔”。2. 环境筑基VB.NET 项目必须装的不是“MySQL”而是 MySql.Data.dll 的精确版本VB.NET 本身不认 MySQL。它只认 ADO.NET 接口。真正干活的是第三方实现——MySql.Data这个 .NET 数据提供程序DataProvider。它的版本、部署方式、GAC 注册状态直接决定你的Imports MySql.Data.MySqlClient是绿灯还是红叉。2.1 为什么 NuGet 安装常翻车——目标框架与驱动版本的硬约束VB.NET 项目有TargetFramework如net472,net6.0-windows,net8.0-windows。而MySql.Data的支持矩阵极不友好MySql.Data 8.0.x仅支持 .NET Core 3.1 / .NET 5对传统net472项目会静默失败编译过运行时报System.IO.FileNotFoundExceptionMySql.Data 6.10.x最后支持 .NET Framework 4.x 的稳定版但默认不兼容 TLS 1.2现代 MySQL 8.0 默认强制 TLS 1.2MySqlConnector开源替代完全跨平台支持net472到net8.0且 TLS 1.2 开箱即用但需手动替换命名空间。提示打开你的.vbproj文件找TargetFramework标签。这是你选驱动的唯一依据不是看 MySQL 服务端版本。2.2 实操三步锁定并安装正确驱动以 net472 项目为例假设你的项目是传统的 Windows Forms 应用.vbproj中写着TargetFrameworknet472/TargetFramework请严格按此流程操作# 步骤1卸载所有可能冲突的旧包在 Visual Studio Package Manager Console 中执行 Uninstall-Package MySql.Data -Force Uninstall-Package MySqlConnector -Force # 步骤2安装经验证的 net472 兼容版注意不是最新版 Install-Package MySql.Data -Version 6.10.9 # 步骤3检查 bin\Debug 下是否生成了 MySql.Data.dll关键 # 如果没有右键项目 → 属性 → 引用 → 手动添加 bin\packages\MySql.Data.6.10.9\lib\net452\MySql.Data.dll参数说明-Version 6.10.9是net452编译的二进制向下兼容net472且已内置 TLS 1.2 支持补丁官方 6.10.9 发布说明明确提及不要用8.0.33它生成的 DLL 依赖System.Runtime.CompilerServices.Unsafe而net472项目若未显式安装该包运行时必崩MySqlConnector虽好但需将代码中所有MySql.Data.MySqlClient替换为MySqlConnector对 ZIP 包原始代码改动大首通不推荐。2.3 连接字符串不是“填空题”而是“协议协商书”很多教程让你抄serverlocalhost;userroot;pwd123;databasetest但这在真实环境中大概率失效。原因在于 MySQL 8.0 默认认证插件从mysql_native_password改为caching_sha2_password而MySql.Data 6.10.9不原生支持后者。必须显式降级用户认证方式在 MySQL 命令行中执行-- 登录 MySQL用 root 或高权限账号 ALTER USER your_user% IDENTIFIED WITH mysql_native_password BY your_password; FLUSH PRIVILEGES;然后你的连接字符串才真正有效 VB.NET 中的连接字符串务必用双引号包裹且不能换行 Dim connectionString As String server192.168.1.100;port3306;useryour_user;passwordyour_password;databasetest_db;charsetutf8mb4;SslModenone;关键参数说明charsetutf8mb4强制客户端使用 UTF-8 四字节编码避免中文存成??SslModenone关闭 SSL开发环境可接受生产环境应配证书并设SslModeRequiredport3306显式写出避免某些内网 MySQL 实例监听非标端口不要加Allow User VariablesTrue或UseCompressionTrue这些在 6.10.9 中有已知内存泄漏。3. CSV 解析别信 TextFieldParser用 StreamReader Split 的血泪经验VB.NET 自带Microsoft.VisualBasic.FileIO.TextFieldParser文档写得天花乱坠号称自动处理引号、换行、逗号。但实战中它在以下场景必然翻车CSV 第 123 行有个字段含abc,def带逗号的字符串TextFieldParser会错误切分成两列CSV 含 BOM 头EF BB BFTextFieldParser读出第一列是id带不可见字符导致INSERT INTO报 “Unknown column id”某行末尾多了一个换行符\r\n\r\nTextFieldParser直接抛MalformedLineException中断整个导入。我一般会弃用TextFieldParser改用StreamReader手动逐行读取 Split虽土但稳。核心逻辑用作为字段边界标记而非依赖Split(,)。3.1 可复用的 CSV 行解析函数VB.NET summary 安全解析 CSV 行正确处理含逗号、引号、换行的字段 /summary param nameline原始 CSV 行已 TrimEnd/param returns字符串数组每个元素为一个字段值已去引号、去空白/returns Public Function ParseCsvLine(line As String) As String() Dim fields As New List(Of String) Dim currentField As New System.Text.StringBuilder Dim inQuotes As Boolean False Dim i As Integer 0 While i line.Length Dim c As Char line(i) If c c Then inQuotes Not inQuotes ElseIf c ,c AndAlso Not inQuotes Then 字段分隔符且不在引号内 fields.Add(currentField.ToString().Trim(c)) currentField.Clear() Else currentField.Append(c) End If i 1 End While 添加最后一个字段 fields.Add(currentField.ToString().Trim(c)) Return fields.ToArray() End Function逻辑说明它不依赖正则或复杂状态机用纯布尔标志inQuotes控制逗号是否生效Trim(c)移除字段两端的英文双引号这是 CSV 标准要求对两个连续引号这种转义写法暂不支持真实业务 CSV 极少用若需支持可在inQuotesTrue且cc时检查下一个字符是否也是然后跳过。3.2 完整导入流程从文件到数据库的最小闭环Private Sub ImportCsvToMysql(filePath As String, tableName As String) Dim connectionString As String server192.168.1.100;port3306;userimporter;passwordpass123;databaseprod_db;charsetutf8mb4;SslModenone; Using conn As New MySqlConnection(connectionString) Try conn.Open() 1. 读取 CSV 文件必须指定 UTF-8 with BOM 编码 Using reader As New StreamReader(filePath, Encoding.UTF8) Dim headerLine As String reader.ReadLine() If headerLine Is Nothing Then Throw New Exception(CSV 文件为空) 2. 解析表头生成 INSERT SQL 模板 Dim headers() As String ParseCsvLine(headerLine) Dim placeholders As String String.Join(,, headers.Select(Function(h) ${h})) Dim sql As String $INSERT INTO {tableName} ({String.Join(,, headers)}) VALUES ({placeholders}) 3. 预编译命令防 SQL 注入 Using cmd As New MySqlCommand(sql, conn) 为每个字段添加参数避免类型推断错误 For Each h In headers cmd.Parameters.AddWithValue(${h}, ) Next 4. 逐行读取并执行 Dim lineNumber As Integer 2 从第2行开始header占第1行 While Not reader.EndOfStream Dim line As String reader.ReadLine() If String.IsNullOrWhiteSpace(line) Then Continue While Dim values() As String ParseCsvLine(line) If values.Length headers.Length Then MessageBox.Show($第 {lineNumber} 行字段数不匹配期望{headers.Length}实际{values.Length}) Continue While End If 绑定参数值关键显式转换为 DB 类型 For i As Integer 0 To headers.Length - 1 Dim param As MySqlParameter cmd.Parameters(${headers(i)}) 数字字段转 Decimal日期转 DateTime其余转 String If IsNumeric(values(i)) AndAlso Not String.IsNullOrEmpty(values(i)) Then param.Value Convert.ToDecimal(values(i)) ElseIf IsDate(values(i)) AndAlso Not String.IsNullOrEmpty(values(i)) Then param.Value Convert.ToDateTime(values(i)) Else param.Value values(i) 字符串直接赋值 End If Next cmd.ExecuteNonQuery() lineNumber 1 End While End Using End Using MessageBox.Show($成功导入 {lineNumber - 2} 行数据) Catch ex As MySqlException MessageBox.Show($MySQL 错误: {ex.Message} (SQL State: {ex.SqlState})) Catch ex As IOException MessageBox.Show($文件读取错误: {ex.Message}) End Try End Using End Sub参数与行为说明Encoding.UTF8强制用 UTF-8 读取兼容带 BOM 的 Excel 导出 CSVcmd.Parameters.AddWithValue初始化时传空字符串避免DBNull问题IsNumeric/IsDate类型判断放在循环内确保每行独立校验lineNumber从 2 开始计方便定位错误行MessageBox.Show用于桌面程序调试生产环境应改用日志记录。4. 避坑VB.NET 连 MySQL 导 CSV 的 5 个高频翻车现场这些不是理论问题是我在某高校实验室部署 12 套同类系统时被反复踩过的坑。每一条都附带现象、根因和一招解决。4.1 现象程序能连 MySQL但INSERT时提示 “Data too long for column name at row 1”原因CSV 中某字段含不可见字符如U200B零宽空格Len()返回长度正常但 MySQLVARCHAR(50)实际存储字节数超限UTF8MB4 下一个中文占 4 字节。解决在ParseCsvLine函数末尾对每个字段值加清洗value Regex.Replace(value, [\u200B-\u200D\uFEFF], ) 清除零宽字符 value value.Trim() 再 Trim 空格、制表符4.2 现象导入后中文全变成???但用 Navicat 手动插入中文却正常原因MySQL 服务端character_set_server是latin1而连接字符串写了charsetutf8mb4但驱动未生效。解决在连接字符串末尾追加;Connection Timeout30;并确认 MySQL 配置文件my.cnf中有[mysqld] character-set-server utf8mb4 collation-server utf8mb4_unicode_ci重启 MySQL 服务。4.3 现象CSV 第 1 行是表头但程序把表头当数据插进去了原因reader.ReadLine()被调用两次——一次在headerLine reader.ReadLine()另一次在While Not reader.EndOfStream循环开头又读了一次。解决删除循环内的reader.ReadLine()改为Dim line As String reader.ReadLine() 在 while 内第一行就读 If line Is Nothing Then Exit While4.4 现象导入大数据量10 万行时内存暴涨程序假死原因MySqlCommand默认开启AutoPrepare每行都重新编译 SQL且MySql.Data 6.10.9有参数缓存泄漏。解决在Using cmd块内显式关闭自动准备cmd.Prepare() 手动预编译一次 然后在循环内只调用 cmd.ExecuteNonQuery()不再 Prepare4.5 现象CSV 含日期字段如2023/05/20导入后 MySQL 中变成0000-00-00原因MySQL 的DATE类型严格要求YYYY-MM-DD格式2023/05/20被视为非法。解决在IsDate(values(i))分支中不直接Convert.ToDateTime而是标准化Dim dt As DateTime Convert.ToDateTime(values(i)) param.Value dt.ToString(yyyy-MM-dd) 强制输出标准格式5. 性能与健壮性进阶批量插入、事务控制与断点续传单行INSERT在导入万级数据时速度感人实测 5000 行约 42 秒。真正的生产级方案必须上批量Bulk和事务。但MySql.Data不支持SqlBulkCopy那是 SQL Server 的得用LOAD DATA INFILE或拼接多值INSERT。前者需要 MySQL 服务端文件权限后者更可控。5.1 用INSERT ... VALUES (),(),()实现百倍提速核心思路攒够 1000 行拼成一条 SQL 执行而非 1000 条单独 SQL。 修改 ImportCsvToMysql 函数中的循环部分 Dim batchValues As New List(Of String) Dim batchCount As Integer 0 Const BATCH_SIZE As Integer 1000 While Not reader.EndOfStream Dim line As String reader.ReadLine() If String.IsNullOrWhiteSpace(line) Then Continue While Dim values() As String ParseCsvLine(line) If values.Length headers.Length Then Continue While 构建单行 VALUES 字符串(val1,val2,123) Dim valueParts As New List(Of String) For i As Integer 0 To headers.Length - 1 Dim v As String If(String.IsNullOrEmpty(values(i)), NULL, ${values(i).Replace(, )}) valueParts.Add(v) Next batchValues.Add($({String.Join(,, valueParts)})) batchCount 1 达到批次执行批量插入 If batchCount BATCH_SIZE Then Dim batchSql As String $INSERT INTO {tableName} ({String.Join(,, headers)}) VALUES {String.Join(,, batchValues)} Using cmd As New MySqlCommand(batchSql, conn) cmd.ExecuteNonQuery() End Using batchValues.Clear() batchCount 0 End If End While 插入剩余不足 BATCH_SIZE 的行 If batchValues.Count 0 Then Dim batchSql As String $INSERT INTO {tableName} ({String.Join(,, headers)}) VALUES {String.Join(,, batchValues)} Using cmd As New MySqlCommand(batchSql, conn) cmd.ExecuteNonQuery() End Using End If关键细节values(i).Replace(, )简单防 SQL 注入生产环境建议用参数化但批量拼接下参数化不适用此为折中BATCH_SIZE 1000MySQL 默认max_allowed_packet4M1000 行 × 平均 200 字节 ≈ 200KB安全不用UNION ALL因INSERT ... VALUES语法更简洁、性能更好。5.2 加事务要么全成功要么全回滚在conn.Open()后、循环前显式开启事务Using transaction As MySqlTransaction conn.BeginTransaction() Try ... 所有 INSERT 语句都绑定到 transaction ... cmd.Transaction transaction 批量插入后 transaction.Commit() Catch ex As Exception transaction.Rollback() Throw 重新抛出由外层捕获 End Try End Using5.3 断点续传记录已处理行号崩溃后从断点继续在导入前先查表当前最大id假设主键自增再读 CSV 时跳过前 N 行 查询当前最大 ID Dim maxIdSql As String $SELECT COALESCE(MAX(id), 0) FROM {tableName} Using cmd As New MySqlCommand(maxIdSql, conn) Dim maxId As Integer CInt(cmd.ExecuteScalar()) 跳过 CSV 前 maxId 行需 CSV 有序且 id 字段对应 For i As Integer 1 To maxId reader.ReadLine() 丢弃 Next End Using我的习惯是首次导入用小批量100 行 详细日志确认逻辑无误后再切到 1000 行批量 事务上线前必加断点续传。因为客户不会等你重跑 2 小时——他们只关心“现在卡在哪一行”。希望帮到你。本文还有配套的精品资源点击获取