项目初始化
This commit is contained in:
commit
e667d3f9d2
266
.gitignore
vendored
Normal file
266
.gitignore
vendored
Normal file
|
@ -0,0 +1,266 @@
|
||||||
|
## Ignore Visual Studio temporary files, build results, and
|
||||||
|
## files generated by popular Visual Studio add-ons.
|
||||||
|
|
||||||
|
.vs/
|
||||||
|
|
||||||
|
#Log files
|
||||||
|
HosManager/Logs/
|
||||||
|
|
||||||
|
# User-specific files
|
||||||
|
*.suo
|
||||||
|
*.user
|
||||||
|
*.userosscache
|
||||||
|
*.sln.docstates
|
||||||
|
|
||||||
|
# User-specific files (MonoDevelop/Xamarin Studio)
|
||||||
|
*.userprefs
|
||||||
|
|
||||||
|
# Build results
|
||||||
|
[Dd]ebug/
|
||||||
|
[Dd]ebugPublic/
|
||||||
|
[Rr]elease/
|
||||||
|
[Rr]eleases/
|
||||||
|
x64/
|
||||||
|
x86/
|
||||||
|
bld/
|
||||||
|
[Bb]in/
|
||||||
|
[Oo]bj/
|
||||||
|
[Ll]og/
|
||||||
|
|
||||||
|
# Visual Studio 2015 cache/options directory
|
||||||
|
.vs/
|
||||||
|
# Uncomment if you have tasks that create the project's static files in wwwroot
|
||||||
|
#wwwroot/
|
||||||
|
|
||||||
|
# MSTest test Results
|
||||||
|
[Tt]est[Rr]esult*/
|
||||||
|
[Bb]uild[Ll]og.*
|
||||||
|
|
||||||
|
# NUNIT
|
||||||
|
*.VisualState.xml
|
||||||
|
TestResult.xml
|
||||||
|
|
||||||
|
# Build Results of an ATL Project
|
||||||
|
[Dd]ebugPS/
|
||||||
|
[Rr]eleasePS/
|
||||||
|
dlldata.c
|
||||||
|
|
||||||
|
# DNX
|
||||||
|
project.lock.json
|
||||||
|
project.fragment.lock.json
|
||||||
|
artifacts/
|
||||||
|
|
||||||
|
*_i.c
|
||||||
|
*_p.c
|
||||||
|
*_i.h
|
||||||
|
*.ilk
|
||||||
|
*.meta
|
||||||
|
*.obj
|
||||||
|
*.pch
|
||||||
|
*.pdb
|
||||||
|
*.pgc
|
||||||
|
*.pgd
|
||||||
|
*.rsp
|
||||||
|
*.sbr
|
||||||
|
*.tlb
|
||||||
|
*.tli
|
||||||
|
*.tlh
|
||||||
|
*.tmp
|
||||||
|
*.tmp_proj
|
||||||
|
*.log
|
||||||
|
*.vspscc
|
||||||
|
*.vssscc
|
||||||
|
.builds
|
||||||
|
*.pidb
|
||||||
|
*.svclog
|
||||||
|
*.scc
|
||||||
|
|
||||||
|
# Chutzpah Test files
|
||||||
|
_Chutzpah*
|
||||||
|
|
||||||
|
# Visual C++ cache files
|
||||||
|
ipch/
|
||||||
|
*.aps
|
||||||
|
*.ncb
|
||||||
|
*.opendb
|
||||||
|
*.opensdf
|
||||||
|
*.sdf
|
||||||
|
*.cachefile
|
||||||
|
*.VC.db
|
||||||
|
*.VC.VC.opendb
|
||||||
|
|
||||||
|
# Visual Studio profiler
|
||||||
|
*.psess
|
||||||
|
*.vsp
|
||||||
|
*.vspx
|
||||||
|
*.sap
|
||||||
|
|
||||||
|
# TFS 2012 Local Workspace
|
||||||
|
$tf/
|
||||||
|
|
||||||
|
# Guidance Automation Toolkit
|
||||||
|
*.gpState
|
||||||
|
|
||||||
|
# ReSharper is a .NET coding add-in
|
||||||
|
_ReSharper*/
|
||||||
|
*.[Rr]e[Ss]harper
|
||||||
|
*.DotSettings.user
|
||||||
|
|
||||||
|
# JustCode is a .NET coding add-in
|
||||||
|
.JustCode
|
||||||
|
|
||||||
|
# TeamCity is a build add-in
|
||||||
|
_TeamCity*
|
||||||
|
|
||||||
|
# DotCover is a Code Coverage Tool
|
||||||
|
*.dotCover
|
||||||
|
|
||||||
|
# NCrunch
|
||||||
|
_NCrunch_*
|
||||||
|
.*crunch*.local.xml
|
||||||
|
nCrunchTemp_*
|
||||||
|
|
||||||
|
# MightyMoose
|
||||||
|
*.mm.*
|
||||||
|
AutoTest.Net/
|
||||||
|
|
||||||
|
# Web workbench (sass)
|
||||||
|
.sass-cache/
|
||||||
|
|
||||||
|
# Installshield output folder
|
||||||
|
[Ee]xpress/
|
||||||
|
|
||||||
|
# DocProject is a documentation generator add-in
|
||||||
|
DocProject/buildhelp/
|
||||||
|
DocProject/Help/*.HxT
|
||||||
|
DocProject/Help/*.HxC
|
||||||
|
DocProject/Help/*.hhc
|
||||||
|
DocProject/Help/*.hhk
|
||||||
|
DocProject/Help/*.hhp
|
||||||
|
DocProject/Help/Html2
|
||||||
|
DocProject/Help/html
|
||||||
|
|
||||||
|
# Click-Once directory
|
||||||
|
publish/
|
||||||
|
|
||||||
|
# Publish Web Output
|
||||||
|
*.[Pp]ublish.xml
|
||||||
|
*.azurePubxml
|
||||||
|
# TODO: Comment the next line if you want to checkin your web deploy settings
|
||||||
|
# but database connection strings (with potential passwords) will be unencrypted
|
||||||
|
#*.pubxml
|
||||||
|
*.publishproj
|
||||||
|
|
||||||
|
# Microsoft Azure Web App publish settings. Comment the next line if you want to
|
||||||
|
# checkin your Azure Web App publish settings, but sensitive information contained
|
||||||
|
# in these scripts will be unencrypted
|
||||||
|
PublishScripts/
|
||||||
|
|
||||||
|
# NuGet Packages
|
||||||
|
*.nupkg
|
||||||
|
# The packages folder can be ignored because of Package Restore
|
||||||
|
**/packages/*
|
||||||
|
# except build/, which is used as an MSBuild target.
|
||||||
|
!**/packages/build/
|
||||||
|
# Uncomment if necessary however generally it will be regenerated when needed
|
||||||
|
#!**/packages/repositories.config
|
||||||
|
# NuGet v3's project.json files produces more ignoreable files
|
||||||
|
*.nuget.props
|
||||||
|
*.nuget.targets
|
||||||
|
|
||||||
|
# Microsoft Azure Build Output
|
||||||
|
csx/
|
||||||
|
*.build.csdef
|
||||||
|
|
||||||
|
# Microsoft Azure Emulator
|
||||||
|
ecf/
|
||||||
|
rcf/
|
||||||
|
|
||||||
|
# Windows Store app package directories and files
|
||||||
|
AppPackages/
|
||||||
|
BundleArtifacts/
|
||||||
|
Package.StoreAssociation.xml
|
||||||
|
_pkginfo.txt
|
||||||
|
|
||||||
|
# Visual Studio cache files
|
||||||
|
# files ending in .cache can be ignored
|
||||||
|
*.[Cc]ache
|
||||||
|
# but keep track of directories ending in .cache
|
||||||
|
!*.[Cc]ache/
|
||||||
|
|
||||||
|
# Others
|
||||||
|
ClientBin/
|
||||||
|
~$*
|
||||||
|
*~
|
||||||
|
*.dbmdl
|
||||||
|
*.dbproj.schemaview
|
||||||
|
*.jfm
|
||||||
|
*.pfx
|
||||||
|
*.publishsettings
|
||||||
|
node_modules/
|
||||||
|
orleans.codegen.cs
|
||||||
|
|
||||||
|
# Since there are multiple workflows, uncomment next line to ignore bower_components
|
||||||
|
# (https://github.com/github/gitignore/pull/1529#issuecomment-104372622)
|
||||||
|
#bower_components/
|
||||||
|
|
||||||
|
# RIA/Silverlight projects
|
||||||
|
Generated_Code/
|
||||||
|
|
||||||
|
# Backup & report files from converting an old project file
|
||||||
|
# to a newer Visual Studio version. Backup files are not needed,
|
||||||
|
# because we have git ;-)
|
||||||
|
_UpgradeReport_Files/
|
||||||
|
Backup*/
|
||||||
|
UpgradeLog*.XML
|
||||||
|
UpgradeLog*.htm
|
||||||
|
|
||||||
|
# SQL Server files
|
||||||
|
*.mdf
|
||||||
|
*.ldf
|
||||||
|
|
||||||
|
# Business Intelligence projects
|
||||||
|
*.rdl.data
|
||||||
|
*.bim.layout
|
||||||
|
*.bim_*.settings
|
||||||
|
|
||||||
|
# Microsoft Fakes
|
||||||
|
FakesAssemblies/
|
||||||
|
|
||||||
|
# GhostDoc plugin setting file
|
||||||
|
*.GhostDoc.xml
|
||||||
|
|
||||||
|
# Node.js Tools for Visual Studio
|
||||||
|
.ntvs_analysis.dat
|
||||||
|
|
||||||
|
# Visual Studio 6 build log
|
||||||
|
*.plg
|
||||||
|
|
||||||
|
# Visual Studio 6 workspace options file
|
||||||
|
*.opt
|
||||||
|
|
||||||
|
# Visual Studio LightSwitch build output
|
||||||
|
**/*.HTMLClient/GeneratedArtifacts
|
||||||
|
**/*.DesktopClient/GeneratedArtifacts
|
||||||
|
**/*.DesktopClient/ModelManifest.xml
|
||||||
|
**/*.Server/GeneratedArtifacts
|
||||||
|
**/*.Server/ModelManifest.xml
|
||||||
|
_Pvt_Extensions
|
||||||
|
|
||||||
|
# Paket dependency manager
|
||||||
|
.paket/paket.exe
|
||||||
|
paket-files/
|
||||||
|
|
||||||
|
# FAKE - F# Make
|
||||||
|
.fake/
|
||||||
|
|
||||||
|
# JetBrains Rider
|
||||||
|
.idea/
|
||||||
|
*.sln.iml
|
||||||
|
|
||||||
|
# CodeRush
|
||||||
|
.cr/
|
||||||
|
|
||||||
|
# Python Tools for Visual Studio (PTVS)
|
||||||
|
__pycache__/
|
||||||
|
*.pyc
|
45
Falcon.ModelSP.Test/Db/TestDbContext.cs
Normal file
45
Falcon.ModelSP.Test/Db/TestDbContext.cs
Normal file
|
@ -0,0 +1,45 @@
|
||||||
|
using Microsoft.EntityFrameworkCore;
|
||||||
|
using Falcon.ModelSP;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP.Test.Db
|
||||||
|
{
|
||||||
|
class TestDbContext:DbContext
|
||||||
|
{
|
||||||
|
protected TestDbContext() { }
|
||||||
|
protected TestDbContext(DbContextOptions option) : base(option) { }
|
||||||
|
|
||||||
|
public static TestDbContext GetDbInMemory() {
|
||||||
|
var option = new DbContextOptionsBuilder<TestDbContext>().UseInMemoryDatabase("TestDb").Options;
|
||||||
|
var db = new TestDbContext(option);
|
||||||
|
AddTestPr(db);
|
||||||
|
return db;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void AddTestPr(TestDbContext db) {
|
||||||
|
var sql = @"
|
||||||
|
DROP PROC Pr_AddOne
|
||||||
|
CREATE PROCEDURE Pr_AddOne
|
||||||
|
@a AS INT
|
||||||
|
AS
|
||||||
|
Set Nocount On
|
||||||
|
SELECT @a+1 aa;
|
||||||
|
GO
|
||||||
|
";
|
||||||
|
//db.Database.ExecuteSqlCommandAsync(sql).Wait();
|
||||||
|
}
|
||||||
|
|
||||||
|
public IEnumerable<Pr_AddOneResult> Pr_AddOne(Pr_AddOne data) {
|
||||||
|
return this.RunProcuder<Pr_AddOne,Pr_AddOneResult>(data);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public class Pr_AddOne
|
||||||
|
{
|
||||||
|
public int A { get; set; }
|
||||||
|
}
|
||||||
|
public class Pr_AddOneResult
|
||||||
|
{
|
||||||
|
public int Aa { get; set; }
|
||||||
|
}
|
||||||
|
}
|
21
Falcon.ModelSP.Test/Falcon.ModelSP.Test.csproj
Normal file
21
Falcon.ModelSP.Test/Falcon.ModelSP.Test.csproj
Normal file
|
@ -0,0 +1,21 @@
|
||||||
|
<Project Sdk="Microsoft.NET.Sdk">
|
||||||
|
|
||||||
|
<PropertyGroup>
|
||||||
|
<TargetFramework>netcoreapp2.2</TargetFramework>
|
||||||
|
|
||||||
|
<IsPackable>false</IsPackable>
|
||||||
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="Microsoft.EntityFrameworkCore" Version="2.2.6" />
|
||||||
|
<PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="2.2.6" />
|
||||||
|
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.0.1" />
|
||||||
|
<PackageReference Include="MSTest.TestAdapter" Version="1.4.0" />
|
||||||
|
<PackageReference Include="MSTest.TestFramework" Version="1.4.0" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<ProjectReference Include="..\Falcon.ModelSP\Falcon.ModelSP.csproj" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
</Project>
|
61
Falcon.ModelSP.Test/ModelSPTest.cs
Normal file
61
Falcon.ModelSP.Test/ModelSPTest.cs
Normal file
|
@ -0,0 +1,61 @@
|
||||||
|
using Microsoft.VisualStudio.TestTools.UnitTesting;
|
||||||
|
using Falcon.ModelSP;
|
||||||
|
using System.Linq;
|
||||||
|
using Falcon.ModelSP.Test.Db;
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP.Test
|
||||||
|
{
|
||||||
|
[TestClass]
|
||||||
|
public class ModelSPTest
|
||||||
|
{
|
||||||
|
[TestMethod]
|
||||||
|
public void getParamsTest() {
|
||||||
|
var model = new ParmModel { Id = 1,Name = "n1",AAAge = 10 };
|
||||||
|
|
||||||
|
var data = DataExtend.getParams(model);
|
||||||
|
Assert.IsNotNull(data);
|
||||||
|
Assert.IsTrue(data.Count() == typeof(ParmModel).GetProperties().Length - 1);
|
||||||
|
|
||||||
|
Assert.IsTrue(data.Any(m => m.ParameterName == "@Id" && m.Value.Equals(1)));
|
||||||
|
Assert.IsTrue(data.Any(m => m.ParameterName == "@Name" && m.Value.Equals("n1")));
|
||||||
|
Assert.IsTrue(data.Any(m => m.ParameterName == "@age" && m.Value.Equals(10)));
|
||||||
|
Assert.IsTrue(!data.Any(m => m.ParameterName == "@Address"));
|
||||||
|
}
|
||||||
|
|
||||||
|
[TestMethod]
|
||||||
|
public void getProcuderNameTest() {
|
||||||
|
var model = new ParmModel { };
|
||||||
|
Assert.IsTrue(DataExtend.getProcuderName<ParmModel>() == "ParmModel");
|
||||||
|
Assert.IsTrue(DataExtend.getProcuderName<ParmModel1>() == "sp123");
|
||||||
|
}
|
||||||
|
|
||||||
|
class ParmModel
|
||||||
|
{
|
||||||
|
public int Id { get; set; }
|
||||||
|
|
||||||
|
public string Name { get; set; }
|
||||||
|
|
||||||
|
[FalconSPPrarmName("age")]
|
||||||
|
public int AAAge { get; set; }
|
||||||
|
|
||||||
|
[FalconSPIgnore]
|
||||||
|
public string Address { get; set; }
|
||||||
|
}
|
||||||
|
|
||||||
|
[FalconSPProcuderName("sp123")]
|
||||||
|
class ParmModel1 { }
|
||||||
|
|
||||||
|
[TestMethod]
|
||||||
|
public void InMemoryDbTest() {
|
||||||
|
//内存数据库无法使用关系模型,测试无法进行
|
||||||
|
return;
|
||||||
|
using(var db = TestDbContext.GetDbInMemory()) {
|
||||||
|
var re = db.Pr_AddOne(new Pr_AddOne { A = 1 });
|
||||||
|
Assert.IsTrue(re != null);
|
||||||
|
Assert.IsTrue(re.Any());
|
||||||
|
var first = re.First();
|
||||||
|
Assert.IsTrue(first.Aa == 2);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
31
Falcon.ModelSP.sln
Normal file
31
Falcon.ModelSP.sln
Normal file
|
@ -0,0 +1,31 @@
|
||||||
|
|
||||||
|
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||||
|
# Visual Studio Version 16
|
||||||
|
VisualStudioVersion = 16.0.29509.3
|
||||||
|
MinimumVisualStudioVersion = 10.0.40219.1
|
||||||
|
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Falcon.ModelSP", "Falcon.ModelSP\Falcon.ModelSP.csproj", "{0EBEFFE2-D7C0-4E41-9AA4-F9E130E5E825}"
|
||||||
|
EndProject
|
||||||
|
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Falcon.ModelSP.Test", "Falcon.ModelSP.Test\Falcon.ModelSP.Test.csproj", "{F3184885-2AB1-42A5-8570-4C6429D6FCBD}"
|
||||||
|
EndProject
|
||||||
|
Global
|
||||||
|
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||||
|
Debug|Any CPU = Debug|Any CPU
|
||||||
|
Release|Any CPU = Release|Any CPU
|
||||||
|
EndGlobalSection
|
||||||
|
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||||
|
{0EBEFFE2-D7C0-4E41-9AA4-F9E130E5E825}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||||
|
{0EBEFFE2-D7C0-4E41-9AA4-F9E130E5E825}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||||
|
{0EBEFFE2-D7C0-4E41-9AA4-F9E130E5E825}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||||
|
{0EBEFFE2-D7C0-4E41-9AA4-F9E130E5E825}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||||
|
{F3184885-2AB1-42A5-8570-4C6429D6FCBD}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||||
|
{F3184885-2AB1-42A5-8570-4C6429D6FCBD}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||||
|
{F3184885-2AB1-42A5-8570-4C6429D6FCBD}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||||
|
{F3184885-2AB1-42A5-8570-4C6429D6FCBD}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||||
|
EndGlobalSection
|
||||||
|
GlobalSection(SolutionProperties) = preSolution
|
||||||
|
HideSolutionNode = FALSE
|
||||||
|
EndGlobalSection
|
||||||
|
GlobalSection(ExtensibilityGlobals) = postSolution
|
||||||
|
SolutionGuid = {CA8B38ED-C59C-47BF-B783-E932E4044BA0}
|
||||||
|
EndGlobalSection
|
||||||
|
EndGlobal
|
125
Falcon.ModelSP/DataExtend.cs
Normal file
125
Falcon.ModelSP/DataExtend.cs
Normal file
|
@ -0,0 +1,125 @@
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Data.Common;
|
||||||
|
using Microsoft.Data.SqlClient;
|
||||||
|
using System.Linq;
|
||||||
|
using System.Reflection;
|
||||||
|
using Microsoft.EntityFrameworkCore;
|
||||||
|
using Microsoft.EntityFrameworkCore.Infrastructure;
|
||||||
|
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 数据库上下文方法扩展
|
||||||
|
/// </summary>
|
||||||
|
public static class DataExtend
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 执行无返回值的存储过程
|
||||||
|
/// </summary>
|
||||||
|
/// <typeparam name="TPrarmType">参数类型</typeparam>
|
||||||
|
/// <param name="db">数据上下文</param>
|
||||||
|
/// <param name="data">参数数据</param>
|
||||||
|
public static int RunProcuder<TPrarmType>(this DbContext db,TPrarmType data) {
|
||||||
|
var parms = getParams(data);
|
||||||
|
return db.Database.ExecuteSqlCommand(getProcuderName<TPrarmType>(),parms.ToArray());
|
||||||
|
}
|
||||||
|
/// <summary>
|
||||||
|
/// 执行有返回值的存储过程
|
||||||
|
/// </summary>
|
||||||
|
/// <typeparam name="TPrarmType">参数类型</typeparam>
|
||||||
|
/// <typeparam name="TResultType">返回结果项类型</typeparam>
|
||||||
|
/// <param name="db">数据上下文</param>
|
||||||
|
/// <param name="data">参数数据</param>
|
||||||
|
public static IEnumerable<TResultType> RunProcuder<TPrarmType, TResultType>(this DbContext db,TPrarmType data)
|
||||||
|
where TResultType : class, new() {
|
||||||
|
var parms = getParams(data);
|
||||||
|
return db.Database.SqlQuery<TResultType>(getProcuderName<TPrarmType>(),parms.ToArray()).ToList();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 获取存储过程参数枚举
|
||||||
|
/// </summary>
|
||||||
|
/// <typeparam name="T">参数模型类型</typeparam>
|
||||||
|
/// <param name="data">参数实例</param>
|
||||||
|
public static IEnumerable<SqlParameter> getParams<T>(T data) {
|
||||||
|
if(data == null)
|
||||||
|
yield break;
|
||||||
|
foreach(var p in typeof(T).GetProperties()) {
|
||||||
|
if(!p.CanRead || ignoreProp(p))
|
||||||
|
continue;
|
||||||
|
yield return new SqlParameter($"@{getName(p)}",p.GetValue(data));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 是否忽略属性
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="p">要检查的属性</param>
|
||||||
|
private static bool ignoreProp(PropertyInfo p) {
|
||||||
|
return p.GetCustomAttribute<FalconSPIgnoreAttribute>(true) != null;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 获取存储过程参数名称
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="p">对应的属性</param>
|
||||||
|
private static string getName(PropertyInfo p) {
|
||||||
|
var np = p.GetCustomAttribute<FalconSPPrarmNameAttribute>(true);
|
||||||
|
if(np != null && np is FalconSPPrarmNameAttribute na) {
|
||||||
|
return na.Name;
|
||||||
|
}
|
||||||
|
return p.Name;
|
||||||
|
}
|
||||||
|
/// <summary>
|
||||||
|
/// 获取存储过程名
|
||||||
|
/// </summary>
|
||||||
|
/// <typeparam name="T">参数模型</typeparam>
|
||||||
|
public static string getProcuderName<T>() {
|
||||||
|
var attr = typeof(T).GetCustomAttribute<FalconSPProcuderNameAttribute>(true);
|
||||||
|
if(attr != null && attr is FalconSPProcuderNameAttribute pna && !string.IsNullOrEmpty(pna.ProcuderName)) {
|
||||||
|
return pna.ProcuderName;
|
||||||
|
}
|
||||||
|
return typeof(T).Name;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 根据传入的sql语句和参数枚举执行存储过程,并且返回类型枚举
|
||||||
|
/// </summary>
|
||||||
|
/// <typeparam name="TR">返回值类型</typeparam>
|
||||||
|
/// <param name="db">数据库上下文</param>
|
||||||
|
/// <param name="sql">要执行的sql语句</param>
|
||||||
|
/// <param name="para">参数枚举</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public static IEnumerable<TR> SqlQuery<TR>(this DatabaseFacade db,string sql,params SqlParameter[] paras)
|
||||||
|
where TR : class, new() {
|
||||||
|
var connection = db.GetDbConnection();
|
||||||
|
using(var cmd = connection.CreateCommand()) {
|
||||||
|
cmd.CommandText = sql;
|
||||||
|
cmd.CommandType = System.Data.CommandType.StoredProcedure;
|
||||||
|
cmd.Parameters.AddRange(paras);
|
||||||
|
connection.Open();
|
||||||
|
var dr = cmd.ExecuteReader();
|
||||||
|
var result = new List<TR>();
|
||||||
|
if(!dr.CanGetColumnSchema())
|
||||||
|
return result;
|
||||||
|
while(dr.Read()) {
|
||||||
|
var item = new TR();
|
||||||
|
var columnSchema = dr.GetColumnSchema();
|
||||||
|
for(var i = 0;i < columnSchema.Count;i++) {
|
||||||
|
var name = dr.GetName(i);
|
||||||
|
var value = dr.IsDBNull(i) ? null : dr.GetValue(i);
|
||||||
|
var pi = typeof(TR).GetProperty(name);
|
||||||
|
if(pi == null || !pi.CanWrite)
|
||||||
|
continue;
|
||||||
|
pi.SetValue(item,value);
|
||||||
|
}
|
||||||
|
result.Add(item);
|
||||||
|
}
|
||||||
|
connection.Close();
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
21
Falcon.ModelSP/Falcon.ModelSP.csproj
Normal file
21
Falcon.ModelSP/Falcon.ModelSP.csproj
Normal file
|
@ -0,0 +1,21 @@
|
||||||
|
<Project Sdk="Microsoft.NET.Sdk">
|
||||||
|
|
||||||
|
<PropertyGroup>
|
||||||
|
<TargetFrameworks>netstandard2.0</TargetFrameworks>
|
||||||
|
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
|
||||||
|
<AssemblyVersion>1.0.1.0</AssemblyVersion>
|
||||||
|
<FileVersion>1.0.1.0</FileVersion>
|
||||||
|
<Version>1.0.1</Version>
|
||||||
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<PropertyGroup Condition="'$(Configuration)|$(TargetFramework)|$(Platform)'=='Release|netstandard2.0|AnyCPU'">
|
||||||
|
<DocumentationFile>C:\Documentation\develop\FalconCore\Falcon.ModelSP\Falcon.ModelSP.xml</DocumentationFile>
|
||||||
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="Microsoft.Data.SqlClient" Version="1.1.0" />
|
||||||
|
<PackageReference Include="Microsoft.EntityFrameworkCore" Version="2.2.6" />
|
||||||
|
<PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="2.2.6" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
</Project>
|
124
Falcon.ModelSP/Falcon.ModelSP.xml
Normal file
124
Falcon.ModelSP/Falcon.ModelSP.xml
Normal file
|
@ -0,0 +1,124 @@
|
||||||
|
<?xml version="1.0"?>
|
||||||
|
<doc>
|
||||||
|
<assembly>
|
||||||
|
<name>Falcon.ModelSP</name>
|
||||||
|
</assembly>
|
||||||
|
<members>
|
||||||
|
<member name="T:Falcon.ModelSP.DataExtend">
|
||||||
|
<summary>
|
||||||
|
数据库上下文方法扩展
|
||||||
|
</summary>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.DataExtend.RunProcuder``1(Microsoft.EntityFrameworkCore.DbContext,``0)">
|
||||||
|
<summary>
|
||||||
|
执行无返回值的存储过程
|
||||||
|
</summary>
|
||||||
|
<typeparam name="TPrarmType">参数类型</typeparam>
|
||||||
|
<param name="db">数据上下文</param>
|
||||||
|
<param name="data">参数数据</param>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.DataExtend.RunProcuder``2(Microsoft.EntityFrameworkCore.DbContext,``0)">
|
||||||
|
<summary>
|
||||||
|
执行有返回值的存储过程
|
||||||
|
</summary>
|
||||||
|
<typeparam name="TPrarmType">参数类型</typeparam>
|
||||||
|
<typeparam name="TResultType">返回结果项类型</typeparam>
|
||||||
|
<param name="db">数据上下文</param>
|
||||||
|
<param name="data">参数数据</param>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.DataExtend.getParams``1(``0)">
|
||||||
|
<summary>
|
||||||
|
获取存储过程参数枚举
|
||||||
|
</summary>
|
||||||
|
<typeparam name="T">参数模型类型</typeparam>
|
||||||
|
<param name="data">参数实例</param>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.DataExtend.ignoreProp(System.Reflection.PropertyInfo)">
|
||||||
|
<summary>
|
||||||
|
是否忽略属性
|
||||||
|
</summary>
|
||||||
|
<param name="p">要检查的属性</param>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.DataExtend.getName(System.Reflection.PropertyInfo)">
|
||||||
|
<summary>
|
||||||
|
获取存储过程参数名称
|
||||||
|
</summary>
|
||||||
|
<param name="p">对应的属性</param>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.DataExtend.getProcuderName``1">
|
||||||
|
<summary>
|
||||||
|
获取存储过程名
|
||||||
|
</summary>
|
||||||
|
<typeparam name="T">参数模型</typeparam>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.DataExtend.SqlQuery``1(Microsoft.EntityFrameworkCore.Infrastructure.DatabaseFacade,System.String,Microsoft.Data.SqlClient.SqlParameter[])">
|
||||||
|
<summary>
|
||||||
|
根据传入的sql语句和参数枚举执行存储过程,并且返回类型枚举
|
||||||
|
</summary>
|
||||||
|
<typeparam name="TR">返回值类型</typeparam>
|
||||||
|
<param name="db">数据库上下文</param>
|
||||||
|
<param name="sql">要执行的sql语句</param>
|
||||||
|
<param name="para">参数枚举</param>
|
||||||
|
<returns></returns>
|
||||||
|
</member>
|
||||||
|
<member name="T:Falcon.ModelSP.FalconSPIgnoreAttribute">
|
||||||
|
<summary>
|
||||||
|
表示调用时候忽略此属性
|
||||||
|
</summary>
|
||||||
|
</member>
|
||||||
|
<member name="T:Falcon.ModelSP.FalconSPPrarmNameAttribute">
|
||||||
|
<summary>
|
||||||
|
定义名称
|
||||||
|
</summary>
|
||||||
|
</member>
|
||||||
|
<member name="T:Falcon.ModelSP.FalconSPProcuderNameAttribute">
|
||||||
|
<summary>
|
||||||
|
定义存储过程名称
|
||||||
|
</summary>
|
||||||
|
</member>
|
||||||
|
<member name="T:Falcon.ModelSP.FalconSPRuner">
|
||||||
|
<summary>
|
||||||
|
存储过程执行器实现
|
||||||
|
</summary>
|
||||||
|
</member>
|
||||||
|
<member name="T:Falcon.ModelSP.IFalconSPRuner">
|
||||||
|
<summary>
|
||||||
|
执行存储过程接口
|
||||||
|
</summary>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.IFalconSPRuner.RunSP``1(Microsoft.EntityFrameworkCore.DbContext,``0)">
|
||||||
|
<summary>
|
||||||
|
通过数据库上下文执行无返回值的存储过程
|
||||||
|
</summary>
|
||||||
|
<typeparam name="TPrarmType">参数类型</typeparam>
|
||||||
|
<param name="db">数据上下文</param>
|
||||||
|
<param name="data">参数数据</param>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.IFalconSPRuner.RunSP``2(Microsoft.EntityFrameworkCore.DbContext,``0)">
|
||||||
|
<summary>
|
||||||
|
通过数据库上下文执行存储过程,并返回查询结果
|
||||||
|
</summary>
|
||||||
|
<typeparam name="TPrarmType">参数类型</typeparam>
|
||||||
|
<typeparam name="TResultType">返回结果项类型</typeparam>
|
||||||
|
<param name="db">数据上下文</param>
|
||||||
|
<param name="data">参数数据</param>
|
||||||
|
</member>
|
||||||
|
<member name="T:Falcon.ModelSP.IServiceCollectionExtend">
|
||||||
|
<summary>
|
||||||
|
IServiceCollection扩展
|
||||||
|
</summary>
|
||||||
|
</member>
|
||||||
|
<member name="M:Falcon.ModelSP.IServiceCollectionExtend.UseFalconSP(Microsoft.Extensions.DependencyInjection.IServiceCollection)">
|
||||||
|
<summary>
|
||||||
|
注册对数据库存储过程模型化的调用扩展
|
||||||
|
</summary>
|
||||||
|
<param name="services">注册服务集合</param>
|
||||||
|
<returns></returns>
|
||||||
|
</member>
|
||||||
|
<member name="T:Falcon.ModelSP.ProcuderNotFoundException">
|
||||||
|
<summary>
|
||||||
|
存储过程没有找到的异常
|
||||||
|
</summary>
|
||||||
|
</member>
|
||||||
|
</members>
|
||||||
|
</doc>
|
11
Falcon.ModelSP/FalconSPIgnoreAttribute.cs
Normal file
11
Falcon.ModelSP/FalconSPIgnoreAttribute.cs
Normal file
|
@ -0,0 +1,11 @@
|
||||||
|
using System;
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 表示调用时候忽略此属性
|
||||||
|
/// </summary>
|
||||||
|
public class FalconSPIgnoreAttribute:Attribute
|
||||||
|
{
|
||||||
|
}
|
||||||
|
}
|
13
Falcon.ModelSP/FalconSPPrarmNameAttribute.cs
Normal file
13
Falcon.ModelSP/FalconSPPrarmNameAttribute.cs
Normal file
|
@ -0,0 +1,13 @@
|
||||||
|
using System;
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 定义名称
|
||||||
|
/// </summary>
|
||||||
|
public class FalconSPPrarmNameAttribute:Attribute
|
||||||
|
{
|
||||||
|
public FalconSPPrarmNameAttribute(string name) { this.Name = name; }
|
||||||
|
public string Name { get; set; }
|
||||||
|
}
|
||||||
|
}
|
14
Falcon.ModelSP/FalconSPProcuderNameAttribute.cs
Normal file
14
Falcon.ModelSP/FalconSPProcuderNameAttribute.cs
Normal file
|
@ -0,0 +1,14 @@
|
||||||
|
using System;
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 定义存储过程名称
|
||||||
|
/// </summary>
|
||||||
|
public class FalconSPProcuderNameAttribute:Attribute
|
||||||
|
{
|
||||||
|
public string ProcuderName { get; set; }
|
||||||
|
|
||||||
|
public FalconSPProcuderNameAttribute(string m) => this.ProcuderName = m;
|
||||||
|
}
|
||||||
|
}
|
20
Falcon.ModelSP/FalconSPRuner.cs
Normal file
20
Falcon.ModelSP/FalconSPRuner.cs
Normal file
|
@ -0,0 +1,20 @@
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using Microsoft.EntityFrameworkCore;
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 存储过程执行器实现
|
||||||
|
/// </summary>
|
||||||
|
public class FalconSPRuner:IFalconSPRuner
|
||||||
|
{
|
||||||
|
public int RunSP<TPrarmType>(DbContext db,TPrarmType data) {
|
||||||
|
return db.RunProcuder(data);
|
||||||
|
}
|
||||||
|
|
||||||
|
public IEnumerable<TResultType> RunSP<TPrarmType, TResultType>(DbContext db,TPrarmType data)
|
||||||
|
where TResultType : class, new() {
|
||||||
|
return db.RunProcuder<TPrarmType,TResultType>(data);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
28
Falcon.ModelSP/IFalconSPRuner.cs
Normal file
28
Falcon.ModelSP/IFalconSPRuner.cs
Normal file
|
@ -0,0 +1,28 @@
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using Microsoft.EntityFrameworkCore;
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 执行存储过程接口
|
||||||
|
/// </summary>
|
||||||
|
public interface IFalconSPRuner
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 通过数据库上下文执行无返回值的存储过程
|
||||||
|
/// </summary>
|
||||||
|
/// <typeparam name="TPrarmType">参数类型</typeparam>
|
||||||
|
/// <param name="db">数据上下文</param>
|
||||||
|
/// <param name="data">参数数据</param>
|
||||||
|
int RunSP<TPrarmType>(DbContext db,TPrarmType data);
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 通过数据库上下文执行存储过程,并返回查询结果
|
||||||
|
/// </summary>
|
||||||
|
/// <typeparam name="TPrarmType">参数类型</typeparam>
|
||||||
|
/// <typeparam name="TResultType">返回结果项类型</typeparam>
|
||||||
|
/// <param name="db">数据上下文</param>
|
||||||
|
/// <param name="data">参数数据</param>
|
||||||
|
IEnumerable<TResultType> RunSP<TPrarmType, TResultType>(DbContext db,TPrarmType data) where TResultType : class, new();
|
||||||
|
}
|
||||||
|
}
|
19
Falcon.ModelSP/IServiceCollectionExtend.cs
Normal file
19
Falcon.ModelSP/IServiceCollectionExtend.cs
Normal file
|
@ -0,0 +1,19 @@
|
||||||
|
using Microsoft.Extensions.DependencyInjection;
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// IServiceCollection扩展
|
||||||
|
/// </summary>
|
||||||
|
public static class IServiceCollectionExtend
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 注册对数据库存储过程模型化的调用扩展
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="services">注册服务集合</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public static IServiceCollection UseFalconSP(this IServiceCollection services) {
|
||||||
|
return services.AddSingleton<IFalconSPRuner,FalconSPRuner>();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
12
Falcon.ModelSP/ProcuderNotFoundException.cs
Normal file
12
Falcon.ModelSP/ProcuderNotFoundException.cs
Normal file
|
@ -0,0 +1,12 @@
|
||||||
|
using System;
|
||||||
|
|
||||||
|
namespace Falcon.ModelSP
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 存储过程没有找到的异常
|
||||||
|
/// </summary>
|
||||||
|
public class ProcuderNotFoundException:Exception
|
||||||
|
{
|
||||||
|
public ProcuderNotFoundException() : base("存储过程没有找到") { }
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user