Skip to content
This repository was archived by the owner on Aug 30, 2025. It is now read-only.

Commit ce3bd6e

Browse files
author
alishakawaguchi
authored
NEOS-1790: Postgres init schema handle column updates (#3448)
1 parent 4172248 commit ce3bd6e

19 files changed

Lines changed: 1299 additions & 642 deletions

File tree

backend/gen/go/db/dbschemas/postgresql/querier.go

Lines changed: 1 addition & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

backend/gen/go/db/dbschemas/postgresql/system.sql.go

Lines changed: 58 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

backend/pkg/dbschemas/sql/postgresql/queries/system.sql

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -603,6 +603,27 @@ ORDER BY
603603
rst.table_name,
604604
cws.column_name;
605605

606+
-- name: GetSequencesOwnedByTables :many
607+
SELECT
608+
s.relname AS sequence_name,
609+
seq_ns.nspname AS sequence_schema,
610+
tbl_ns.nspname AS table_schema,
611+
t.relname AS table_name,
612+
a.attname AS column_name
613+
FROM
614+
pg_catalog.pg_class s
615+
JOIN pg_catalog.pg_namespace seq_ns ON s.relnamespace = seq_ns.oid
616+
JOIN pg_catalog.pg_depend d ON d.objid = s.oid
617+
JOIN pg_catalog.pg_class t ON d.refobjid = t.oid
618+
JOIN pg_catalog.pg_namespace tbl_ns ON t.relnamespace = tbl_ns.oid
619+
JOIN pg_catalog.pg_attribute a ON a.attrelid = t.oid
620+
AND a.attnum = d.refobjsubid
621+
WHERE
622+
s.relkind = 'S' -- 'S' means sequence
623+
AND d.deptype = 'a' -- 'a' means "auto" dependency (owned by)
624+
AND(tbl_ns.nspname || '.' || t.relname) = ANY (sqlc.arg ('schematables')::TEXT []);
625+
626+
606627
-- name: GetNonForeignKeyTableConstraintsBySchema :many
607628
SELECT
608629
pn.nspname AS schema_name,

backend/pkg/sqlmanager/mysql/mysql-manager.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -242,6 +242,7 @@ func (m *MysqlManager) GetColumnsByTables(
242242
Schema: row.TableSchema,
243243
Table: row.TableName,
244244
Name: row.ColumnName,
245+
OrdinalPosition: row.OrdinalPosition,
245246
DataType: row.DataType,
246247
IsNullable: row.IsNullable,
247248
ColumnDefault: row.ColumnDefault,
@@ -251,7 +252,8 @@ func (m *MysqlManager) GetColumnsByTables(
251252
GeneratedExpression: row.GeneratedExpression,
252253
Comment: row.Comment,
253254
}
254-
col.Fingerprint = sqlmanager_shared.BuildTableColumnFingerprint(col)
255+
shouldIncludeOrdinalPosition := false
256+
col.Fingerprint = sqlmanager_shared.BuildTableColumnFingerprint(col, shouldIncludeOrdinalPosition)
255257
columns = append(columns, col)
256258
}
257259
return columns, nil

0 commit comments

Comments
 (0)