src/ZKEACMS.Updater/Service/DbUpdaterService.cs

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

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

/* http://www.zkea.net/ 
 * Copyright (c) ZKEASOFT. All rights reserved. 
 * http://www.zkea.net/licenses */

using Easy.Extend;
using Easy.Mvc.Plugin;
using Easy.Net;
using Microsoft.AspNetCore.Hosting;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.IO;
using System.IO.Compression;
using System.Linq;
using System.Text;
using System.Text.Json;
using ZKEACMS.Options;
using ZKEACMS.Updater.Models;

namespace ZKEACMS.Updater.Service
{
    public class DbUpdaterService : IDbUpdaterService
    {
        private readonly IOptions<DBVersionOption> _dbVersionOption;
        private readonly IWebClient _webClient;
        private readonly ILogger<DbUpdaterService> _logger;
        private readonly IDBContextProvider _dbContextProvider;
        private const int DBVersionRecord = 1;
        private readonly string _scriptFileName;
        private string availableSource;
        public DbUpdaterService(DatabaseOption databaseOption,
            IOptions<DBVersionOption> dbVersionOption,
            IWebClient webClient,
            IDBContextProvider dbContextProvider,
            ILogger<DbUpdaterService> logger)
        {
            _dbVersionOption = dbVersionOption;
            _webClient = webClient;
            _scriptFileName = $"{databaseOption.DbType}.sql";//MsSql.sql, MySql.sql, Sqlite.sql
            _logger = logger;
            _dbContextProvider = dbContextProvider;
        }

        public void UpdateDatabase()
        {
            ExcuteLocalScripts();

            UpgradeDbToLatest();
        }

        private void UpgradeDbToLatest()
        {
            var appVersion = Easy.Version.Parse(Version.VersionInfo);
            bool allSuccess = true;
            foreach (var dbContext in _dbContextProvider.GetAvailableDbContexts())