using System.Data;
using System.Data.Common;
using System.Data.Entity;public static class DbContextExtensions
{/** needOnly EntityFramework*/public static DataTable DataTable(this DbContext context, string sqlQuery, params DbParameter[] parameters){DataTable dataTable = new DataTable();DbConnection connection = context.Database.Connection;DbProviderFactory dbFactory = DbProviderFactories.GetFactory(connection);using (var cmd = dbFactory.CreateCommand()){cmd.Connection = connection;cmd.CommandType = CommandType.Text;cmd.CommandText = sqlQuery;if (parameters != null){foreach (var item in parameters){cmd.Parameters.Add(item);}}using (DbDataAdapter adapter = dbFactory.CreateDataAdapter()){adapter.SelectCommand = cmd;adapter.Fill(dataTable);}}return dataTable;}
}

实体框架核心(Entity Framework Core)

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Data;
using System.Data.Common;
using Microsoft.EntityFrameworkCore;public static class DbContextExtensions
{/** needMicrosoft.EntityFrameworkCoreMicrosoft.EntityFrameworkCore.Relational*/public static DataTable DataTable(this DbContext context, string sqlQuery, params DbParameter[] parameters){DataTable dataTable = new DataTable();DbConnection connection = context.Database.GetDbConnection();DbProviderFactory dbFactory = DbProviderFactories.GetFactory(connection);using (var cmd = dbFactory.CreateCommand()){cmd.Connection = connection;cmd.CommandType = CommandType.Text;cmd.CommandText = sqlQuery;if (parameters != null){foreach (var item in parameters){cmd.Parameters.Add(item);}}using (DbDataAdapter adapter = dbFactory.CreateDataAdapter()){adapter.SelectCommand = cmd;adapter.Fill(dataTable);}}return dataTable;}
}

我试图将代码放到一个普通项目中，这实际上取决于Microsoft.EntityFrameworkCore.Relational。默认情况下，它会自动包含任何提供程序DLL，比如Microsoft.EntityFrameworkCore.SqlServer。

var db = new MopDb();
DataTable allUser = db.DataTable("SELECT * FROM [dbo].[tbl_test_role]");

使用参数化查询

var db = new MopDb();/*stored procedure*/
DataTable searchUser = db.DataTable("EXEC sp_test_role @name = @paramName",new SqlParameter("paramName", SqlDbType.NVarChar) { Value = "sa" }
);/*select query*/
DataTable likeUser = db.DataTable("SELECT * FROM [dbo].[tbl_test_role] WHERE [name] LIKE '%' + @paramName +'%'",new SqlParameter("paramName", SqlDbType.NVarChar) { Value = "a" }
);

我们正在执行存储过程和查询，我相信函数也将起作用。

CREATE TABLE [dbo].[tbl_test_role] ([id]   INT           IDENTITY (1, 1) NOT NULL,[name] NVARCHAR (50) NOT NULL,[details] NVARCHAR (150) NULL,PRIMARY KEY CLUSTERED ([id] ASC)
);
INSERT INTO [dbo].[tbl_test_role] (name)
VALUES ('admin'), ('sa'), ('user');CREATE PROCEDURE sp_test_role @name nvarchar(30)
AS
BEGINSELECT * FROM [dbo].[tbl_test_role]WHERE [name] = @name;
END;

如果需要，可以删除Db对象

DROP TABLE [dbo].[tbl_test_role];
DROP PROCEDURE sp_test_role;

解决方案和项目

<connectionStrings><add name="MopDbConnection" connectionString="Data Source=10.10.15.13\DB002;Initial Catalog=TESTDB; PASSWORD=dhaka; USER ID=FSTEST;"providerName="System.Data.SqlClient" />
</connectionStrings>

WithEfCore中的appsettings.json：

"ConnectionStrings": {"MopDbConnection": "server=10.10.15.13\\DB002;database=TESTDB;user id=FSTEST;password=dhaka"
}