SQL：在 VarBinary 列上顺序执行 UPDATE .WRITE

Question

我正在尝试创建一个小测试应用程序，它读取 FileStream 块并将其附加到 SQL Server 2005 Express 上的 VarBinary(max) 列。

一切正常 - 该列按预期填充，但我的机器似乎仍然将所有内容缓冲到内存中，我只是不明白为什么。

我正在使用以下代码 (C#)：

using (IDbConnection connection = new SqlConnection(ConfigurationManager.ConnectionStrings[1].ConnectionString))
{
    connection.Open();

    string id = Guid.NewGuid().ToString();

    using (IDbCommand command = connection.CreateCommand())
    {
        command.CommandText = "INSERT INTO [BLOB] ([Id],[Data]) VALUES (@p1,0x0)";

        SqlParameter param = new SqlParameter("@p1", SqlDbType.VarChar);
        param.Value = id;
        command.Parameters.Add(param);

        command.ExecuteNonQuery();
    }

    if (File.Exists(textBox1.Text))
    {
        using (IDbCommand command = connection.CreateCommand())
        {
            command.CommandText = "UPDATE [BLOB] SET [Data].WRITE(@data, @offset, @len) WHERE [Id]=@id";

            SqlParameter dataParam = new SqlParameter("@data", SqlDbType.VarBinary);
            command.Parameters.Add(dataParam);

            SqlParameter offsetParam = new SqlParameter("@offset", SqlDbType.BigInt);
            command.Parameters.Add(offsetParam);

            SqlParameter lengthParam = new SqlParameter("@len", SqlDbType.BigInt);
            command.Parameters.Add(lengthParam);

            SqlParameter idParam = new SqlParameter("@id", SqlDbType.VarChar);
            command.Parameters.Add(idParam);
            idParam.Value = id;

            using (FileStream fs = new FileStream(textBox1.Text, FileMode.Open, FileAccess.Read, FileShare.Read))
            {
                byte[] buffer = new byte[2090400]; //chunk sizes that are multiples of 8040 bytes.
                int read = 0;
                int offset = 0;

                while ((read = fs.Read(buffer, 0, buffer.Length)) > 0)
                {
                    dataParam.Value = buffer;
                    offsetParam.Value = offset;
                    lengthParam.Value = read;

                    command.ExecuteNonQuery();

                    offset += read;
                }
            }
        }
    }
}

谁能告诉我为什么它将文件缓冲到内存中？我使用的 byte[] 缓冲区大小只有近 2 MB。

我可以为每个块创建一个新的缓冲区，但这似乎也浪费了 CPU/内存......

Answer 1

FileStream 类缓冲输入和输出。您可以在每次更新后调用 Flush() 方法来清除内部缓冲区。

需要明确的是，它只会缓冲最大缓冲区大小 (4 KB)。

在这种情况下，我认为你的罪魁祸首是SqlExpress。当我执行您的代码并写入 SqlExpress 的本地副本时，sqlsrvr 进程的内存使用量跃升了约 1 GB。当我写入非本地数据库时，我的内存使用量保持不变。

Answer 2

它会缓冲它，因为当您将其保存到 varbinary 列中时，它会成为 sql server 中 LOB 数据缓存的一部分。这就是它的工作原理。

或者你的意思是它在其他地方缓冲？