Skip to content

Commit 4fdf903

Browse files
committed
fix: pass SequenceReader by ref in MySql and fix compiler errors
1 parent 78a3d84 commit 4fdf903

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

src/CosmoSQLClient.MySql/MySqlConnection.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,8 @@ public async Task<IReadOnlyList<SqlRow>> QueryAsync(string sql, IReadOnlyList<Sq
190190
// Binary Protocol (COM_STMT_PREPARE + COM_STMT_EXECUTE)
191191
await SendPacketAsync(MyStmtPrepareMessage.Build(sql), 0, ct).ConfigureAwait(false);
192192
var prepResp = await ReceivePacketAsync(ct).ConfigureAwait(false);
193-
if (prepResp.First.Span[0] == 0xFF) throw SqlException.Query(MyDecoder.DecodeError(prepResp).Message);
193+
var reader = new SequenceReader<byte>(prepResp);
194+
if (prepResp.First.Span[0] == 0xFF) throw SqlException.Query(MyDecoder.DecodeError(ref reader).Message);
194195

195196
// Decode stmt-id (4 bytes starting at offset 1)
196197
uint stmtId = prepResp.ToArray()[1] | ((uint)prepResp.ToArray()[2] << 8) | ((uint)prepResp.ToArray()[3] << 16) | ((uint)prepResp.ToArray()[4] << 24);
@@ -212,7 +213,8 @@ public async Task<IReadOnlyList<SqlRow>> QueryAsync(string sql, IReadOnlyList<Sq
212213

213214
await SendPacketAsync(MyStmtExecuteMessage.Build(stmtId, parameters), 0, ct).ConfigureAwait(false);
214215
var execResp = await ReceivePacketAsync(ct).ConfigureAwait(false);
215-
if (execResp.First.Span[0] == 0xFF) throw SqlException.Query(MyDecoder.DecodeError(execResp).Message);
216+
var execReader = new SequenceReader<byte>(execResp);
217+
if (execResp.First.Span[0] == 0xFF) throw SqlException.Query(MyDecoder.DecodeError(ref execReader).Message);
216218

217219
// Row decoding for Binary Protocol is different (binary rows),
218220
// but for now let's assume text protocol for simplicity or implement binary rows.

0 commit comments

Comments
 (0)