第一部分：C#基础入门
9.MySQL数据库操作——跨数据库适配
实例介绍
你有没有遇到过这样的场景？
公司的电商系统原本用SQL Server，但为了降低服务器成本，要迁移到MySQL；
产品需要同时支持SQL Server和MySQL两种数据库，给不同客户部署；
迁移时发现之前写的代码里全是SQL Server特有的语法：比如分页用OFFSET FETCH，而MySQL用LIMIT；数据类型nvarchar在MySQL里是varchar；甚至连接字符串的格式都不一样。
如果每个数据库都写一套代码，维护成本会爆炸。这一节我vb.net教程C#教程python教程SQL教程access 2010教程
们就用真实的电商系统迁移场景，带你掌握跨数据库适配的核心技巧：连接配置切换、数据类型兼容、SQL语法抽象、EF Core Provider适配，让你的代码一次编写，多数据库运行。
需求分析
本节要解决的核心问题：
1.连接适配：通过配置文件切换SQL Server/MySQL的连接字符串；
2.数据类型兼容：处理不同数据库的数据类型差异（如字符串、日期、数值）；
3.语法兼容：避免数据库特有SQL语法，用EF Core通用API实现分页、查询；
4.Provider切换：EF Core自动适配不同数据库的Provider（SQL Server/MySQL）；
5.跨库一致性：保证在不同数据库上执行相同逻辑得到相同结果（如数据查询、插入）。
目标：让你的代码无需修改（或极少修改）就能在SQL Server和MySQL上运行，降低迁移和维护成本。
代码实现
前置条件：.NET 6+、EF Core 7+；需安装NuGet包：
SQL Server Provider：Microsoft.EntityFrameworkCore.SqlServer
MySQL Provider：Pomelo.EntityFrameworkCore.MySql（社区维护，功能更全）
配置文件：appsettings.json中添加两种数据库的连接字符串。
准备工作：配置文件与依赖安装
步骤1：安装NuGet包
bash

	# 安装SQL Server Provider
	dotnet add package Microsoft.EntityFrameworkCore.SqlServer
	
	# 安装MySQL Provider（Pomelo）
	dotnet add package Pomelo.EntityFrameworkCore.MySql

步骤2：配置连接字符串（appsettings.json）
json

	{
	"ConnectionStrings": {
	"SQLServer": "Server=.;Database=ShopDB;Trusted_Connection=True;Encrypt=False;",
	"MySQL": "Server=localhost;Database=shopdb;User=root;Password=123456;Port=3306;SslMode=None;CharSet=utf8mb4;"
	},
	"Database": {
	"Type": "MySQL" // 可切换为"SQLServer"
	}
	}

场景1：DbContext适配多数据库
错误写法：硬编码Provider，无法切换数据库
csharp

	// ❌错误：硬编码用SQL Server Provider，无法切换到MySQL
	public void ConfigureServices(IServiceCollection services, IConfiguration config)
	{
	var connStr = config.GetConnectionString("SQLServer");
	services.AddDbContext<ShopDbContext>(options => 
	options.UseSqlServer(connStr)); // 固定SQL Server
	}

正确写法：通过配置切换Provider
csharp

	// ✅正确：根据配置文件切换SQL Server/MySQL Provider
	var builder = WebApplication.CreateBuilder(args);
	
	// 读取数据库类型和连接字符串
	var dbType = builder.Configuration["Database:Type"] ?? "SQLServer";
	var connStr = builder.Configuration.GetConnectionString(dbType);
	
	// 注册DbContext，自动适配Provider
	if (dbType == "SQLServer")
	{
	builder.Services.AddDbContext<ShopDbContext>(options =>
	options.UseSqlServer(connStr)
	.LogTo(Console.WriteLine) // 日志输出SQL，方便调试
	.EnableSensitiveDataLogging());
	}
	else if (dbType == "MySQL")
	{
	builder.Services.AddDbContext<ShopDbContext>(options =>
	options.UseMySql(
	connStr, 
	new MySqlServerVersion(new Version(8, 0, 28)), // MySQL版本
	options => options.CharSetBehavior(CharSetBehavior.NeverAppend))
	.LogTo(Console.WriteLine)
	.EnableSensitiveDataLogging());
	}

场景2：数据类型适配
错误写法：忽略数据类型差异，导致迁移失败
csharp

	// ❌错误：SQL Server的nvarchar(max)在MySQL中无对应类型，会报错
	public class Product
	{
	public int Id { get; set; }
	[Column(TypeName = "nvarchar(max)")] // 硬编码SQL Server类型
	public string Description { get; set; } = null!;
	public DateTime CreateTime { get; set; } = DateTime.Now; // 时区问题
	}

正确写法：用通用数据类型标注，让EF Core自动映射
csharp

	// ✅正确：用EF Core通用属性，自动适配不同数据库
	public class Product
	{
	public int Id { get; set; }
	
	[MaxLength(2000)] // 通用长度标注：SQL Server→nvarchar(2000)，MySQL→varchar(2000)
	public string Description { get; set; } = null!;
	
	public DateTime CreateTime { get; set; } = DateTime.UtcNow; // 用UTC时间避免时区差异
	}
	
	// 补充：在DbContext中配置数据类型映射（可选）
	protected override void OnModelCreating(ModelBuilder modelBuilder)
	{
	// 对MySQL特殊配置：将CreateTime映射为timestamp
	modelBuilder.Entity<Product>()
	.Property(p => p.CreateTime)
	.HasColumnType("timestamp") // MySQL特有类型，但通过条件判断适配
	.ValueGeneratedOnAdd(); // 插入时自动生成
	}

场景3：分页查询适配（避免特有语法）
错误写法：用数据库特有SQL分页，无法跨库
csharp

	// ❌错误：用SQL Server特有OFFSET FETCH，MySQL不支持
	public async Task<List<Product>> GetProductsWrong(ShopDbContext db, int page, int size)
	{
	var skip = (page - 1) * size;
	// 原生SQL，MySQL会报错
	return await db.Products.FromSqlRaw(
	$"SELECT * FROM Products ORDER BY Id OFFSET {skip} ROWS FETCH NEXT {size} ROWS ONLY"
	).ToListAsync();
	}

正确写法：用EF Core通用LINQ分页，自动适配
csharp

	// ✅正确：用LINQ Skip/Take，EF Core自动生成对应数据库的分页SQL
	public async Task<List<Product>> GetProductsCorrect(ShopDbContext db, int page, int size)
	{
	var skip = (page - 1) * size;
	// LINQ查询：EF Core会自动转换为对应数据库的分页语法
	return await db.Products
	.OrderBy(p => p.Id)
	.Skip(skip)
	.Take(size)
	.ToListAsync();
	}

生成的SQL对比：
SQL Server：SELECT * FROM Products ORDER BY Id OFFSET 10 ROWS FETCH NEXT 5 ROWS ONLY
MySQL：SELECT * FROM Products ORDER BY Id LIMIT 5 OFFSET 10
场景4：跨数据库数据同步（同时操作SQL Server和MySQL）
正确写法：注入两个DbContext，分别操作不同数据库
csharp

	// 注册两个DbContext：一个SQL Server，一个MySQL
	builder.Services.AddDbContext<ShopDbContext>(options => 
	options.UseSqlServer(config.GetConnectionString("SQLServer")), 
	contextLifetime: ServiceLifetime.Scoped, 
	optionsLifetime: ServiceLifetime.Singleton);
	
	builder.Services.AddDbContext<ShopMySqlDbContext>(options => 
	options.UseMySql(config.GetConnectionString("MySQL"), new MySqlServerVersion(new Version(8,0,28))));
	
	// 跨库同步数据示例
	public async Task SyncProducts(ShopDbContext sqlDb, ShopMySqlDbContext mySqlDb)
	{
	// 从SQL Server读取数据
	var sqlProducts = await sqlDb.Products.Take(100).ToListAsync();
	
	// 同步到MySQL
	foreach (var p in sqlProducts)
	{
	mySqlDb.Products.Add(new Product 
	{ 
	Id = p.Id, 
	Name = p.Name, 
	Price = p.Price, 
	CreateTime = p.CreateTime 
	});
	}
	await mySqlDb.SaveChangesAsync();
	}

逐行讲解
场景1：DbContext适配多数据库
1.读取配置：builder.Configuration["Database:Type"]读取数据库类型，GetConnectionString获取对应连接字符串；
2.Provider切换：根据dbType选择UseSqlServer或UseMySql，Pomelo的UseMySql需要指定MySQL版本；
3.日志配置：LogTo(Console.WriteLine)输出生成的SQL，方便调试跨库差异。
场景2：数据类型适配
1.UTC时间：DateTime.UtcNow存储UTC时间，避免SQL Server（本地时间）和MySQL（UTC时间）的时区差异；
2.MaxLength标注：[MaxLength(2000)]让EF Core自动映射为SQL Server的nvarchar(2000)和MySQL的varchar(2000)；
3.条件配置：在OnModelCreating中对MySQL特殊配置（如timestamp类型），但可通过#if或配置判断是否启用。
场景3：分页查询适配
1.LINQ通用API：Skip+Take是EF Core通用分页方式，自动转换为对应数据库的SQL；
2.避免原生SQL：原生SQL会绑定特定数据库，而LINQ查询具有跨库兼容性；
3.性能保证：EF Core生成的分页SQL和手写原生SQL性能一致，无需担心效率问题。
场景4：跨库同步
1.多DbContext注册：通过不同的DbContext（如ShopDbContext和ShopMySqlDbContext）分别操作两个数据库；
2.事务注意：不同数据库无法用同一个事务，若需一致性需用分布式事务（如DTC）或最终一致性（如消息队列）；
3.数据转换：同步时需注意数据类型的兼容性（如之前配置的UTC时间和字符串长度）。
基础知识拓展

1. SQL Server vs MySQL 核心差异对比

2. EF Core跨库适配最佳实践
   用通用API：优先用LINQ查询、EF Core内置方法，避免原生SQL；
   配置驱动：通过appsettings.json切换数据库类型，无需修改代码；
   抽象层：用Repository模式封装数据库操作，隐藏Provider细节；
   条件配置：对数据库特有配置（如timestamp），用#if或配置判断启用；
   测试覆盖：对核心逻辑（如分页、数据插入），同时测试SQL Server和MySQL环境。
3. 常见坑点与解决
   时区问题：统一用DateTime.UtcNow存储，前端显示时转换为本地时间；
   字符集问题：MySQL需配置CharSet=utf8mb4支持Emoji，避免乱码；
   排序规则：若需区分大小写，MySQL需设置COLLATE utf8mb4_bin；
   事务一致性：跨库操作无法用本地事务，需用分布式事务（如DTC）或最终一致性（如RabbitMQ）。
4. Provider选择建议
   SQL Server：用官方Microsoft.EntityFrameworkCore.SqlServer；
   MySQL：优先用Pomelo.EntityFrameworkCore.MySql（社区活跃，支持最新EF Core版本），避免官方MySql.EntityFrameworkCore（更新慢、功能不全）；
   其他数据库：PostgreSQL用Npgsql.EntityFrameworkCore.PostgreSQL，SQLite用Microsoft.EntityFrameworkCore.Sqlite。
   总结
   跨数据库适配的核心是抽象与兼容：通过配置切换Provider，用EF Core通用API避免特有语法，处理数据类型差异，最终实现“一次编写，多库运行”。本节的关键要点：
   1.配置驱动：用appsettings.json切换数据库类型和连接字符串；
   2.通用API：用LINQ、EF Core内置方法替代原生SQL；
   3.数据兼容：统一用UTC时间、MaxLength标注处理类型差异；
   4.抽象封装：用Repository模式隐藏数据库细节，降低耦合。
   掌握这些技巧，你就能轻松应对数据库迁移、多客户多数据库需求，让系统更灵活、易维护。

本站原创，转载请注明出处：