Come eseguire il flusso di dati da/a campi BLOB di SQL Server?

Question

Per lo sfondo a questa domanda, vedere “How to I serialize a large graph of .NET object into a SQL Server BLOB without creating a large buffer?” che ha ora un gran taglia su di esso.

desidero poter utilizzare un oggetto Stream per leggere/scrivere dati a/da un campo BLOB fila SQL Server senza dover mettere le tutti i dati in un buffer temporaneo.

---

Se quanto sopra può essere fatto ...

Come la classe Streams ha molte CanXXX() metodi, non tutti i corsi d'acqua possono essere utilizzati da tutti i metodi di prendere accettare ingressi di flusso/uscite.

Quindi, in che misura un flusso deve funzionare con ADO.NET quando si inviano dati a/da SQL Server?

---

Sto cercando di avere un flusso standard al quale posso passarlo su altre API.

Anche i due risposte finora riguarda solo ottenere sotto forma di dati SqlServer, non invio i dati da SqlServer.

Answer 1

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

Answer 2

Non mettere tutti i dati in un buffer; in genere esegui un ciclo, bufferizzando più di 8040 byte (in relazione alle dimensioni della pagina), aggiungendo il BLOB ogni volta WRITETEXT/UPDATETEXT per image o UPDATE.WRITE per varbinary(max). Here's an older example (utilizza image, scusa).

Allo stesso modo, quando si leggono i dati, si spera che si pompino i dati in un piccolo buffer verso un'altra destinazione (una risposta HTTP, una rete, un file, ecc.). Qualcosa like this (anche se non mi piace come gestisce il suo EOF/chunking, controllerei + ve byte letti).

Answer 3

Ecco un esempio per la lettura dei dati in blocchi:

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; 
       } 
      } 

     } 
    }