之前,当我想使用代码优先方法将 SQL 文件表与我的 .Net Core 应用程序一起使用时,我提出了这个问题但没有找到答案。好吧,既然我已经解决了这个问题,我想分享一下。我不会详细介绍每一个细节,但是,这在微软的网站上有详细的定义。
首先,您需要在 SQL Server 实例级别启用文件流支持。右键单击 SQL Server 配置管理器中的 MSSQLSERVER 服务(我的 SQL Server 实例名称是 MSSQLSERVER),然后选择属性。在 FileStream 选项卡中,启用前两个复选框(“Enable Filestream for transact-SQL access & Enable Filestream for file I/O access”)。然后重启服务。
在 SQL Server Management Studio (SSMS) 中,右键单击顶部节点(主要以您的计算机名称命名)并单击属性。转到“高级”选项卡并根据需要更改 FILESTREAM 访问级别(无论是事务 SQL 还是完全访问)。
此后,您应该通过以下查询创建数据库:
CREATE DATABASE xyz
ON PRIMARY
(NAME = FS,
FILENAME = 'D:\Database\xyzDB.mdf'),
FILEGROUP FileStreamFS CONTAINS FILESTREAM(NAME = FStream,
FILENAME = 'D:\Database\xyzFs')
LOG ON
(NAME = FILESDBLog,
FILENAME = 'D:\Database\xyzDBLog.ldf')
WITH FILESTREAM (NON_TRANSACTED_ACCESS = FULL, DIRECTORY_NAME = N'xyz')
GO
这里,D:\Database 是我存储数据库文件的目录,包括将存储在 SQL 文件表中的文件。 xyz 是数据库的名称,后缀为DB.mdf、Fs 和DBLog.ldf,其后为前缀N。我启用了NON_TRANSACTED_ACCESS;但如果您不想进行此类访问,则可以禁用。请注意,在运行此查询之前,目录必须存在。
现在您已经创建了数据库,您可以继续从您的 .Net 应用程序运行迁移,并在您的连接字符串中使用相同的数据库名称。
您还需要一个 SQL 函数来支持您的操作,我使用 MigrationBuilder 类创建了它:
migrationBuilder.Sql("CREATE FUNCTION dbo.HierarchyIdToString (@Id hierarchyid) RETURNS varchar(max) with schemabinding AS BEGIN RETURN CONVERT(varchar(max),CONVERT(varbinary(max),@Id,1),1); END");
与
migrationBuilder.SQL("CREATE FUNCTION StringToHierarchyId (@Id varchar(max)) "+
"RETURNS hierarchyid WITH SCHEMABINDING AS "+
"BEGIN "+
"RETURN CONVERT(hierarchyid,CONVERT(VARBINARY(MAX),@Id,1),1) "+
"END");
稍后,我将使用这个函数,并沿途解释它的作用。
现在,创建用于存储文件的文件表。当然,您可以为不同类型的文件创建任意数量的文件表。
migrationBuilder.Sql("CREATE TABLE DocumentStore AS FILETABLE WITH (FileTable_Directory = 'DocumentStore', FileTable_Collate_Filename = database_default);");
我的文件表名称是DocumentStore。
您还需要一个存储过程来获取文件表根路径(它存储文件的位置),以便在文件系统级别访问这些文件,以防您想访问 NON-交易方式。下面是代码:
migrationBuilder.Sql("CREATE PROCEDURE GetFileTableRootPath @TableName VARCHAR(100), @Path VARCHAR(1000) OUTPUT AS BEGIN SET @Path = (SELECT FILETABLEROOTPATH(@TableName)) END");
请注意,FILETABLEROOTPATH('TableName') 是我在存储过程中使用的内置函数。我知道如何在 .Net 中调用存储过程,所以我只是将函数包装在存储过程中。
我创建了另一个存储过程来获取文件表中存储的任何文件的Path_Locator。 Path_Locator 是文件表的主键,我稍后需要将其作为对该文件的引用输入到另一个表中。代码是:
migrationBuilder.Sql("CREATE PROCEDURE GetFileTableRootPath @TableName VARCHAR(100), @Path VARCHAR(1000) OUTPUT AS BEGIN SET @Path = (SELECT FILETABLEROOTPATH(@TableName)) END");
我还使用名为 Documents.cs 的简单 .Net 模型类创建了一个表,其中包括正常属性(尽管它们在文件表中也可用,但重复了),包括在文件表中引用文件的属性。由于文件表有PK名为Path_Locator,类型为HIERARCHYID,我在Documents表中创建了varchar(max)字段,并将Path_Locator从SQLHIERARCHYID数据转换为SQLVARCHAR后存储在该列中类型。此表是我的域类的一部分,并且将具有与表通常具有的关系。
现在我已经创建了支持表,我还需要实现 CASCADE DELETE 功能,这可以通过使用 SQL 触发器来完成。文件表上的第一个触发器为:
migrationBuilder.Sql(
"CREATE TRIGGER dbo.CascadeDelete ON DocumentStore "+
"AFTER DELETE NOT FOR REPLICATION " +
"AS "+
"BEGIN "+
"SET NOCOUNT ON "+
"DECLARE @Id varchar(max); "+
"DECLARE @Table Table (MyHierarchy hierarchyid); "+
"INSERT INTO @Table SELECT deleted.path_locator from deleted; "+
"WHILE ((SELECT COUNT(*) FROM @Table) > 0) "+
"BEGIN "+
"select @Id = dbo.HierarchyIdToString((SELECT TOP 1 * from @Table)); "+
"DELETE FROM Documents WHERE HierarchyInString = @Id; "+
"DELETE FROM @Table where MyHierarchy = dbo.StringToHierarchyId(@Id); "+
"END END"
);
第二个触发器将使用名为 Documents 的迁移来处理表,以反映文件表中的文件删除(同步数据库):
migrationBuilder.Sql(
"CREATE TRIGGER dbo.CascadeDeleteDocuments ON Documents AFTER DELETE NOT FOR REPLICATION AS BEGIN SET NOCOUNT ON DECLARE @Id hierarchyid; DECLARE @Table Table (MyHierarchyInString varchar(max)); INSERT INTO @Table SELECT deleted.HierarchyInString from deleted; WHILE ((SELECT COUNT(*) FROM @Table) > 0) BEGIN select @Id = dbo.StringToHierarchyId((SELECT TOP 1 * from @Table)); DELETE FROM DocumentStore WHERE path_locator = @Id; DELETE FROM @Table where MyHierarchyInString = dbo.HierarchyIdToString(@Id); END END");
要使用这些触发器,我需要将 HIERARCHYID 与 VARCHAR(MAX) 转换,反之亦然,为此我使用 SQL 标量函数来回转换。
现在,为了插入文件,我将文件存储到从GETPATHLOCATOR 存储过程检索到的位置处的 Windows 文件系统中,并且文件自动存储到我的文件表中。同时,我还将一条记录添加到从 C# 模型类创建的另一个表中,即 Documents 维护两个表。
将来,我将尝试创建支持文件流的数据库,使用应用程序中的一些代码在 SQL Server 实例级别启用文件流支持,以避免在代码过程之外发生这种情况。