Stream.CopyToAsync는 WriteAynsc 메서드를 호출하지 않습니다.

Question

정보를 읽기/쓰기 위해 데이터베이스에 접근해야하는 사용자 지정 Stream 클래스를 작성했습니다. XxAsync 데이터베이스 메서드를 사용하려고 했으므로 동기식 읽기/쓰기 메서드에서 connection.OpenAsync()을 사용할 수 없기 때문에 동기식 및 비동기식 메서드를 모두 스트림에 작성하는 것이 좋습니다. 그러나

, 두 버전을 모두 구현 후, 나는 다음)합니다 (간단한 콘솔 응용 프로그램의 무효 홈페이지에 다음과 같은 호출 대상으로 방법이 스트림을 사용하는 경우 :

Task.Run(async() => 
{ 
    using (var ctx = new JobContext()) 
    { 
     // create AssemblyCache record and get assemblyKey... 

     using (var fs = new System.IO.FileStream(@"C:\BTR\Source\Assemblies\BTR.Rbl.Evolution.Documents.dll", 
            System.IO.FileMode.Open, 
            System.IO.FileAccess.Read, 
            System.IO.FileShare.None, 
            8192, 
            true)) 
     using (var bs = ctx.GetBinaryWriteStream<AssemblyCache>(assemblyKey)) 
     { 
      await fs.CopyToAsync(bs); 
     } 
    } 
}).Wait(); 

결코 전화를 보인다 내 XxAsync 메서드. 동기 버전 만 추적합니다. Stream 기본 클래스의 소스를 보면 CopyToAsync가 내 WriteAsync 메서드를 호출해야하므로 내가 무엇을 놓치고 있는지 알 수 없습니다.

UPDATE는

그것은 내 GetBinaryWriteStream 확장 (의도적으로) 압축을 지원하기 위해 내 사용자 지정 스트림 주위에 GZipStream를 래핑 밝혀졌습니다. GZipStream은 WriteAsync을 호출하지 않은 원인입니다. 이 질문과 관련하여 새로운 질문을했습니다. here

Answer 1

SqlClient's streaming support을 사용하여 클라이언트의 데이터를 서버의 BLOV (즉, varbinary (MAX)) 열로 스트리밍 할 수 있습니다. INSERT를 수행하는 데 사용하는 것과 거의 동일한 코드를 사용하지만 SQL 명령에 값을 전달하는 대신 스트림 또는 스트림 판독기를 전달합니다. 당신이 많은 파일을 보내려면 예를 들어, 대신

var sql="INSERT INTO [MyTable] (blobField) VALUES (@data)" 
using (SqlConnection conn = new SqlConnection(connectionString)) 
using (SqlCommand cmd = new SqlCommand(sql, conn)) 
{ 
    cmd.Parameters.Add("@data", SqlDbType.Binary, myBuffer.Length).Value = myBuffer; 
    await conn.OpenAsync(); 
    await cmd.ExecuteNonQueryAsync(); 
} 

을 사용하는 당신은 루프에서 매개 변수에 스트림을 할당 할 수

var sql="INSERT INTO [MyTable] (blobField) VALUES (@data)" 
using (SqlConnection conn = new SqlConnection(connectionString)) 
using (SqlCommand cmd = new SqlCommand(sql, conn)) 
{ 
    await conn.OpenAsync(); 
    using (FileStream file = File.Open("binarydata.bin", FileMode.Open)) 
    { 
     cmd.Parameters.Add("@data", SqlDbType.Binary, -1).Value = file; 
     await cmd.ExecuteNonQueryAsync(); 
    } 
} 

을 써서 :

var blobParam=cmd.Parameters.Add("@data", SqlDbType.Binary, -1); 
    foreach(var somePath in aListOfPaths) 
    { 
     using (FileStream file = File.Open(somePath, FileMode.Open)) 
     { 
      blobparam.Value = file; 
      await cmd.ExecuteNonQueryAsync(); 
     } 
    }