wdevs/relspecgo
3
0
Fork 0
Code Issues Pull Requests Actions Packages Releases 15 Wiki Activity

feat(writer): enhance type conversion for PostgreSQL compatibility and add tests
Some checks failed
CI / Test (1.24) (push) Successful in -26m32s
Details
CI / Test (1.25) (push) Successful in -26m27s
Details
CI / Build (push) Successful in -26m48s
Details
CI / Lint (push) Successful in -26m33s
Details
Integration Tests / Integration Tests (push) Failing after -26m51s
Details
Release / Build and Release (push) Successful in -26m41s
Details

Browse Source
This commit is contained in:
Warky
2026-01-29 21:36:23 +02:00
parent 283b568adb
commit 92dff99725
4 changed files with 94 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/writers/pgsql/writer.go
View File

@@ -13,6 +13,7 @@ import (
"github.com/jackc/pgx/v5"
"git.warky.dev/wdevs/relspecgo/pkg/models"
"git.warky.dev/wdevs/relspecgo/pkg/pgsql"
"git.warky.dev/wdevs/relspecgo/pkg/writers"
)
@@ -332,15 +333,16 @@ func (w *Writer) generateCreateTableStatement(schema *models.Schema, table *mode
func (w *Writer) generateColumnDefinition(col *models.Column) string {
parts := []string{col.SQLName()}
// Type with length/precision
typeStr := col.Type
// Type with length/precision - convert to valid PostgreSQL type
baseType := pgsql.ConvertSQLType(col.Type)
typeStr := baseType
if col.Length > 0 && col.Precision == 0 {
typeStr = fmt.Sprintf("%s(%d)", col.Type, col.Length)
typeStr = fmt.Sprintf("%s(%d)", baseType, col.Length)
} else if col.Precision > 0 {
if col.Scale > 0 {
typeStr = fmt.Sprintf("%s(%d,%d)", col.Type, col.Precision, col.Scale)
typeStr = fmt.Sprintf("%s(%d,%d)", baseType, col.Precision, col.Scale)
} else {
typeStr = fmt.Sprintf("%s(%d)", col.Type, col.Precision)
typeStr = fmt.Sprintf("%s(%d)", baseType, col.Precision)
}
}
parts = append(parts, typeStr)
@@ -488,7 +490,7 @@ func (w *Writer) writeCreateTables(schema *models.Schema) error {
columnDefs := make([]string, 0, len(columns))
for _, col := range columns {
colDef := fmt.Sprintf(" %s %s", col.SQLName(), col.Type)
colDef := fmt.Sprintf(" %s %s", col.SQLName(), pgsql.ConvertSQLType(col.Type))
// Add default value if present
if col.Default != nil && col.Default != "" {