diff --git a/packages/server/src/integrations/snowflake.ts b/packages/server/src/integrations/snowflake.ts index e82b796a59..950c1009ec 100644 --- a/packages/server/src/integrations/snowflake.ts +++ b/packages/server/src/integrations/snowflake.ts @@ -112,9 +112,15 @@ module SnowflakeModule { const descResp = await this.internalQuery({ sql: `DESCRIBE TABLE ${tableName};`, }) + if (tableName === "CUSTOMER") { + console.log("DESC = ", descResp) + } for (let column of descResp) { - const columnName = column.name - if (column["primary key"] === "Y") { + const columnName = column.Field + if ( + column["primary key"] === "Y" && + primaryKeys.indexOf(column.Key) === -1 + ) { primaryKeys.push(columnName) } const constraints = {