npgsql/src/Npgsql/PregeneratedMessages.cs at main · npgsql/npgsql

History

52 lines (42 loc) · 2.04 KB

Raw

using System.IO;

using System.Text;

using Npgsql.Internal;

using Npgsql.Util;

namespace Npgsql;

static class PregeneratedMessages

{

static PregeneratedMessages()

{

// This is the only use of a write buffer without a connector, for in-memory construction of

// pregenerated messages.

using var buf = new NpgsqlWriteBuffer(null, new MemoryStream(), null, NpgsqlWriteBuffer.MinimumSize, Encoding.ASCII);

BeginTransRepeatableRead = Generate(buf, "BEGIN ISOLATION LEVEL REPEATABLE READ");

BeginTransSerializable = Generate(buf, "BEGIN TRANSACTION ISOLATION LEVEL SERIALIZABLE");

BeginTransReadCommitted = Generate(buf, "BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED");

BeginTransReadUncommitted = Generate(buf, "BEGIN TRANSACTION ISOLATION LEVEL READ UNCOMMITTED");

CommitTransaction = Generate(buf, "COMMIT");

RollbackTransaction = Generate(buf, "ROLLBACK");

DiscardAll = Generate(buf, "DISCARD ALL");

}

internal static byte[] Generate(NpgsqlWriteBuffer buf, string query)

{

NpgsqlWriteBuffer.AssertASCIIOnly(query);

var queryByteLen = buf.TextEncoding.GetByteCount(query);

buf.WriteByte(FrontendMessageCode.Query);

buf.WriteInt32(4 + // Message length (including self excluding code)

queryByteLen + // Query byte length

1); // Null terminator

buf.WriteString(query, queryByteLen, false).Wait();

buf.WriteByte(0);

var bytes = buf.GetContents();

buf.Clear();

return bytes;

}

internal static readonly byte[] BeginTransRepeatableRead;

internal static readonly byte[] BeginTransSerializable;

internal static readonly byte[] BeginTransReadCommitted;

internal static readonly byte[] BeginTransReadUncommitted;

internal static readonly byte[] CommitTransaction;

internal static readonly byte[] RollbackTransaction;

internal static readonly byte[] DiscardAll;

}

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Expand file tree

Search code, repositories, users, issues, pull requests...

Uh oh!

FilesExpand file tree

PregeneratedMessages.cs

Latest commit

History

PregeneratedMessages.cs

File metadata and controls

Expand file tree