refactor retry/sql_test and upload with off gocognit linter and undo last commit with log/table

Author: grishagavrin

CHANGELOG.md

@@ -1,18 +1,19 @@
-* Refactored `internal/topic/topicwriterinternal/queue_test.go` and extract funcs
-* Refactored `log/driver.go` and extract funcs
-* Refactored `internal/table/scanner/scanner.go` and extract funcs
-* Refactored `log/topic.go` and extract funcs
-* Refactored `internal/table/scanner/scanner_test.go` and extract funcs
-* Refactored `log/sql.go` and extract funcs
-* Refactored `metrics/driver.go` and extract funcs
-* Refactored `metrics/sql.go` and extract funcs
-* Refactored `internal/table/retry_test.go` and extract func `retry_test.checkResultsRetryWithCustomErrors`
-* Refactored `internal/table/client.go` and extract func `client.onCloseSession`
-* Refactored `internal/decimal/decimal.go` and extract func `decimal.dotStringAnalysis`
-* Refactored `internal/backoff/backoff_test.go` and extract func `backoff_test.checkExpWithAct` for compare
-* Refactored `internal/xsql/dsn.go` and extract func `dsn.bindTablePathPrefixInConnectorOptions`
-* Refactored `sugar/path.go` and extract funcs `path.removeWithPrefix`,  `path.removeEntry`
-* Refactored `internal/stack/record.go` and extract func `record.findFileNameAndPkgPath`
+* Refactored `retry/sql_test.go` and extract func `sql_test.canRetry` for gocognit linter
+* Refactored `internal/topic/topicwriterinternal/queue_test.go` and extract funcs for gocognit linter
+* Refactored `log/driver.go` and extract funcs for gocognit linter
+* Refactored `internal/table/scanner/scanner.go` and extract funcs for gocognit linter
+* Refactored `log/topic.go` and extract funcs for gocognit linter
+* Refactored `internal/table/scanner/scanner_test.go` and extract funcs for gocognit linter
+* Refactored `log/sql.go` and extract funcs for gocognit linter
+* Refactored `metrics/driver.go` and extract funcs for gocognit linter
+* Refactored `metrics/sql.go` and extract funcs for gocognit linter
+* Refactored `internal/table/retry_test.go` and extract func `retry_test.checkResultsRetryWithCustomErrors` for gocognit linter
+* Refactored `internal/table/client.go` and extract func `client.onCloseSession` for gocognit linter
+* Refactored `internal/decimal/decimal.go` and extract func `decimal.dotStringAnalysis` for gocognit linter
+* Refactored `internal/backoff/backoff_test.go` and extract func `backoff_test.checkExpWithAct` for gocognit linter
+* Refactored `internal/xsql/dsn.go` and extract func `dsn.bindTablePathPrefixInConnectorOptions` for gocognit linter
+* Refactored `sugar/path.go` and extract funcs `path.removeWithPrefix`,  `path.removeEntry` for gocognit linter
+* Refactored `internal/stack/record.go` and extract func `record.findFileNameAndPkgPath` for gocognit linter
 * Fixed topic writer infinite reconnections in some cases
 * Refactored nil on err `internal/grpcwrapper/rawydb/issues.go`, when golangci-lint nilerr enabled
 * Refactored nil on err `internal/grpcwrapper/rawtopic/describe_topic.go`, when golangci-lint nilerr enabled

retry/sql_test.go

@@ -180,7 +180,6 @@ func (m *mockStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (
 	return m.conn.QueryContext(ctx, m.query, args)
 }
 
-//nolint:nestif
 func TestDoTx(t *testing.T) {
 	for _, idempotentType := range []idempotency{
 		idempotent,
@@ -228,27 +227,44 @@ func TestDoTx(t *testing.T) {
 							},
 						}),
 					)
-					if tt.canRetry[idempotentType] {
-						if err != nil {
-							t.Errorf("unexpected err after attempts=%d and driver conns=%d: %v)", attempts, m.conns, err)
-						}
-						if attempts <= 1 {
-							t.Errorf("must be attempts > 1 (actual=%d), driver conns=%d)", attempts, m.conns)
-						}
-						if tt.deleteSession {
-							if m.conns <= 1 {
-								t.Errorf("must be retry on different conns (attempts=%d, driver conns=%d)", attempts, m.conns)
-							}
-						} else {
-							if m.conns > 1 {
-								t.Errorf("must be retry on single conn (attempts=%d, driver conns=%d)", attempts, m.conns)
-							}
-						}
-					} else if err == nil {
-						t.Errorf("unexpected nil err (attempts=%d, driver conns=%d)", attempts, m.conns)
-					}
+					canRetry(t, tt, idempotentType, err, attempts, m)
 				})
 			}
 		})
 	}
 }
+
+// canRetry checks if a retry can be performed based on the given parameters.
+//
+//nolint:nestif
+func canRetry(t *testing.T, tt struct {
+	err           error
+	backoff       backoff.Type
+	deleteSession bool
+	canRetry      map[idempotency]bool
+},
+	idempotentType idempotency,
+	err error,
+	attempts int,
+	m *mockConnector,
+) {
+	if tt.canRetry[idempotentType] {
+		if err != nil {
+			t.Errorf("unexpected err after attempts=%d and driver conns=%d: %v)", attempts, m.conns, err)
+		}
+		if attempts <= 1 {
+			t.Errorf("must be attempts > 1 (actual=%d), driver conns=%d)", attempts, m.conns)
+		}
+		if tt.deleteSession {
+			if m.conns <= 1 {
+				t.Errorf("must be retry on different conns (attempts=%d, driver conns=%d)", attempts, m.conns)
+			}
+		} else {
+			if m.conns > 1 {
+				t.Errorf("must be retry on single conn (attempts=%d, driver conns=%d)", attempts, m.conns)
+			}
+		}
+	} else if err == nil {
+		t.Errorf("unexpected nil err (attempts=%d, driver conns=%d)", attempts, m.conns)
+	}
+}