Cómo transmitir datos desde/hacia los campos BLOB de SQL Server?

Question

Para el trasfondo de esta cuestión, ver “How to I serialize a large graph of .NET object into a SQL Server BLOB without creating a large buffer?” que ahora tiene una gran recompensa por ello.

Deseo ser capaz de utilizar un objeto Stream para leer/escribir datos desde/hacia un campo BLOB en una fila de SQL Server sin tener que poner los todos los datos en una memoria intermedia temporal.

---

Si lo anterior se puede hacer ...

medida que la clase Corrientes tiene mucha CanXXX() métodos, no todas las corrientes pueden ser utilizadas por todos los métodos de tomar aceptar entradas de corriente/salidas.

Entonces, ¿qué capacidad tiene una secuencia para trabajar con ADO.NET al enviar datos a/desde SQL Server?

---

Estoy buscando tener una transmisión estándar a la que pueda pasarla a otras API.

También las dos respuestas hasta ahora solo cubren la obtención de datos de SqlServer, no enviando los datos a SqlServer.

Answer 1

ver How to I serialize a large graph of .NET object into a SQL Server BLOB without creating a large buffer?

Answer 2

No pondría todos los datos en un búfer; por lo general, se ejecuta un bucle, se almacena en el búfer un múltiplo de 8040 bytes (relacionado con el tamaño de página), se agrega el BLOB cada vez WRITETEXT/UPDATETEXT para image, o UPDATE.WRITE para varbinary(max). Here's an older example (usa image, lo siento).

Del mismo modo, al leer los datos se espera que se bombeen datos en un pequeño búfer a algún otro destino (una respuesta http, una red, un archivo, etc.). Algo like this (aunque no me gusta mucho cómo maneja su EOF/fragmentación, yo vería + ve bytes leídos).

Answer 3

He aquí un ejemplo para la lectura de datos en fragmentos:

using (var conn = new SqlConnection(connectionString)) 
    using (var cmd = conn.CreateCommand()) 
    { 
     conn.Open(); 
     cmd.CommandText = "select somebinary from mytable where id = 1"; 
     using (var reader = cmd.ExecuteReader()) 
     { 
      while (reader.Read()) 
      { 
       byte[] buffer = new byte[1024]; // Read chunks of 1KB 
       long bytesRead = 0; 
       long dataIndex = 0; 
       while ((bytesRead = reader.GetBytes(0, dataIndex, buffer, 0, buffer.Length)) > 0) 
       { 
        byte[] actual = new byte[bytesRead]; 
        Array.Copy(buffer, 0, actual, 0, bytesRead); 
        // TODO: Do something here with the actual variable, 
        // for example write it to a stream 
        dataIndex += bytesRead; 
       } 
      } 

     } 
    }