SQL Server 2008中使用FileStream存取大文件的相關(guān)知識是本文我們主要要介紹的內(nèi)容，我們知道，SQL Server 2008中引入了Filestream，使用它可以將非機構(gòu)化大型數(shù)據(jù)（如文本文檔、圖像和視頻）等以varbinary(max)的形式存儲在文件系統(tǒng)中。使用數(shù)據(jù)庫的備份還原功能可以將這些數(shù)據(jù)一起備份還原。本文將簡單總結(jié)如何創(chuàng)建可以使用FileStream的數(shù)據(jù)庫以及如何使用c#訪問存取數(shù)據(jù)。

1. 創(chuàng)建數(shù)據(jù)庫

創(chuàng)建數(shù)據(jù)時可以執(zhí)行以下T-SQL語句，

CREATE DATABASE TestDB     
ON    
PRIMARY ( NAME = TestDB,    
FILENAME = 'c:\data\TestDB.mdf'),    
FILEGROUP FileStreamGroup1 CONTAINS FILESTREAM( NAME = Arch3,    
FILENAME = 'c:\data\filestream1')    
LOG ON  ( NAME = TestDBlog,    
FILENAME = 'c:\data\TestDBlog.ldf')    
GO   

如果是在已經(jīng)創(chuàng)建好的數(shù)據(jù)庫上啟用FileStream，可以

a. Right click the “TestDB” database and select “Properties”.  
b. First create a FileGroup, click “Filegroups” menu and create one under “Stream” section,   
named “FileStreamGroup1”. And then click “Files” menu, and add a file named “filestream1”   
and Set it’s FileGroup to “FileStreamGroup1”, and then specify a folder to hold data,   
like c:\Data.  Click ok, and you can check the folder “c:\data” to see what is added. 

2. 創(chuàng)建表

CREATE TABLE [dbo].[TestTable2](    
[ID] [uniqueidentifier] ROWGUIDCOL  NOT NULL,    
[ContentType] [nvarchar](50) NOT NULL,    
[FileName] [nvarchar](50) NOT NULL,    
[FileContent] [varbinary](max) FILESTREAM  NULL,    
[FileSize] [int] NULL,    
CONSTRAINT [PK_TestTable2] PRIMARY KEY CLUSTERED     
(    
[ID] ASC    
)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = OFF,  
ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON) ON [PRIMARY] FILESTREAM_ON [FileStreamGroup1]    
) ON [PRIMARY] FILESTREAM_ON [FileStreamGroup1]    
GO    
SET ANSI_PADDING OFF    
GO 

如果表已經(jīng)創(chuàng)建，可以執(zhí)行以下TSQL來設(shè)置：

ALTER TABLE [dbo].[TestTable] alter column ID [uniqueidentifier] not null  
ALTER TABLE [dbo].[TestTable] alter column ID add ROWGUIDCOL  
ALTER TABLE [dbo].[TestTable] add FileContent varbinary(MAX) FILESTREAM; 

3. 使用C#讀寫

讀：

SqlConnection conn = null;conn = new SqlConnection(connect);                    
conn.Open();    
tx = conn.BeginTransaction();var qry = "SELECT FileName, FileContent.PathName() as FilePath,  
ContentType, GET_FILESTREAM_TRANSACTION_CONTEXT() as TranContext  FROM TestTable2 WHERE ID = @ID";    
var cmd = new SqlCommand(qry, conn, tx);    
cmd.Parameters.AddWithValue("@ID", id);using (rdr = cmd.ExecuteReader())    
{     if (rdr.HasRows)    
{    
rdr.Read();    
fileModel = new FileModel();    
fileModel.FileName = Convert.ToString(rdr["FileName"]);    
fileModel.FilePath = Convert.ToString(rdr["FilePath"]);    
byte[] tranContext = (byte[])rdr["TranContext"];    
fileModel.ContentType = Convert.ToString(rdr["ContentType"]); ;    
fileModel.FileStream = new SqlFileStream(fileModel.FilePath, tranContext, FileAccess.Read)；    
}    
}  

得到文件的Stream，就可以對該文件進行讀寫操作了。

寫：

public static void PostFileToDB(HttpPostedFileBase file)    
{    
string fileName = Path.GetFileName(file.FileName);    
string contentType = file.ContentType;    
int filefileSize = file.ContentLength / 1024;    
using (SqlConnection conn = new SqlConnection(connect))    
{    
conn.Open();    
using (SqlTransaction trn = conn.BeginTransaction ())    
{    
SqlCommand cmdInsert = new SqlCommand(    
@"insert into TestTable2    
(FileName, FileContent, ContentType, FileSize)       
output    
INSERTED.FileContent.PathName(),    
GET_FILESTREAM_TRANSACTION_CONTEXT ()                                            
values    
(@FileName, 0x, @ContentType, @FileSize)", conn, trn);    
cmdInsert.Parameters.Add("@FileName", SqlDbType.VarChar, 256);    
cmdInsert.Parameters["@FileName"].Value = fileName;    
cmdInsert.Parameters.Add("@ContentType", SqlDbType.VarChar, 256);    
cmdInsert.Parameters["@ContentType"].Value = contentType;     
cmdInsert.Parameters.Add("@FileSize", SqlDbType.Int);    
cmdInsert.Parameters["@FileSize"].Value = fileSize;    
string path = null;    
byte[] context = null;                  
// cmdInsert is an INSERT command that uses the OUTPUT clause     
// Thus we use the ExecuteReader to get the     
// result set from the output columns     
// using (SqlDataReader rdr = cmdInsert.ExecuteReader())    
{    
rdr.Read();    
path = rdr.GetString(0);    
context = rdr.GetSqlBytes(1).Buffer;    
}                      
using (SqlFileStream sfs = new SqlFileStream(    
path, context, FileAccess.Write))    
{    
file.InputStream.CopyTo(sfs);    
}    
trn.Commit ();    
}    
}    
}  

關(guān)于SQL Server 2008中使用FileStream存取大文件實例就介紹到這里了，希望本次的介紹能夠?qū)δ兴斋@！

【編輯推薦】

1. 初學(xué)SQL Server數(shù)據(jù)庫的一些常用操作總結(jié)
2. SQL Server數(shù)據(jù)庫創(chuàng)建數(shù)據(jù)倉庫已分區(qū)表詳解
3. SQL Server與Access數(shù)據(jù)庫ASP代碼的比較詳解
4. SQL Server數(shù)據(jù)庫中bit字段類型使用時的注意事項
5. SQL Server數(shù)據(jù)庫timestamp數(shù)據(jù)類型相關(guān)知識介紹