src/02_Data/Adapters/Data.Adapter.MySql/MySqlCodeFirstProvider.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using Dapper;
using Microsoft.Extensions.DependencyInjection;
using Mkh.Data.Abstractions;
using Mkh.Data.Abstractions.Descriptors;
using Mkh.Data.Abstractions.Options;
using Mkh.Data.Abstractions.Schema;
using Mkh.Data.Core;

namespace Mkh.Data.Adapter.MySql;

public class MySqlCodeFirstProvider : CodeFirstProviderAbstract
{
    public MySqlCodeFirstProvider(CodeFirstOptions options, IDbContext context, IServiceCollection service) : base(options, context, service)
    {
    }

    #region ==创建库==

    public override void CreateDatabase()
    {
        var con = Context.NewConnection();

        //数据库名称
        var databaseName = con.Database;
        /*
        * 创建数据库需要当前连接字符串使用的账户拥有对应的权限，并且需要使用mysql数据库
        */
        var connString = con.ConnectionString.Replace(databaseName, "mysql");
        using var con1 = Context.NewConnection(connString);
        var schemaProvider = new MySqlSchemaProvider(con1);
        var isExistsDatabase = schemaProvider.IsExistsDatabase(databaseName);
        if (isExistsDatabase)
        {
            con.Close();
            return;
        }

        //创建前事件
        Options.BeforeCreateDatabase?.Invoke(Context);

        //创建数据库
        schemaProvider.CreateDatabase(databaseName);

        con1.Close();

        //创建后事件
        Options.AfterCreateDatabase?.Invoke(Context);
    }

    #endregion

    #region ==创建表==

    public override void CreateTable()
    {
        foreach (var descriptor in Context.EntityDescriptors.Where(m => m.AutoCreate))