69 lines
2.5 KiB
C#
69 lines
2.5 KiB
C#
using Ewide.Core.Util;
|
|
using Ewide.EntityFramework.Core;
|
|
using Ewide.EntityFramework.Core.SqlSugar;
|
|
using Furion;
|
|
using Furion.DatabaseAccessor;
|
|
using Furion.DependencyInjection;
|
|
using Furion.DynamicApiController;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Microsoft.EntityFrameworkCore.Metadata;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Reflection;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace Ewide.Web.Core.Service
|
|
{
|
|
[ApiDescriptionSettings(Name = "DBHandler", Order = 3)]
|
|
public class DBqueryService : IDynamicApiController, ITransient
|
|
{
|
|
private readonly DefaultDbContext _db;
|
|
|
|
public DBqueryService(DefaultDbContext db)
|
|
{
|
|
_db = db;
|
|
}
|
|
[HttpGet("/DBreader/detail")]
|
|
[AllowAnonymous]
|
|
public async Task XMLDoneAsync()
|
|
{
|
|
#if DEBUG
|
|
XmlSerializerUtil xmlHandler = new XmlSerializerUtil();
|
|
//xmlHandler.WriteDataSeed();
|
|
//拿到数据保存到 XML文件
|
|
Dictionary<string, object> dicDataBase = await GetDataBase();
|
|
foreach (KeyValuePair<string, object> item in dicDataBase)
|
|
{
|
|
xmlHandler.WriteXML(item.Value.GetType(), item.Value, item.Key);
|
|
}
|
|
#endif
|
|
}
|
|
/// <summary>
|
|
/// 读取数据库的所有表 并拿到数据
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
private async Task<Dictionary<string, object>> GetDataBase()
|
|
{
|
|
Dictionary<string, object> dicDataBase = new Dictionary<string, object>();
|
|
var defaultConnection = App.Configuration["DefaultConnection"];
|
|
//获取 所有继承 IEntity 接口的表
|
|
IEnumerable<IEntityType> entityTypedb = _db.Model.GetEntityTypes().Where(x => typeof(IEntity).IsAssignableFrom(x.ClrType)).ToList();
|
|
|
|
foreach (IEntityType item in entityTypedb)
|
|
{
|
|
MethodInfo mi = _db.GetType().GetMethods().FirstOrDefault(s => s.Name == "Set");
|
|
MethodInfo miConstructed = mi.MakeGenericMethod(item.ClrType);
|
|
object objList = miConstructed.Invoke(_db, null);
|
|
var objsource = item.ClrType.MakeList(objList);
|
|
dicDataBase.Add(item.ClrType.Name, objsource);
|
|
}
|
|
await _db.Database.CloseConnectionAsync();
|
|
return dicDataBase;
|
|
}
|
|
}
|
|
}
|