学习路线指引(点击解锁) | 知识定位 | 人群定位 |
---|---|---|
🧡 Python实战微信订餐小程序 🧡 | 进阶级 | 本课程是python flask+微信小程序的完美结合,从项目搭建到腾讯云部署上线,打造一个全栈订餐系统。 |
💛Python量化交易实战💛 | 入门级 | 手把手带你打造一个易扩展、更安全、效率更高的量化交易系统 |
上一篇我们讨论到获取将要执行的迁移操作,到这一步为止,针对所有数据库都通用,在此之后需要生成SQL脚本对于不同数据库将有不同差异,我们一起来瞅一瞅
在上一篇拿到的迁移操作类即MigrationOperation为执行所有其他操作类的父类,比如添加列操作(AddColumnOperation),修改列操作(AlterColumnOperation)、创建表操作(CreateTableOperation)等等,我们知道SQLite不支持修改列,所以我们需要去除列修改操作,代码如下:
// Sqlite不支持修改操作,所以需过滤修改迁移操作
var operations = migrationOperations.Except(migrationOperations.Where(o => o is AlterColumnOperation)).ToList();
if (!operations.Any())
{
return;
}
然后获取生成SQL脚本接口,拿到执行操作命令类里面的脚本文本即可
var migrationsSqlGenerator = context.GetService();
var commandList = migrationsSqlGenerator.Generate(operations);
if (!commandList.Any())
{
return;
}
var sqlScript = string.Concat(commandList.Select(c => c.CommandText));
if (string.IsNullOrEmpty(sqlScript))
{
return;
}
因为我们可能会修改主键,此时Pomelo.EntityFrameworkCore.MySql使用的方式则是创建一个临时存储过程,先删除主键,然后则执行完相关脚本后,最后重建主键,然后删除临时存储过程,临时存储过程如下:
#region Custom Sql
#region BeforeDropPrimaryKey
private const string BeforeDropPrimaryKeyMigrationBegin = @"DROP PROCEDURE IF EXISTS `POMELO\_BEFORE\_DROP\_PRIMARY\_KEY`;
CREATE PROCEDURE `POMELO\_BEFORE\_DROP\_PRIMARY\_KEY`(IN `SCHEMA\_NAME\_ARGUMENT` VARCHAR(255), IN `TABLE\_NAME\_ARGUMENT` VARCHAR(255))
BEGIN
DECLARE HAS\_AUTO\_INCREMENT\_ID TINYINT(1);
DECLARE PRIMARY\_KEY\_COLUMN\_NAME VARCHAR(255);
DECLARE PRIMARY\_KEY\_TYPE VARCHAR(255);
DECLARE SQL\_EXP VARCHAR(1000);
SELECT COUNT(*)
INTO HAS\_AUTO\_INCREMENT\_ID
FROM `information\_schema`.`COLUMNS`
WHERE `TABLE\_SCHEMA`