Skip to content

Commit

Permalink
adds more detailed error wrappers to mysql table init stmts for easie…
Browse files Browse the repository at this point in the history
…r debugging
  • Loading branch information
nickzelei committed Jan 27, 2025
1 parent d372bdd commit b3702b4
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions backend/pkg/sqlmanager/mysql/mysql-manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -316,7 +316,7 @@ func (m *MysqlManager) GetTableInitStatements(ctx context.Context, tables []*sql
Tables: tables,
})
if err != nil {
return err
return fmt.Errorf("failed to build mysql database table schemas by schemas and tables: %w", err)
}
colDefMapMu.Lock()
defer colDefMapMu.Unlock()
Expand All @@ -337,7 +337,7 @@ func (m *MysqlManager) GetTableInitStatements(ctx context.Context, tables []*sql
Tables: tables,
})
if err != nil {
return err
return fmt.Errorf("failed to build mysql table constraints: %w", err)
}
constraintMapMu.Lock()
defer constraintMapMu.Unlock()
Expand All @@ -358,7 +358,7 @@ func (m *MysqlManager) GetTableInitStatements(ctx context.Context, tables []*sql
Tables: tables,
})
if err != nil {
return err
return fmt.Errorf("failed to build mysql indices by schemas and tables: %w", err)
}

indexMapMu.Lock()
Expand Down Expand Up @@ -407,7 +407,7 @@ func (m *MysqlManager) GetTableInitStatements(ctx context.Context, tables []*sql

columnDefaultStr, err := convertUInt8ToString(record.ColumnDefault)
if err != nil {
return nil, err
return nil, fmt.Errorf("failed to convert column default to string: %w", err)
}
var columnDefaultType *string
if identityType != nil && columnDefaultStr != "" && *identityType == "" {
Expand All @@ -419,12 +419,12 @@ func (m *MysqlManager) GetTableInitStatements(ctx context.Context, tables []*sql
}
columnDefaultStr, err = EscapeMysqlDefaultColumn(columnDefaultStr, columnDefaultType)
if err != nil {
return nil, err
return nil, fmt.Errorf("failed to escape column default: %w", err)
}

genExp, err := convertUInt8ToString(record.GenerationExp)
if err != nil {
return nil, err
return nil, fmt.Errorf("failed to convert generation expression to string: %w", err)
}
columns = append(columns, buildTableCol(&buildTableColRequest{
ColumnName: record.ColumnName,
Expand All @@ -444,7 +444,7 @@ func (m *MysqlManager) GetTableInitStatements(ctx context.Context, tables []*sql
for _, constraint := range constraintmap[key] {
stmt, err := buildAlterStatementByConstraint(constraint)
if err != nil {
return nil, err
return nil, fmt.Errorf("failed to build alter table statement by constraint: %w", err)
}
info.AlterTableStatements = append(info.AlterTableStatements, stmt)
}
Expand Down

0 comments on commit b3702b4

Please sign in to comment.