mirror of https://github.com/abpframework/abp.git
liangshiw
7 years ago
2192 changed files with 64454 additions and 131029 deletions
@ -1,4 +1,15 @@ |
|||
ui-angular: |
|||
- npm/ng-packs/* |
|||
- npm/ng-packs/**/* |
|||
- npm/ng-packs/**/**/* |
|||
- npm/ng-packs/**/**/**/* |
|||
- npm/ng-packs/**/**/**/**/* |
|||
- npm/ng-packs/**/**/**/**/**/* |
|||
- templates/app/angular/* |
|||
- templates/app/angular/**/* |
|||
- templates/app/angular/**/**/* |
|||
- templates/app/angular/**/**/**/* |
|||
- templates/module/angular/* |
|||
- templates/module/angular/**/* |
|||
- templates/module/angular/**/**/* |
|||
- templates/module/angular/**/**/**/* |
|||
|
|||
@ -1,17 +1,12 @@ |
|||
name: "Pull Request Labeler" |
|||
name: Pull request labeler |
|||
on: |
|||
pull_request: |
|||
paths: |
|||
- npm/ng-packs/**/* |
|||
- templates/app/angular/**/* |
|||
- templates/module/angular/**/* |
|||
branches: |
|||
- master |
|||
- dev |
|||
schedule: |
|||
- cron: '0 12 */1 * *' |
|||
jobs: |
|||
labeler: |
|||
runs-on: ubuntu-18.04 |
|||
runs-on: ubuntu-latest |
|||
steps: |
|||
- uses: actions/labeler@v2 |
|||
with: |
|||
repo-token: "${{ secrets.GITHUB_TOKEN }}" |
|||
- uses: paulfantom/periodic-labeler@master |
|||
env: |
|||
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }} |
|||
GITHUB_REPOSITORY: ${{ github.repository }} |
|||
|
|||
@ -1,35 +0,0 @@ |
|||
## Entity Framework Core PostgreSQL integrace |
|||
|
|||
> Podívejte se na [Entity Framework Core integrační dokument](../Entity-Framework-Core.md) pro základy integrace EF Core. |
|||
|
|||
### Aktualizace projektu EntityFrameworkCore |
|||
|
|||
- V projektu `Acme.BookStore.EntityFrameworkCore` nahraďte balík `Volo.Abp.EntityFrameworkCore.SqlServer` za `Volo.Abp.EntityFrameworkCore.PostgreSql` |
|||
- Aktualizace pro použití PostgreSQL v `BookStoreEntityFrameworkCoreModule` |
|||
- Nahraďte `AbpEntityFrameworkCoreSqlServerModule` za `AbpEntityFrameworkCorePostgreSqlModule` |
|||
- Nahraďte `options.UseSqlServer()` za `options.UsePostgreSql()` |
|||
- V jiných projektech aktualizujte PostgreSQL connection string v nezbytných `appsettings.json` souborech |
|||
|
|||
#### Odstranění stávajících migrací |
|||
|
|||
Smažte všechny stavající migrační soubory (včetně `DbContextModelSnapshot`) |
|||
|
|||
 |
|||
|
|||
#### Znovu vygenerujte počáteční migraci & aktualizujte databázi |
|||
|
|||
Nastavte správný spouštěcí projekt (obvykle web projekt), |
|||
Otevřete **Package Manager Console** (Tools -> Nuget Package Manager -> Package Manager Console), zvolte `Acme.BookStore.EntityFrameworkCore.DbMigrations` jako **Default project** a proveďte následující příkaz: |
|||
|
|||
Proveďte příkaz `Add-Migration`: |
|||
```` |
|||
PM> Add-Migration Initial |
|||
```` |
|||
|
|||
Poté proveďte příkaz `Update-Database` k aktualizaci schématu databáze: |
|||
|
|||
```` |
|||
PM> Update-Database |
|||
```` |
|||
|
|||
 |
|||
@ -0,0 +1,74 @@ |
|||
## Entity Framework Core PostgreSQL integrace |
|||
|
|||
> Podívejte se na [Entity Framework Core integrační dokument](../Entity-Framework-Core.md) pro základy integrace EF Core. |
|||
|
|||
### Aktualizace projektu EntityFrameworkCore |
|||
|
|||
- V projektu `Acme.BookStore.EntityFrameworkCore` nahraďte balík `Volo.Abp.EntityFrameworkCore.SqlServer` za `Volo.Abp.EntityFrameworkCore.PostgreSql` |
|||
- Aktualizace pro použití PostgreSQL v `BookStoreEntityFrameworkCoreModule` |
|||
- Nahraďte `AbpEntityFrameworkCoreSqlServerModule` za `AbpEntityFrameworkCorePostgreSqlModule` |
|||
- Nahraďte `options.UseSqlServer()` za `options.UsePostgreSql()` |
|||
- V jiných projektech aktualizujte PostgreSQL connection string v nezbytných `appsettings.json` souborech |
|||
- Více informací v [PostgreSQL connection strings](https://www.connectionstrings.com/postgresql/), v tomto dokumentu věnujte pozornost sekci `Npgsql` |
|||
|
|||
### Aktualizace projektu EntityFrameworkCore.DbMigrations |
|||
- Aktualizace pro použití PostgreSQL v `XXXMigrationsDbContextFactory` |
|||
- Nahraďte `new DbContextOptionsBuilder<XXXMigrationsDbContext>().UseSqlServer()` za `new DbContextOptionsBuilder<XXXMigrationsDbContext>().UseNpgsql()` |
|||
|
|||
|
|||
### Odstranění stávajících migrací |
|||
|
|||
Smažte všechny stavající migrační soubory (včetně `DbContextModelSnapshot`) |
|||
|
|||
 |
|||
|
|||
### Znovu vygenerujte počáteční migraci |
|||
|
|||
Nastavte správný spouštěcí projekt (obvykle web projekt) |
|||
|
|||
 |
|||
|
|||
Otevřete **Package Manager Console** (Tools -> Nuget Package Manager -> Package Manager Console), zvolte `.EntityFrameworkCore.DbMigrations` jako **Default project** a proveďte následující příkaz: |
|||
|
|||
Proveďte příkaz `Add-Migration`: |
|||
```` |
|||
PM> Add-Migration Initial |
|||
```` |
|||
|
|||
### Aktualizace databáze |
|||
|
|||
K vytvoření databáze máte dvě možnosti. |
|||
|
|||
#### Použití DbMigrator aplikace |
|||
|
|||
Řešení obsahuje konzolovou aplikaci (v tomto příkladu nazvanou `Acme.BookStore.DbMigrator`), která může vytvářet databáze, aplikovat migrace a vkládat seed data. Je užitečná jak pro vývojové, tak pro produkční prostředí. |
|||
|
|||
> Projekt `.DbMigrator` má vlastní `appsettings.json`. Takže pokud jste změnili connection string uvedený výše, musíte změnit také tento. |
|||
|
|||
Klikněte pravým na projekt `.DbMigrator` a vyberte **Set as StartUp Project**: |
|||
|
|||
 |
|||
|
|||
Zmáčkněte F5 (nebo Ctrl+F5) ke spuštění aplikace. Výstup bude vypadat následovně: |
|||
|
|||
 |
|||
|
|||
#### Použití EF Core Update-Database příkazu |
|||
|
|||
Ef Core má `Update-Database` příkaz, který v případě potřeby vytvoří databázi a aplikuje čekající migrace. |
|||
|
|||
Nastavte správný spouštěcí projekt (obvykle web projekt) |
|||
|
|||
 |
|||
|
|||
Otevřete **Package Manager Console** (Tools -> Nuget Package Manager -> Package Manager Console), vyberte projekt `.EntityFrameworkCore.DbMigrations` jako **Default Project** and spusťte následující příkaz: |
|||
|
|||
```` |
|||
PM> Update-Database |
|||
```` |
|||
|
|||
Dojde k vytvoření nové databáze na základě nakonfigurovaného connection stringu. |
|||
|
|||
 |
|||
|
|||
> Použití nástroje `.DbMigrator` je doporučený způsob, jelikož zároveň vloží seed data nutné k správnému běhu webové aplikace. |
|||
|
After Width: | Height: | Size: 61 KiB |
|
After Width: | Height: | Size: 40 KiB |
|
After Width: | Height: | Size: 42 KiB |
|
After Width: | Height: | Size: 80 KiB |
|
After Width: | Height: | Size: 178 KiB |
|
After Width: | Height: | Size: 64 KiB |
@ -0,0 +1,11 @@ |
|||
# Data Access |
|||
|
|||
ABP framework was designed as database agnostic, it can work any type of data source by the help of the [repository](Repositories.md) and [unit of work](Unit-Of-Work.md) abstractions. |
|||
|
|||
However, currently the following providers are implements: |
|||
|
|||
* [Entity Framework Core](Entity-Framework-Core.md) (works with [various DBMS and providers](https://docs.microsoft.com/en-us/ef/core/providers/?tabs=dotnet-core-cli).) |
|||
* [MongoDB](MongoDB.md) |
|||
* [Dapper](Dapper.md) |
|||
|
|||
More providers might be added in the next releases. |
|||
|
After Width: | Height: | Size: 9.4 KiB |
@ -0,0 +1,20 @@ |
|||
using System.Threading.Tasks; |
|||
using Microsoft.Extensions.Logging; |
|||
using Microsoft.Extensions.Logging.Abstractions; |
|||
|
|||
namespace Volo.Abp.BackgroundJobs |
|||
{ |
|||
public abstract class AsyncBackgroundJob<TArgs> : IAsyncBackgroundJob<TArgs> |
|||
{ |
|||
//TODO: Add UOW, Localization and other useful properties..?
|
|||
|
|||
public ILogger<AsyncBackgroundJob<TArgs>> Logger { get; set; } |
|||
|
|||
protected AsyncBackgroundJob() |
|||
{ |
|||
Logger = NullLogger<AsyncBackgroundJob<TArgs>>.Instance; |
|||
} |
|||
|
|||
public abstract Task ExecuteAsync(TArgs args); |
|||
} |
|||
} |
|||
@ -0,0 +1,16 @@ |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace Volo.Abp.BackgroundJobs |
|||
{ |
|||
/// <summary>
|
|||
/// Defines interface of a background job.
|
|||
/// </summary>
|
|||
public interface IAsyncBackgroundJob<in TArgs> |
|||
{ |
|||
/// <summary>
|
|||
/// Executes the job with the <see cref="args"/>.
|
|||
/// </summary>
|
|||
/// <param name="args">Job arguments.</param>
|
|||
Task ExecuteAsync(TArgs args); |
|||
} |
|||
} |
|||
@ -1,9 +1,10 @@ |
|||
using Volo.Abp.Threading; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.Threading; |
|||
|
|||
namespace Volo.Abp.BackgroundJobs.RabbitMQ |
|||
{ |
|||
public interface IJobQueueManager : IRunnable |
|||
{ |
|||
IJobQueue<TArgs> Get<TArgs>(); |
|||
Task<IJobQueue<TArgs>> GetAsync<TArgs>(); |
|||
} |
|||
} |
|||
@ -0,0 +1,15 @@ |
|||
using Castle.DynamicProxy; |
|||
using Volo.Abp.DynamicProxy; |
|||
|
|||
namespace Volo.Abp.Castle.DynamicProxy |
|||
{ |
|||
public class AbpAsyncDeterminationInterceptor<TInterceptor> : AsyncDeterminationInterceptor |
|||
where TInterceptor : IAbpInterceptor |
|||
{ |
|||
public AbpAsyncDeterminationInterceptor(TInterceptor abpInterceptor) |
|||
: base(new CastleAsyncAbpInterceptorAdapter<TInterceptor>(abpInterceptor)) |
|||
{ |
|||
|
|||
} |
|||
} |
|||
} |
|||
@ -1,89 +0,0 @@ |
|||
using System.Reflection; |
|||
using System.Threading.Tasks; |
|||
using Castle.DynamicProxy; |
|||
using Volo.Abp.DynamicProxy; |
|||
using Volo.Abp.Threading; |
|||
|
|||
namespace Volo.Abp.Castle.DynamicProxy |
|||
{ |
|||
public class CastleAbpInterceptorAdapter<TInterceptor> : IInterceptor |
|||
where TInterceptor : IAbpInterceptor |
|||
{ |
|||
private static readonly MethodInfo MethodExecuteWithoutReturnValueAsync = |
|||
typeof(CastleAbpInterceptorAdapter<TInterceptor>) |
|||
.GetMethod( |
|||
nameof(ExecuteWithoutReturnValueAsync), |
|||
BindingFlags.NonPublic | BindingFlags.Instance |
|||
); |
|||
|
|||
private static readonly MethodInfo MethodExecuteWithReturnValueAsync = |
|||
typeof(CastleAbpInterceptorAdapter<TInterceptor>) |
|||
.GetMethod( |
|||
nameof(ExecuteWithReturnValueAsync), |
|||
BindingFlags.NonPublic | BindingFlags.Instance |
|||
); |
|||
|
|||
private readonly TInterceptor _abpInterceptor; |
|||
|
|||
public CastleAbpInterceptorAdapter(TInterceptor abpInterceptor) |
|||
{ |
|||
_abpInterceptor = abpInterceptor; |
|||
} |
|||
|
|||
public void Intercept(IInvocation invocation) |
|||
{ |
|||
var proceedInfo = invocation.CaptureProceedInfo(); |
|||
|
|||
var method = invocation.MethodInvocationTarget ?? invocation.Method; |
|||
|
|||
if (method.IsAsync()) |
|||
{ |
|||
InterceptAsyncMethod(invocation, proceedInfo); |
|||
} |
|||
else |
|||
{ |
|||
InterceptSyncMethod(invocation, proceedInfo); |
|||
} |
|||
} |
|||
|
|||
private void InterceptSyncMethod(IInvocation invocation, IInvocationProceedInfo proceedInfo) |
|||
{ |
|||
_abpInterceptor.Intercept(new CastleAbpMethodInvocationAdapter(invocation, proceedInfo)); |
|||
} |
|||
|
|||
private void InterceptAsyncMethod(IInvocation invocation, IInvocationProceedInfo proceedInfo) |
|||
{ |
|||
if (invocation.Method.ReturnType == typeof(Task)) |
|||
{ |
|||
invocation.ReturnValue = MethodExecuteWithoutReturnValueAsync |
|||
.Invoke(this, new object[] { invocation, proceedInfo }); |
|||
} |
|||
else |
|||
{ |
|||
invocation.ReturnValue = MethodExecuteWithReturnValueAsync |
|||
.MakeGenericMethod(invocation.Method.ReturnType.GenericTypeArguments[0]) |
|||
.Invoke(this, new object[] {invocation, proceedInfo}); |
|||
} |
|||
} |
|||
|
|||
private async Task ExecuteWithoutReturnValueAsync(IInvocation invocation, IInvocationProceedInfo proceedInfo) |
|||
{ |
|||
await Task.Yield(); |
|||
|
|||
await _abpInterceptor.InterceptAsync( |
|||
new CastleAbpMethodInvocationAdapter(invocation, proceedInfo) |
|||
); |
|||
} |
|||
|
|||
private async Task<T> ExecuteWithReturnValueAsync<T>(IInvocation invocation, IInvocationProceedInfo proceedInfo) |
|||
{ |
|||
await Task.Yield(); |
|||
|
|||
await _abpInterceptor.InterceptAsync( |
|||
new CastleAbpMethodInvocationAdapter(invocation, proceedInfo) |
|||
); |
|||
|
|||
return await (Task<T>)invocation.ReturnValue; |
|||
} |
|||
} |
|||
} |
|||
@ -1,77 +1,26 @@ |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Reflection; |
|||
using System.Threading.Tasks; |
|||
using Castle.DynamicProxy; |
|||
using Volo.Abp.DynamicProxy; |
|||
using Volo.Abp.Threading; |
|||
|
|||
namespace Volo.Abp.Castle.DynamicProxy |
|||
{ |
|||
public class CastleAbpMethodInvocationAdapter : IAbpMethodInvocation |
|||
public class CastleAbpMethodInvocationAdapter : CastleAbpMethodInvocationAdapterBase, IAbpMethodInvocation |
|||
{ |
|||
public object[] Arguments => Invocation.Arguments; |
|||
|
|||
public IReadOnlyDictionary<string, object> ArgumentsDictionary => _lazyArgumentsDictionary.Value; |
|||
private readonly Lazy<IReadOnlyDictionary<string, object>> _lazyArgumentsDictionary; |
|||
|
|||
public Type[] GenericArguments => Invocation.GenericArguments; |
|||
|
|||
public object TargetObject => Invocation.InvocationTarget ?? Invocation.MethodInvocationTarget; |
|||
|
|||
public MethodInfo Method => Invocation.MethodInvocationTarget ?? Invocation.Method; |
|||
|
|||
public object ReturnValue |
|||
{ |
|||
get => _actualReturnValue ?? Invocation.ReturnValue; |
|||
set => Invocation.ReturnValue = value; |
|||
} |
|||
|
|||
private object _actualReturnValue; |
|||
|
|||
protected IInvocation Invocation { get; } |
|||
protected IInvocationProceedInfo ProceedInfo { get; } |
|||
protected Func<IInvocation, IInvocationProceedInfo, Task> Proceed { get; } |
|||
|
|||
public CastleAbpMethodInvocationAdapter(IInvocation invocation, IInvocationProceedInfo proceedInfo) |
|||
public CastleAbpMethodInvocationAdapter(IInvocation invocation, IInvocationProceedInfo proceedInfo, |
|||
Func<IInvocation, IInvocationProceedInfo, Task> proceed) |
|||
: base(invocation) |
|||
{ |
|||
Invocation = invocation; |
|||
ProceedInfo = proceedInfo; |
|||
|
|||
_lazyArgumentsDictionary = new Lazy<IReadOnlyDictionary<string, object>>(GetArgumentsDictionary); |
|||
Proceed = proceed; |
|||
} |
|||
|
|||
public void Proceed() |
|||
public override async Task ProceedAsync() |
|||
{ |
|||
ProceedInfo.Invoke(); |
|||
|
|||
if (Invocation.Method.IsAsync()) |
|||
{ |
|||
AsyncHelper.RunSync(() => (Task)Invocation.ReturnValue); |
|||
} |
|||
} |
|||
|
|||
public Task ProceedAsync() |
|||
{ |
|||
ProceedInfo.Invoke(); |
|||
|
|||
_actualReturnValue = Invocation.ReturnValue; |
|||
|
|||
return Invocation.Method.IsAsync() |
|||
? (Task)_actualReturnValue |
|||
: Task.FromResult(_actualReturnValue); |
|||
} |
|||
|
|||
private IReadOnlyDictionary<string, object> GetArgumentsDictionary() |
|||
{ |
|||
var dict = new Dictionary<string, object>(); |
|||
|
|||
var methodParameters = Method.GetParameters(); |
|||
for (int i = 0; i < methodParameters.Length; i++) |
|||
{ |
|||
dict[methodParameters[i].Name] = Invocation.Arguments[i]; |
|||
} |
|||
|
|||
return dict; |
|||
await Proceed(Invocation, ProceedInfo); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,48 @@ |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Reflection; |
|||
using System.Threading.Tasks; |
|||
using Castle.DynamicProxy; |
|||
using Volo.Abp.DynamicProxy; |
|||
|
|||
namespace Volo.Abp.Castle.DynamicProxy |
|||
{ |
|||
public abstract class CastleAbpMethodInvocationAdapterBase : IAbpMethodInvocation |
|||
{ |
|||
public object[] Arguments => Invocation.Arguments; |
|||
|
|||
public IReadOnlyDictionary<string, object> ArgumentsDictionary => _lazyArgumentsDictionary.Value; |
|||
private readonly Lazy<IReadOnlyDictionary<string, object>> _lazyArgumentsDictionary; |
|||
|
|||
public Type[] GenericArguments => Invocation.GenericArguments; |
|||
|
|||
public object TargetObject => Invocation.InvocationTarget ?? Invocation.MethodInvocationTarget; |
|||
|
|||
public MethodInfo Method => Invocation.MethodInvocationTarget ?? Invocation.Method; |
|||
|
|||
public object ReturnValue { get; set; } |
|||
|
|||
protected IInvocation Invocation { get; } |
|||
|
|||
protected CastleAbpMethodInvocationAdapterBase(IInvocation invocation) |
|||
{ |
|||
Invocation = invocation; |
|||
_lazyArgumentsDictionary = new Lazy<IReadOnlyDictionary<string, object>>(GetArgumentsDictionary); |
|||
} |
|||
|
|||
public abstract Task ProceedAsync(); |
|||
|
|||
private IReadOnlyDictionary<string, object> GetArgumentsDictionary() |
|||
{ |
|||
var dict = new Dictionary<string, object>(); |
|||
|
|||
var methodParameters = Method.GetParameters(); |
|||
for (int i = 0; i < methodParameters.Length; i++) |
|||
{ |
|||
dict[methodParameters[i].Name] = Invocation.Arguments[i]; |
|||
} |
|||
|
|||
return dict; |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,27 @@ |
|||
using System; |
|||
using System.Threading.Tasks; |
|||
using Castle.DynamicProxy; |
|||
using Volo.Abp.DynamicProxy; |
|||
|
|||
namespace Volo.Abp.Castle.DynamicProxy |
|||
{ |
|||
public class CastleAbpMethodInvocationAdapterWithReturnValue<TResult> : CastleAbpMethodInvocationAdapterBase, IAbpMethodInvocation |
|||
{ |
|||
protected IInvocationProceedInfo ProceedInfo { get; } |
|||
protected Func<IInvocation, IInvocationProceedInfo, Task<TResult>> Proceed { get; } |
|||
|
|||
public CastleAbpMethodInvocationAdapterWithReturnValue(IInvocation invocation, |
|||
IInvocationProceedInfo proceedInfo, |
|||
Func<IInvocation, IInvocationProceedInfo, Task<TResult>> proceed) |
|||
: base(invocation) |
|||
{ |
|||
ProceedInfo = proceedInfo; |
|||
Proceed = proceed; |
|||
} |
|||
|
|||
public override async Task ProceedAsync() |
|||
{ |
|||
ReturnValue = await Proceed(Invocation, ProceedInfo); |
|||
} |
|||
} |
|||
} |
|||
Some files were not shown because too many files changed in this diff
Loading…
Reference in new issue