refactor internal/xsql/dsn and upload with off gocognit linter

Author: grishagavrin

CHANGELOG.md

@@ -1,3 +1,4 @@
+* 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`
 * Fixed topic writer infinite reconnections in some cases

internal/xsql/dsn.go

@@ -53,29 +53,10 @@ func Parse(dataSourceName string) (opts []config.Option, connectorOpts []Connect
 		}
 	}
 	if info.Params.Has("go_query_bind") {
-		var binders []ConnectorOption
 		queryTransformers := strings.Split(info.Params.Get("go_query_bind"), ",")
-		for _, transformer := range queryTransformers {
-			switch transformer {
-			case "declare":
-				binders = append(binders, WithQueryBind(bind.AutoDeclare{}))
-			case "positional":
-				binders = append(binders, WithQueryBind(bind.PositionalArgs{}))
-			case "numeric":
-				binders = append(binders, WithQueryBind(bind.NumericArgs{}))
-			default:
-				if strings.HasPrefix(transformer, tablePathPrefixTransformer) {
-					prefix, err := extractTablePathPrefixFromBinderName(transformer)
-					if err != nil {
-						return nil, nil, xerrors.WithStackTrace(err)
-					}
-					binders = append(binders, WithTablePathPrefix(prefix))
-				} else {
-					return nil, nil, xerrors.WithStackTrace(
-						fmt.Errorf("unknown query rewriter: %s", transformer),
-					)
-				}
-			}
+		binders, err := bindTablePathPrefixInConnectorOptions(queryTransformers)
+		if err != nil {
+			return nil, nil, err
 		}
 		connectorOpts = append(connectorOpts, binders...)
 	}
@@ -96,3 +77,30 @@ func extractTablePathPrefixFromBinderName(binderName string) (string, error) {
 
 	return ss[0][1], nil
 }
+
+// bindTablePathPrefixInConnectorOptions binds table path prefix query transformers to a list of ConnectorOptions.
+func bindTablePathPrefixInConnectorOptions(queryTransformers []string) ([]ConnectorOption, error) {
+	var binders []ConnectorOption
+	for _, transformer := range queryTransformers {
+		switch transformer {
+		case "declare":
+			binders = append(binders, WithQueryBind(bind.AutoDeclare{}))
+		case "positional":
+			binders = append(binders, WithQueryBind(bind.PositionalArgs{}))
+		case "numeric":
+			binders = append(binders, WithQueryBind(bind.NumericArgs{}))
+		default:
+			if strings.HasPrefix(transformer, tablePathPrefixTransformer) {
+				prefix, err := extractTablePathPrefixFromBinderName(transformer)
+				if err != nil {
+					return nil, xerrors.WithStackTrace(err)
+				}
+				binders = append(binders, WithTablePathPrefix(prefix))
+			} else {
+				return nil, xerrors.WithStackTrace(fmt.Errorf("unknown query rewriter: %s", transformer))
+			}
+		}
+	}
+
+	return binders, nil
+}