Spelling and grammar fixes

conn.go

@@ -37,7 +37,7 @@ type ConnConfig struct {
 
 	// DefaultQueryExecMode controls the default mode for executing queries. By default pgx uses the extended protocol
 	// and automatically prepares and caches prepared statements. However, this may be incompatible with proxies such as
-	// PGBouncer. In this case it may be preferrable to use QueryExecModeExec or QueryExecModeSimpleProtocol. The same
+	// PGBouncer. In this case it may be preferable to use QueryExecModeExec or QueryExecModeSimpleProtocol. The same
 	// functionality can be controlled on a per query basis by passing a QueryExecMode as the first query argument.
 	DefaultQueryExecMode QueryExecMode
 
@@ -275,7 +275,7 @@ func connect(ctx context.Context, config *ConnConfig) (c *Conn, err error) {
 	return c, nil
 }
 
-// Close closes a connection. It is safe to call Close on a already closed
+// Close closes a connection. It is safe to call Close on an already closed
 // connection.
 func (c *Conn) Close(ctx context.Context) error {
 	if c.IsClosed() {
@@ -620,13 +620,13 @@ const (
 	// Assume the PostgreSQL query parameter types based on the Go type of the arguments. This uses the extended protocol
 	// with text formatted parameters and results. Queries are executed in a single round trip. Type mappings can be
 	// registered with pgtype.Map.RegisterDefaultPgType. Queries will be rejected that have arguments that are
-	// unregistered or ambigious. e.g. A map[string]string may have the PostgreSQL type json or hstore. Modes that know
+	// unregistered or ambiguous. e.g. A map[string]string may have the PostgreSQL type json or hstore. Modes that know
 	// the PostgreSQL type can use a map[string]string directly as an argument. This mode cannot.
 	QueryExecModeExec
 
 	// Use the simple protocol. Assume the PostgreSQL query parameter types based on the Go type of the arguments.
 	// Queries are executed in a single round trip. Type mappings can be registered with
-	// pgtype.Map.RegisterDefaultPgType. Queries will be rejected that have arguments that are unregistered or ambigious.
+	// pgtype.Map.RegisterDefaultPgType. Queries will be rejected that have arguments that are unregistered or ambiguous.
 	// e.g. A map[string]string may have the PostgreSQL type json or hstore. Modes that know the PostgreSQL type can use
 	// a map[string]string directly as an argument. This mode cannot.
 	//

pgconn/auth_scram.go

@@ -47,7 +47,7 @@ func (c *PgConn) scramAuth(serverAuthMechanisms []string) error {
 		return err
 	}
 
-	// Receive server-first-message payload in a AuthenticationSASLContinue.
+	// Receive server-first-message payload in an AuthenticationSASLContinue.
 	saslContinue, err := c.rxSASLContinue()
 	if err != nil {
 		return err
@@ -67,7 +67,7 @@ func (c *PgConn) scramAuth(serverAuthMechanisms []string) error {
 		return err
 	}
 
-	// Receive server-final-message payload in a AuthenticationSASLFinal.
+	// Receive server-final-message payload in an AuthenticationSASLFinal.
 	saslFinal, err := c.rxSASLFinal()
 	if err != nil {
 		return err

pgconn/config.go

@@ -809,7 +809,7 @@ func makeConnectTimeoutDialFunc(timeout time.Duration) DialFunc {
 	return d.DialContext
 }
 
-// ValidateConnectTargetSessionAttrsReadWrite is an ValidateConnectFunc that implements libpq compatible
+// ValidateConnectTargetSessionAttrsReadWrite is a ValidateConnectFunc that implements libpq compatible
 // target_session_attrs=read-write.
 func ValidateConnectTargetSessionAttrsReadWrite(ctx context.Context, pgConn *PgConn) error {
 	result := pgConn.ExecParams(ctx, "show transaction_read_only", nil, nil, nil, nil).Read()
@@ -824,7 +824,7 @@ func ValidateConnectTargetSessionAttrsReadWrite(ctx context.Context, pgConn *PgC
 	return nil
 }
 
-// ValidateConnectTargetSessionAttrsReadOnly is an ValidateConnectFunc that implements libpq compatible
+// ValidateConnectTargetSessionAttrsReadOnly is a ValidateConnectFunc that implements libpq compatible
 // target_session_attrs=read-only.
 func ValidateConnectTargetSessionAttrsReadOnly(ctx context.Context, pgConn *PgConn) error {
 	result := pgConn.ExecParams(ctx, "show transaction_read_only", nil, nil, nil, nil).Read()
@@ -839,7 +839,7 @@ func ValidateConnectTargetSessionAttrsReadOnly(ctx context.Context, pgConn *PgCo
 	return nil
 }
 
-// ValidateConnectTargetSessionAttrsStandby is an ValidateConnectFunc that implements libpq compatible
+// ValidateConnectTargetSessionAttrsStandby is a ValidateConnectFunc that implements libpq compatible
 // target_session_attrs=standby.
 func ValidateConnectTargetSessionAttrsStandby(ctx context.Context, pgConn *PgConn) error {
 	result := pgConn.ExecParams(ctx, "select pg_is_in_recovery()", nil, nil, nil, nil).Read()
@@ -854,7 +854,7 @@ func ValidateConnectTargetSessionAttrsStandby(ctx context.Context, pgConn *PgCon
 	return nil
 }
 
-// ValidateConnectTargetSessionAttrsPrimary is an ValidateConnectFunc that implements libpq compatible
+// ValidateConnectTargetSessionAttrsPrimary is a ValidateConnectFunc that implements libpq compatible
 // target_session_attrs=primary.
 func ValidateConnectTargetSessionAttrsPrimary(ctx context.Context, pgConn *PgConn) error {
 	result := pgConn.ExecParams(ctx, "select pg_is_in_recovery()", nil, nil, nil, nil).Read()
@@ -869,7 +869,7 @@ func ValidateConnectTargetSessionAttrsPrimary(ctx context.Context, pgConn *PgCon
 	return nil
 }
 
-// ValidateConnectTargetSessionAttrsPreferStandby is an ValidateConnectFunc that implements libpq compatible
+// ValidateConnectTargetSessionAttrsPreferStandby is a ValidateConnectFunc that implements libpq compatible
 // target_session_attrs=prefer-standby.
 func ValidateConnectTargetSessionAttrsPreferStandby(ctx context.Context, pgConn *PgConn) error {
 	result := pgConn.ExecParams(ctx, "select pg_is_in_recovery()", nil, nil, nil, nil).Read()

pgconn/pgconn.go

@@ -593,7 +593,7 @@ func (pgConn *PgConn) Frontend() *pgproto3.Frontend {
 	return pgConn.frontend
 }
 
-// Close closes a connection. It is safe to call Close on a already closed connection. Close attempts a clean close by
+// Close closes a connection. It is safe to call Close on an already closed connection. Close attempts a clean close by
 // sending the exit message to PostgreSQL. However, this could block so ctx is available to limit the time to wait. The
 // underlying net.Conn.Close() will always be called regardless of any other errors.
 func (pgConn *PgConn) Close(ctx context.Context) error {
@@ -1764,7 +1764,7 @@ func (pgConn *PgConn) SyncConn(ctx context.Context) error {
 		}
 	}
 
-	// This should never happen. Only way I can imagine this occuring is if the server is constantly sending data such as
+	// This should never happen. Only way I can imagine this occurring is if the server is constantly sending data such as
 	// LISTEN/NOTIFY or log notifications such that we never can get an empty buffer.
 	return errors.New("SyncConn: conn never synchronized")
 }

pgconn/pgconn_test.go

@@ -438,7 +438,7 @@ func TestConnectCustomLookupWithPort(t *testing.T) {
 	require.NoError(t, err)
 
 	origPort := config.Port
-	// Chnage the config an invalid port so it will fail if used
+	// Change the config an invalid port so it will fail if used
 	config.Port = 0
 
 	looked := false

pgproto3/README.md

@@ -1,6 +1,6 @@
 # pgproto3
 
-Package pgproto3 is a encoder and decoder of the PostgreSQL wire protocol version 3.
+Package pgproto3 is an encoder and decoder of the PostgreSQL wire protocol version 3.
 
 pgproto3 can be used as a foundation for PostgreSQL drivers, proxies, mock servers, load balancers and more.
 

pgproto3/doc.go

@@ -1,7 +1,7 @@
-// Package pgproto3 is a encoder and decoder of the PostgreSQL wire protocol version 3.
+// Package pgproto3 is an encoder and decoder of the PostgreSQL wire protocol version 3.
 //
 // The primary interfaces are Frontend and Backend. They correspond to a client and server respectively. Messages are
-// sent with Send (or a specialized Send variant). Messages are automatically bufferred to minimize small writes. Call
+// sent with Send (or a specialized Send variant). Messages are automatically buffered to minimize small writes. Call
 // Flush to ensure a message has actually been sent.
 //
 // The Trace method of Frontend and Backend can be used to examine the wire-level message traffic. It outputs in a

pgproto3/frontend.go

@@ -156,7 +156,7 @@ func (f *Frontend) SendDescribe(msg *Describe) {
 	}
 }
 
-// SendExecute sends a Execute message to the backend (i.e. the server). The message is not guaranteed to be written until
+// SendExecute sends an Execute message to the backend (i.e. the server). The message is not guaranteed to be written until
 // Flush is called.
 func (f *Frontend) SendExecute(msg *Execute) {
 	prevLen := len(f.wbuf)

pgproto3/startup_message.go

@@ -38,14 +38,14 @@ func (dst *StartupMessage) Decode(src []byte) error {
 	for {
 		idx := bytes.IndexByte(src[rp:], 0)
 		if idx < 0 {
-			return &invalidMessageFormatErr{messageType: "StartupMesage"}
+			return &invalidMessageFormatErr{messageType: "StartupMessage"}
 		}
 		key := string(src[rp : rp+idx])
 		rp += idx + 1
 
 		idx = bytes.IndexByte(src[rp:], 0)
 		if idx < 0 {
-			return &invalidMessageFormatErr{messageType: "StartupMesage"}
+			return &invalidMessageFormatErr{messageType: "StartupMessage"}
 		}
 		value := string(src[rp : rp+idx])
 		rp += idx + 1

pgtype/doc.go

@@ -67,7 +67,7 @@ See example_custom_type_test.go for an example of a custom type for the PostgreS
 
 Sometimes pgx supports a PostgreSQL type such as numeric but the Go type is in an external package that does not have
 pgx support such as github.com/shopspring/decimal. These types can be registered with pgtype with custom conversion
-logic. See https://github.com/jackc/pgx-shopspring-decimal and https://github.com/jackc/pgx-gofrs-uuid for a example
+logic. See https://github.com/jackc/pgx-shopspring-decimal and https://github.com/jackc/pgx-gofrs-uuid for example
 integrations.
 
 New PostgreSQL Type Support
@@ -149,7 +149,7 @@ Overview of Scanning Implementation
 The first step is to use the OID to lookup the correct Codec. If the OID is unavailable, Map will try to find the OID
 from previous calls of Map.RegisterDefaultPgType. The Map will call the Codec's PlanScan method to get a plan for
 scanning into the Go value. A Codec will support scanning into one or more Go types. Oftentime these Go types are
-interfaces rather than explicit types. For example, PointCodec can use any Go type that implments the PointScanner and
+interfaces rather than explicit types. For example, PointCodec can use any Go type that implements the PointScanner and
 PointValuer interfaces.
 
 If a Go value is not supported directly by a Codec then Map will try wrapping it with additional logic and try again.

pgtype/inet.go

@@ -156,7 +156,7 @@ func (scanPlanBinaryInetToNetipPrefixScanner) Scan(src []byte, dst any) error {
 	}
 
 	if len(src) != 8 && len(src) != 20 {
-		return fmt.Errorf("Received an invalid size for a inet: %d", len(src))
+		return fmt.Errorf("Received an invalid size for an inet: %d", len(src))
 	}
 
 	// ignore family

pgtype/interval.go

@@ -179,7 +179,7 @@ func (scanPlanBinaryIntervalToIntervalScanner) Scan(src []byte, dst any) error {
 	}
 
 	if len(src) != 16 {
-		return fmt.Errorf("Received an invalid size for a interval: %d", len(src))
+		return fmt.Errorf("Received an invalid size for an interval: %d", len(src))
 	}
 
 	microseconds := int64(binary.BigEndian.Uint64(src))

pgtype/pgtype_test.go

@@ -43,7 +43,7 @@ type _float32Slice []float32
 type _float64Slice []float64
 type _byteSlice []byte
 
-// unregisteredOID represents a actual type that is not registered. Cannot use 0 because that represents that the type
+// unregisteredOID represents an actual type that is not registered. Cannot use 0 because that represents that the type
 // is not known (e.g. when using the simple protocol).
 const unregisteredOID = uint32(1)
 

rows.go

@@ -688,7 +688,7 @@ func (rs *namedStructRowScanner) appendScanTargets(dstElemValue reflect.Value, s
 			// Field is unexported, skip it.
 			continue
 		}
-		// Handle anoymous struct embedding, but do not try to handle embedded pointers.
+		// Handle anonymous struct embedding, but do not try to handle embedded pointers.
 		if sf.Anonymous && sf.Type.Kind() == reflect.Struct {
 			scanTargets, err = rs.appendScanTargets(dstElemValue.Field(i), scanTargets, fldDescs)
 			if err != nil {

stdlib/sql_test.go

@@ -108,7 +108,7 @@ func testWithAllQueryExecModes(t *testing.T, f func(t *testing.T, db *sql.DB)) {
 }
 
 // Do a simple query to ensure the DB is still usable. This is of less use in stdlib as the connection pool should
-// cover an broken connections.
+// cover broken connections.
 func ensureDBValid(t testing.TB, db *sql.DB) {
 	var sum, rowCount int32