2

我问这个问题作为这个问题的后续。

这里发布了一个使用 bcp 和 xp_cmdshell 的解决方案，这不是我想要的解决方案。

我是 c# 的新手（因为我是 Delphi 开发人员）无论如何我都能够按照教程创建一个简单的 CLR 存储过程。

我的任务是将文件从客户端文件系统移动到服务器文件系统（可以使用远程 IP 访问服务器，所以我不能使用共享文件夹作为目标，这就是我需要 CLR 存储过程的原因）。

所以我打算：

  1. 从 Delphi 将文件存储在临时表的 varbinary(max) 列中
  2. 调用 CLR 存储过程，使用 varbinary(max) 字段中包含的数据在所需路径创建文件

想象一下，我需要将 C:\MyFile.pdf 移动到 Z:\MyFile.pdf，其中 C: 是本地系统上的硬盘，Z: 是服务器上的硬盘。C 在纽约，Z 在伦敦，它们之间没有 VPN，只有 https 连接。

我提供下面的代码（不工作）有人可以修改以使其工作？在这里，我假设有一个名为 MyTable 的表，其中包含两个字段：ID (int) 和 DATA (varbinary(max))。请注意，如果该表是一个真正的临时表或只是一个我临时存储数据的表，这并没有什么区别。如果有一些异常处理代码，我将不胜感激（这样我就可以管理“无法保存文件”异常）。

我希望能够编写一个新文件或覆盖该文件（如果已经存在）。

[Microsoft.SqlServer.Server.SqlProcedure]
public static void VarbinaryToFile(int TableId)
{
   using (SqlConnection connection = new SqlConnection("context connection=true"))
   {
      connection.Open();
      SqlCommand command = new SqlCommand("select data from mytable where ID = @TableId", connection);
      command.Parameters.AddWithValue("@TableId", TableId);
      // This was the sample code I found to run a query
      //SqlContext.Pipe.ExecuteAndSend(command);
      // instead I need something like this (THIS IS META_SYNTAX!!!):
      SqlContext.Pipe.ResultAsStream.SaveToFile('z:\MyFile.pdf');
   }
}

（一个子问题是：这种方法是否正确或者有一种方法可以直接将数据传递给 CLR 存储过程，所以我不需要使用临时表？）

如果子问题的答案是否定的，您能描述一下避免使用临时表的方法吗？那么有没有比我上面描述的更好的方法（=临时表+存储过程）？一种将数据流从客户端应用程序直接传递到 CLR 存储过程的方法？（我的文件可以是任意大小，但也可以很大）

4

4 回答 4

2

[有] 一种方法可以直接将数据传递给 CLR 存储过程，这样我就不需要使用临时表了吗？

是的，将二进制文件传递给 SQLCLR 存储过程并让它将内容写入磁盘是可能且相当简单的，并且不需要首先将这些内容放入表中——临时的或真实的。

[Microsoft.SqlServer.Server.SqlProcedure]
public static void SaveFileToLocalDisk([SqlFacet(MaxSize = -1)] SqlBytes FileContents,
    SqlString DestinationPath)
{
    if (FileContents.IsNull || DestinationPath.IsNull)
    {
        throw new ArgumentException("Seriously?");
    }

    File.WriteAllBytes(DestinationPath.Value, FileContents.Buffer);

    return;
}

或者，由于您说文件有时很大，因此以下内容在内存使用方面应该更容易，因为它利用了流功能：

[Microsoft.SqlServer.Server.SqlProcedure]
public static void SaveFileToLocalDiskStreamed(
    [SqlFacet(MaxSize = -1)] SqlBytes FileContents, SqlString DestinationPath)
{
    if (FileContents.IsNull || DestinationPath.IsNull)
    {
        throw new ArgumentException("Seriously?");
    }

    int _ChunkSize = 1024;
    byte[] _Buffer = new byte[_ChunkSize];

    using (FileStream _File = new FileStream(DestinationPath.Value, FileMode.Create))
    {
        long _Position = 0;
        long _BytesRead = 0;

        while (true)
        {
            _BytesRead = FileContents.Read(_Position, _Buffer, 0, _ChunkSize);

            _File.Write(_Buffer, 0, (int)_BytesRead);
            _Position += _ChunkSize;

            if (_BytesRead < _ChunkSize || (_Position >= FileContents.Length))
            {
                break;
            }

        }

        _File.Close();

    }

    return;
}

包含此代码的程序集当然需要一个PERMISSION_SETof EXTERNAL_ACCESS.

在这两种情况下，您都将按以下方式执行它们：

EXEC dbo.SaveFileToLocalDiskStreamed 0x2A20202A, N'C:\TEMP\SaveToDiskTest.txt';

“0x2A20202A”应该给你一个包含以下 4 个字符（星号、空格、空格、星号）的文件：

* *

于 2015-08-24T03:43:03.237 回答
0

见http://www.mssqltips.com/tip.asp?tip=1662

于 2010-05-04T14:54:42.977 回答
0

经过一番研究，我得出结论认为这没有意义，最好放弃对 2005 的支持并使用 2008 的 fielstream 功能。我可以有条件逻辑在 2005 年和 2008 年之间进行选择，并且仅在 2005 年使用文件流。

于 2010-06-03T13:39:07.403 回答
0

为什么要将这些文件放入数据库？如果您有 http/https 连接，您可以将文件上传到服务器，写入受保护的目录并创建一个页面来列出这些文件并提供下载链接。如果您想存储一些额外的信息，您可以将其写入数据库。您只需要在服务器端更改文件名（使用唯一名称）。

于 2010-06-03T12:29:40.343 回答