fix wrong table name in constraints if schema prefix is used

Author: KarnerTh

changelog.md

@@ -4,6 +4,10 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres
 to [Semantic Versioning](https://semver.org/spec/v2.0.0.html) (after version 0.0.5).
 
+## [0.6.1] - 2023-03-09
+### Fixed
+- Fixed wrong table name in constraints if schema prefix was used
+
 ## [0.6.0] - 2023-03-08
 ### Added
 - Support schema prefix ([Issue #30](https://github.com/KarnerTh/mermerd/issues/30))
@@ -107,6 +111,8 @@ to [Semantic Versioning](https://semver.org/spec/v2.0.0.html) (after version 0.0
 ### Added
 - Initial release of mermerd
 
+[0.6.1]: https://github.com/KarnerTh/mermerd/releases/tag/v0.6.1
+
 [0.6.0]: https://github.com/KarnerTh/mermerd/releases/tag/v0.6.0
 
 [0.5.0]: https://github.com/KarnerTh/mermerd/releases/tag/v0.5.0

database/database_integration_test.go

@@ -286,7 +286,7 @@ func TestDatabaseIntegrations(t *testing.T) {
 					assert.ElementsMatch(t, expectedResult, tables)
 				})
 
-				t.Run("GetCrossSchemaConstraints", func(t *testing.T) {
+				t.Run("Get Cross-Schema-Constraints", func(t *testing.T) {
 					// Arrange
 					tableName := TableDetail{Schema: "other_db", Name: "test_3_b"}
 
@@ -302,6 +302,22 @@ func TestDatabaseIntegrations(t *testing.T) {
 					assert.Equal(t, constraintResults[0].FkTable, "test_3_b")
 					assert.Equal(t, constraintResults[0].PkTable, "test_3_a")
 				})
+
+				t.Run("Get schema from FK and PK table", func(t *testing.T) {
+					// Arrange
+					tableName := TableDetail{Schema: "other_db", Name: "test_3_b"}
+
+					// Act
+					constraintResults, err := connector.GetConstraints(tableName)
+
+					// Assert
+					assert.Nil(t, err)
+					assert.Len(t, constraintResults, 1)
+					assert.Equal(t, constraintResults[0].FkTable, "test_3_b")
+					assert.Equal(t, constraintResults[0].FkSchema, "other_db")
+					assert.Equal(t, constraintResults[0].PkTable, "test_3_a")
+					assert.Equal(t, constraintResults[0].PkSchema, testCase.schema)
+				})
 			})
 		})
 	}

database/mssql.go

@@ -129,7 +129,9 @@ func (c *mssqlConnector) GetColumns(tableName TableDetail) ([]ColumnResult, erro
 func (c *mssqlConnector) GetConstraints(tableName TableDetail) ([]ConstraintResult, error) {
 	rows, err := c.db.Query(`
 select fk.table_name,
+       fk.table_schema,
        pk.table_name,
+       pk.table_schema,
        c.constraint_name,
        kcu.column_name,
        coalesce(
@@ -164,7 +166,9 @@ where c.CONSTRAINT_SCHEMA = @p1 and (fk.table_name = @p2 or pk.table_name = @p2)
 		var constraint ConstraintResult
 		err = rows.Scan(
 			&constraint.FkTable,
+			&constraint.FkSchema,
 			&constraint.PkTable,
+			&constraint.PkSchema,
 			&constraint.ConstraintName,
 			&constraint.ColumnName,
 			&constraint.IsPrimary,

database/mysql.go

@@ -127,7 +127,9 @@ func (c *mySqlConnector) GetColumns(tableName TableDetail) ([]ColumnResult, erro
 func (c *mySqlConnector) GetConstraints(tableName TableDetail) ([]ConstraintResult, error) {
 	rows, err := c.db.Query(`
 		select c.TABLE_NAME,
+         kcu.TABLE_SCHEMA,
 			   c.REFERENCED_TABLE_NAME,
+         kcu.REFERENCED_TABLE_SCHEMA,
 			   c.CONSTRAINT_NAME,
        		   kcu.COLUMN_NAME,
 			   (
@@ -157,7 +159,9 @@ func (c *mySqlConnector) GetConstraints(tableName TableDetail) ([]ConstraintResu
 		var constraint ConstraintResult
 		err = rows.Scan(
 			&constraint.FkTable,
+			&constraint.FkSchema,
 			&constraint.PkTable,
+			&constraint.PkSchema,
 			&constraint.ConstraintName,
 			&constraint.ColumnName,
 			&constraint.IsPrimary,

database/postgres.go

@@ -136,7 +136,9 @@ func (c *postgresConnector) GetColumns(tableName TableDetail) ([]ColumnResult, e
 func (c *postgresConnector) GetConstraints(tableName TableDetail) ([]ConstraintResult, error) {
 	rows, err := c.db.Query(`
 	select fk.table_name,
+       fk.table_schema,
 		   pk.table_name,
+       pk.table_schema,
 		   c.constraint_name,
 		   kcu.column_name,
 		   coalesce(
@@ -172,7 +174,9 @@ func (c *postgresConnector) GetConstraints(tableName TableDetail) ([]ConstraintR
 		var constraint ConstraintResult
 		err = rows.Scan(
 			&constraint.FkTable,
+			&constraint.FkSchema,
 			&constraint.PkTable,
+			&constraint.PkSchema,
 			&constraint.ConstraintName,
 			&constraint.ColumnName,
 			&constraint.IsPrimary,

database/result.go

@@ -26,7 +26,9 @@ type ColumnResult struct {
 type ConstraintResultList []ConstraintResult
 type ConstraintResult struct {
 	FkTable        string
+	FkSchema       string
 	PkTable        string
+	PkSchema       string
 	ConstraintName string
 	ColumnName     string
 	IsPrimary      bool

diagram/diagram_util.go

@@ -72,8 +72,8 @@ func getConstraintData(config config.MermerdConfig, constraint database.Constrai
 	}
 
 	return ErdConstraintData{
-		PkTableName:     constraint.PkTable,
-		FkTableName:     constraint.FkTable,
+		PkTableName:     getTableName(config, database.TableDetail{Schema: constraint.PkSchema, Name: constraint.PkTable}),
+		FkTableName:     getTableName(config, database.TableDetail{Schema: constraint.FkSchema, Name: constraint.FkTable}),
 		Relation:        getRelation(constraint),
 		ConstraintLabel: constraintLabel,
 	}

diagram/diagram_util_test.go

@@ -252,6 +252,7 @@ func TestGetConstraintData(t *testing.T) {
 		// Arrange
 		configMock := mocks.MermerdConfig{}
 		configMock.On("OmitConstraintLabels").Return(true).Once()
+		configMock.On("ShowSchemaPrefix").Return(false).Twice()
 		constraint := database.ConstraintResult{ColumnName: "Column1"}
 
 		// Act