Skip to content

Commit cc34da5

Browse files
jackcjackc
authored
Merge pull request #2370 from Saurabh2402/improvement/setup-linters
Improvement/setup formatters
2 parents dd81f81 + 88500ac commit cc34da5

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

69 files changed

+160
-170
lines changed

‎.golangci.yml‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
# See for configurations: https://golangci-lint.run/usage/configuration/
2+
version: 2
3+
4+
# See: https://golangci-lint.run/usage/formatters/
5+
formatters:
6+
default: none
7+
enable:
8+
- gofmt # https://pkg.go.dev/cmd/gofmt
9+
- gofumpt # https://github.com/mvdan/gofumpt
10+
11+
settings:
12+
gofmt:
13+
simplify: true # Simplify code: gofmt with `-s` option.
14+
15+
gofumpt:
16+
# Module path which contains the source code being formatted.
17+
# Default: ""
18+
module-path: github.com/jackc/pgx/v5 # Should match with module in go.mod
19+
# Choose whether to use the extra rules.
20+
# Default: false
21+
extra-rules: true

‎batch.go‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -207,7 +207,6 @@ func (br *batchResults) Query() (Rows, error) {
207207
func (br *batchResults) QueryRow() Row {
208208
rows, _ := br.Query()
209209
return (*connRow)(rows.(*baseRows))
210-
211210
}
212211

213212
// Close closes the batch operation. Any error that occurred during a batch operation may have made it impossible to
@@ -380,7 +379,6 @@ func (br *pipelineBatchResults) Query() (Rows, error) {
380379
func (br *pipelineBatchResults) QueryRow() Row {
381380
rows, _ := br.Query()
382381
return (*connRow)(rows.(*baseRows))
383-
384382
}
385383

386384
// Close closes the batch operation. Any error that occurred during a batch operation may have made it impossible to

‎batch_test.go‎

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -488,7 +488,6 @@ func TestConnSendBatchCloseRowsPartiallyRead(t *testing.T) {
488488
defer cancel()
489489

490490
pgxtest.RunWithQueryExecModes(ctx, t, defaultConnTestRunner, nil, func(ctx context.Context, t testing.TB, conn *pgx.Conn) {
491-
492491
batch := &pgx.Batch{}
493492
batch.Queue("select n from generate_series(0,5) n")
494493
batch.Queue("select n from generate_series(0,5) n")
@@ -539,7 +538,6 @@ func TestConnSendBatchCloseRowsPartiallyRead(t *testing.T) {
539538
if err != nil {
540539
t.Fatal(err)
541540
}
542-
543541
})
544542
}
545543

@@ -550,7 +548,6 @@ func TestConnSendBatchQueryError(t *testing.T) {
550548
defer cancel()
551549

552550
pgxtest.RunWithQueryExecModes(ctx, t, defaultConnTestRunner, nil, func(ctx context.Context, t testing.TB, conn *pgx.Conn) {
553-
554551
batch := &pgx.Batch{}
555552
batch.Queue("select n from generate_series(0,5) n where 100/(5-n) > 0")
556553
batch.Queue("select n from generate_series(0,5) n")
@@ -580,7 +577,6 @@ func TestConnSendBatchQueryError(t *testing.T) {
580577
if pgErr, ok := err.(*pgconn.PgError); !(ok && pgErr.Code == "22012") {
581578
t.Errorf("br.Close() => %v, want error code %v", err, 22012)
582579
}
583-
584580
})
585581
}
586582

@@ -591,7 +587,6 @@ func TestConnSendBatchQuerySyntaxError(t *testing.T) {
591587
defer cancel()
592588

593589
pgxtest.RunWithQueryExecModes(ctx, t, defaultConnTestRunner, nil, func(ctx context.Context, t testing.TB, conn *pgx.Conn) {
594-
595590
batch := &pgx.Batch{}
596591
batch.Queue("select 1 1")
597592

@@ -607,7 +602,6 @@ func TestConnSendBatchQuerySyntaxError(t *testing.T) {
607602
if err == nil {
608603
t.Error("Expected error")
609604
}
610-
611605
})
612606
}
613607

@@ -618,7 +612,6 @@ func TestConnSendBatchQueryRowInsert(t *testing.T) {
618612
defer cancel()
619613

620614
pgxtest.RunWithQueryExecModes(ctx, t, defaultConnTestRunner, nil, func(ctx context.Context, t testing.TB, conn *pgx.Conn) {
621-
622615
sql := `create temporary table ledger(
623616
id serial primary key,
624617
description varchar not null,
@@ -647,7 +640,6 @@ func TestConnSendBatchQueryRowInsert(t *testing.T) {
647640
}
648641

649642
br.Close()
650-
651643
})
652644
}
653645

@@ -658,7 +650,6 @@ func TestConnSendBatchQueryPartialReadInsert(t *testing.T) {
658650
defer cancel()
659651

660652
pgxtest.RunWithQueryExecModes(ctx, t, defaultConnTestRunner, nil, func(ctx context.Context, t testing.TB, conn *pgx.Conn) {
661-
662653
sql := `create temporary table ledger(
663654
id serial primary key,
664655
description varchar not null,
@@ -687,7 +678,6 @@ func TestConnSendBatchQueryPartialReadInsert(t *testing.T) {
687678
}
688679

689680
br.Close()
690-
691681
})
692682
}
693683

@@ -698,7 +688,6 @@ func TestTxSendBatch(t *testing.T) {
698688
defer cancel()
699689

700690
pgxtest.RunWithQueryExecModes(ctx, t, defaultConnTestRunner, nil, func(ctx context.Context, t testing.TB, conn *pgx.Conn) {
701-
702691
sql := `create temporary table ledger1(
703692
id serial primary key,
704693
description varchar not null
@@ -757,7 +746,6 @@ func TestTxSendBatch(t *testing.T) {
757746
if err != nil {
758747
t.Fatal(err)
759748
}
760-
761749
})
762750
}
763751

@@ -768,7 +756,6 @@ func TestTxSendBatchRollback(t *testing.T) {
768756
defer cancel()
769757

770758
pgxtest.RunWithQueryExecModes(ctx, t, defaultConnTestRunner, nil, func(ctx context.Context, t testing.TB, conn *pgx.Conn) {
771-
772759
sql := `create temporary table ledger1(
773760
id serial primary key,
774761
description varchar not null
@@ -795,7 +782,6 @@ func TestTxSendBatchRollback(t *testing.T) {
795782
if count != 0 {
796783
t.Errorf("count => %v, want %v", count, 0)
797784
}
798-
799785
})
800786
}
801787

@@ -855,7 +841,6 @@ func TestConnBeginBatchDeferredError(t *testing.T) {
855841
defer cancel()
856842

857843
pgxtest.RunWithQueryExecModes(ctx, t, defaultConnTestRunner, nil, func(ctx context.Context, t testing.TB, conn *pgx.Conn) {
858-
859844
pgxtest.SkipCockroachDB(t, conn, "Server does not support deferred constraint (https://github.com/cockroachdb/cockroach/issues/31632)")
860845

861846
mustExec(t, conn, `create temporary table t (
@@ -894,7 +879,6 @@ func TestConnBeginBatchDeferredError(t *testing.T) {
894879
if err, ok := err.(*pgconn.PgError); !ok || err.Code != "23505" {
895880
t.Fatalf("expected error 23505, got %v", err)
896881
}
897-
898882
})
899883
}
900884

‎bench_test.go‎

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -516,7 +516,6 @@ func multiInsert(conn *pgx.Conn, tableName string, columnNames []string, rowSrc
516516
}
517517

518518
return rowCount, nil
519-
520519
}
521520

522521
func benchmarkWriteNRowsViaMultiInsert(b *testing.B, n int) {
@@ -535,7 +534,8 @@ func benchmarkWriteNRowsViaMultiInsert(b *testing.B, n int) {
535534
src := newBenchmarkWriteTableCopyFromSrc(n)
536535

537536
_, err := multiInsert(conn, "t",
538-
[]string{"varchar_1",
537+
[]string{
538+
"varchar_1",
539539
"varchar_2",
540540
"varchar_null_1",
541541
"date_1",
@@ -547,7 +547,8 @@ func benchmarkWriteNRowsViaMultiInsert(b *testing.B, n int) {
547547
"tstz_2",
548548
"bool_1",
549549
"bool_2",
550-
"bool_3"},
550+
"bool_3",
551+
},
551552
src)
552553
if err != nil {
553554
b.Fatal(err)
@@ -568,7 +569,8 @@ func benchmarkWriteNRowsViaCopy(b *testing.B, n int) {
568569

569570
_, err := conn.CopyFrom(context.Background(),
570571
pgx.Identifier{"t"},
571-
[]string{"varchar_1",
572+
[]string{
573+
"varchar_1",
572574
"varchar_2",
573575
"varchar_null_1",
574576
"date_1",
@@ -580,7 +582,8 @@ func benchmarkWriteNRowsViaCopy(b *testing.B, n int) {
580582
"tstz_2",
581583
"bool_1",
582584
"bool_2",
583-
"bool_3"},
585+
"bool_3",
586+
},
584587
src)
585588
if err != nil {
586589
b.Fatal(err)
@@ -611,6 +614,7 @@ func BenchmarkWrite5RowsViaInsert(b *testing.B) {
611614
func BenchmarkWrite5RowsViaMultiInsert(b *testing.B) {
612615
benchmarkWriteNRowsViaMultiInsert(b, 5)
613616
}
617+
614618
func BenchmarkWrite5RowsViaBatchInsert(b *testing.B) {
615619
benchmarkWriteNRowsViaBatchInsert(b, 5)
616620
}
@@ -626,6 +630,7 @@ func BenchmarkWrite10RowsViaInsert(b *testing.B) {
626630
func BenchmarkWrite10RowsViaMultiInsert(b *testing.B) {
627631
benchmarkWriteNRowsViaMultiInsert(b, 10)
628632
}
633+
629634
func BenchmarkWrite10RowsViaBatchInsert(b *testing.B) {
630635
benchmarkWriteNRowsViaBatchInsert(b, 10)
631636
}
@@ -641,6 +646,7 @@ func BenchmarkWrite100RowsViaInsert(b *testing.B) {
641646
func BenchmarkWrite100RowsViaMultiInsert(b *testing.B) {
642647
benchmarkWriteNRowsViaMultiInsert(b, 100)
643648
}
649+
644650
func BenchmarkWrite100RowsViaBatchInsert(b *testing.B) {
645651
benchmarkWriteNRowsViaBatchInsert(b, 100)
646652
}
@@ -672,6 +678,7 @@ func BenchmarkWrite10000RowsViaInsert(b *testing.B) {
672678
func BenchmarkWrite10000RowsViaMultiInsert(b *testing.B) {
673679
benchmarkWriteNRowsViaMultiInsert(b, 10000)
674680
}
681+
675682
func BenchmarkWrite10000RowsViaBatchInsert(b *testing.B) {
676683
benchmarkWriteNRowsViaBatchInsert(b, 10000)
677684
}
@@ -1043,7 +1050,6 @@ func BenchmarkSelectRowsScanDecoder(b *testing.B) {
10431050
}
10441051
for _, format := range formats {
10451052
b.Run(format.name, func(b *testing.B) {
1046-
10471053
br := &BenchRowDecoder{}
10481054
for i := 0; i < b.N; i++ {
10491055
rows, err := conn.Query(

‎conn_test.go‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -412,7 +412,6 @@ func TestExecPerQuerySimpleProtocol(t *testing.T) {
412412
if commandTag.String() != "INSERT 0 1" {
413413
t.Fatalf("Unexpected results from Exec: %v", commandTag)
414414
}
415-
416415
}
417416

418417
func TestPrepare(t *testing.T) {
@@ -1089,7 +1088,7 @@ func TestLoadRangeType(t *testing.T) {
10891088
conn.TypeMap().RegisterType(newRangeType)
10901089
conn.TypeMap().RegisterDefaultPgType(pgtype.Range[float64]{}, "examplefloatrange")
10911090

1092-
var inputRangeType = pgtype.Range[float64]{
1091+
inputRangeType := pgtype.Range[float64]{
10931092
Lower: 1.0,
10941093
Upper: 2.0,
10951094
LowerType: pgtype.Inclusive,
@@ -1129,7 +1128,7 @@ func TestLoadMultiRangeType(t *testing.T) {
11291128
conn.TypeMap().RegisterType(newMultiRangeType)
11301129
conn.TypeMap().RegisterDefaultPgType(pgtype.Multirange[pgtype.Range[float64]]{}, "examplefloatmultirange")
11311130

1132-
var inputMultiRangeType = pgtype.Multirange[pgtype.Range[float64]]{
1131+
inputMultiRangeType := pgtype.Multirange[pgtype.Range[float64]]{
11331132
{
11341133
Lower: 1.0,
11351134
Upper: 2.0,

‎copy_from_test.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,6 @@ func TestConnCopyWithAllQueryExecModes(t *testing.T) {
7676
}
7777

7878
func TestConnCopyWithKnownOIDQueryExecModes(t *testing.T) {
79-
8079
for _, mode := range pgxtest.KnownOIDQueryExecModes {
8180
t.Run(mode.String(), func(t *testing.T) {
8281
ctx, cancel := context.WithTimeout(context.Background(), 120*time.Second)

‎internal/stmtcache/lru_cache.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,6 @@ func (c *LRUCache) Get(key string) *pgconn.StatementDescription {
3131
}
3232

3333
return nil
34-
3534
}
3635

3736
// Put stores sd in the cache. Put panics if sd.SQL is "". Put does nothing if sd.SQL already exists in the cache or

‎pgbouncer_test.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,5 +72,4 @@ func testPgbouncer(t *testing.T, config *pgx.ConnConfig, workers, iterations int
7272
for i := 0; i < workers; i++ {
7373
<-doneChan
7474
}
75-
7675
}

‎pgconn/auth_scram.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -263,7 +263,7 @@ func computeClientProof(saltedPassword, authMessage []byte) []byte {
263263
return buf
264264
}
265265

266-
func computeServerSignature(saltedPassword []byte, authMessage []byte) []byte {
266+
func computeServerSignature(saltedPassword, authMessage []byte) []byte {
267267
serverKey := computeHMAC(saltedPassword, []byte("Server Key"))
268268
serverSignature := computeHMAC(serverKey, authMessage)
269269
buf := make([]byte, base64.StdEncoding.EncodedLen(len(serverSignature)))

‎pgconn/benchmark_test.go‎

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,6 @@ func BenchmarkExec(b *testing.B) {
7878
}
7979
}
8080
_, err = rr.Close()
81-
8281
if err != nil {
8382
b.Fatal(err)
8483
}
@@ -127,7 +126,6 @@ func BenchmarkExecPossibleToCancel(b *testing.B) {
127126
}
128127
}
129128
_, err = rr.Close()
130-
131129
if err != nil {
132130
b.Fatal(err)
133131
}
@@ -184,7 +182,6 @@ func BenchmarkExecPrepared(b *testing.B) {
184182
}
185183
}
186184
_, err = rr.Close()
187-
188185
if err != nil {
189186
b.Fatal(err)
190187
}
@@ -227,7 +224,6 @@ func BenchmarkExecPreparedPossibleToCancel(b *testing.B) {
227224
}
228225
}
229226
_, err = rr.Close()
230-
231227
if err != nil {
232228
b.Fatal(err)
233229
}

0 commit comments

Comments
 (0)