rename file

Author: hariso

destination.go

@@ -39,7 +39,7 @@ type Destination struct {
 	getTableName destination.TableFn
 
 	conn        *pgx.Conn
-	dbInfo      *internal.DbInfo
+	dbInfo      *internal.NumericScaleInfo
 	stmtBuilder sq.StatementBuilderType
 }
 
@@ -347,7 +347,7 @@ func (d *Destination) formatBigRat(ctx context.Context, table string, column str
 
 	// we need to get the scale of the column so we that we can properly
 	// round the result of dividing the input big.Rat's numerator and denominator.
-	scale, err := d.dbInfo.GetNumericColumnScale(ctx, table, column)
+	scale, err := d.dbInfo.Get(ctx, table, column)
 	if err != nil {
 		return "", fmt.Errorf("failed getting scale of numeric column: %w", err)
 	}

internal/db_info.go internal/numeric_scale_info.gointernal/db_info.go renamed to internal/numeric_scale_info.go

@@ -22,52 +22,52 @@ import (
 	"github.com/jackc/pgx/v5"
 )
 
-// DbInfo provides information about tables in a database.
-type DbInfo struct {
+// NumericScaleInfo provides information about the scale of numeric columns
+// in a database.
+type NumericScaleInfo struct {
 	conn  *pgx.Conn
 	cache map[string]*tableCache
 }
 
 // tableCache stores information about a table.
-// The information is cached and refreshed every 'cacheExpiration'.
 type tableCache struct {
 	columns map[string]int
 }
 
-func NewDbInfo(conn *pgx.Conn) *DbInfo {
-	return &DbInfo{
+func NewDbInfo(conn *pgx.Conn) *NumericScaleInfo {
+	return &NumericScaleInfo{
 		conn:  conn,
 		cache: map[string]*tableCache{},
 	}
 }
 
-func (d *DbInfo) GetNumericColumnScale(ctx context.Context, table string, column string) (int, error) {
-	// Check if table exists in cache and is not expired
-	tableInfo, ok := d.cache[table]
+func (i *NumericScaleInfo) Get(ctx context.Context, table string, column string) (int, error) {
+	// Check if table exists in cache
+	tableInfo, ok := i.cache[table]
 	if ok {
 		scale, ok := tableInfo.columns[column]
 		if ok {
 			return scale, nil
 		}
 	} else {
 		// Table info has expired, refresh the cache
-		d.cache[table] = &tableCache{
+		i.cache[table] = &tableCache{
 			columns: map[string]int{},
 		}
 	}
 
 	// Fetch scale from database
-	scale, err := d.numericScaleFromDb(ctx, table, column)
+	scale, err := i.fetchFromDB(ctx, table, column)
 	if err != nil {
 		return 0, err
 	}
 
-	d.cache[table].columns[column] = scale
+	i.cache[table].columns[column] = scale
 
 	return scale, nil
 }
 
-func (d *DbInfo) numericScaleFromDb(ctx context.Context, table string, column string) (int, error) {
+func (i *NumericScaleInfo) fetchFromDB(ctx context.Context, table string, column string) (int, error) {
 	// Query to get the column type and numeric scale
 	query := `
 		SELECT 
@@ -83,7 +83,7 @@ func (d *DbInfo) numericScaleFromDb(ctx context.Context, table string, column st
 	var dataType string
 	var numericScale *int
 
-	err := d.conn.QueryRow(ctx, query, table, column).Scan(&dataType, &numericScale)
+	err := i.conn.QueryRow(ctx, query, table, column).Scan(&dataType, &numericScale)
 	if err != nil {
 		if errors.Is(err, pgx.ErrNoRows) {
 			return 0, fmt.Errorf("column %s not found in table %s", column, table)