3
0

Reorganized RDBMS columne type code

This commit is contained in:
Denis Arh
2022-08-09 14:40:00 +02:00
parent a127d7711c
commit 39916ee149
6 changed files with 37 additions and 28 deletions

View File

@@ -122,18 +122,3 @@ func (s *schema) DropColumn(ctx context.Context, db sqlx.ExtContext, t *ddl.Tabl
return ddl.Exec(ctx, db, aux...)
}
func columnTypeTranslator(ct ddl.ColumnType) string {
switch ct.Type {
case ddl.ColumnTypeIdentifier:
return "BIGINT UNSIGNED"
case ddl.ColumnTypeBinary:
return "BLOB"
case ddl.ColumnTypeTimestamp:
return "DATETIME"
case ddl.ColumnTypeBoolean:
return "TINYINT(1)"
default:
return ddl.ColumnTypeTranslator(ct)
}
}

View File

@@ -4,6 +4,7 @@ import (
"database/sql"
"database/sql/driver"
"fmt"
"github.com/cortezaproject/corteza-server/store/adapters/rdbms/ddl"
"time"
"github.com/cortezaproject/corteza-server/pkg/dal"
@@ -40,3 +41,18 @@ func (t *TypeTime) Decode(raw any) (any, bool, error) {
func (t *TypeTime) Encode(val any) (driver.Value, error) {
return val, nil
}
func columnTypeTranslator(ct ddl.ColumnType) string {
switch ct.Type {
case ddl.ColumnTypeIdentifier:
return "BIGINT UNSIGNED"
case ddl.ColumnTypeBinary:
return "BLOB"
case ddl.ColumnTypeTimestamp:
return "DATETIME"
case ddl.ColumnTypeBoolean:
return "TINYINT(1)"
default:
return ddl.ColumnTypeTranslator(ct)
}
}

View File

@@ -74,7 +74,7 @@ func (postgresDialect) AttributeCast(attr *dal.Attribute, val exp.LiteralExpress
}
func (postgresDialect) NativeColumnType(ct ddl.ColumnType) string {
return ddl.ColumnTypeTranslator(ct)
return columnTypeTranslator(ct)
}
func (postgresDialect) ExprHandler(n *ql.ASTNode, args ...exp.Expression) (exp.Expression, error) {

View File

@@ -4,6 +4,7 @@ import (
"database/sql"
"database/sql/driver"
"fmt"
"github.com/cortezaproject/corteza-server/store/adapters/rdbms/ddl"
"time"
"github.com/cortezaproject/corteza-server/pkg/dal"
@@ -40,3 +41,7 @@ func (t *TypeTime) Decode(raw any) (any, bool, error) {
func (t *TypeTime) Encode(val any) (driver.Value, error) {
return val, nil
}
func columnTypeTranslator(ct ddl.ColumnType) string {
return ddl.ColumnTypeTranslator(ct)
}

View File

@@ -99,15 +99,3 @@ func (s *schema) DropColumn(ctx context.Context, db sqlx.ExtContext, t *ddl.Tabl
return ddl.Exec(ctx, db, aux...)
}
func columnTypeTranslator(ct ddl.ColumnType) string {
switch ct.Type {
case ddl.ColumnTypeTimestamp:
return "TIMESTAMP"
case ddl.ColumnTypeBinary:
return "BLOB"
default:
return ddl.ColumnTypeTranslator(ct)
}
}

View File

@@ -0,0 +1,15 @@
package sqlite
import "github.com/cortezaproject/corteza-server/store/adapters/rdbms/ddl"
func columnTypeTranslator(ct ddl.ColumnType) string {
switch ct.Type {
case ddl.ColumnTypeTimestamp:
return "TIMESTAMP"
case ddl.ColumnTypeBinary:
return "BLOB"
default:
return ddl.ColumnTypeTranslator(ct)
}
}