@@ -109,7 +109,7 @@ protected function convertChild(\DOMNode $childNode, $data)
109
109
}
110
110
$ name = $ this ->getAttributeValue ($ subscription , 'name ' );
111
111
$ column = $ this ->getAttributeValue ($ subscription , 'entity_column ' );
112
- $ column = $ this ->checkColumnOrReturnPrimarykeyColumn ($ name , $ column );
112
+ $ column = $ this ->checkifcolumnexist ($ name , $ column );
113
113
$ subscriptionModel = $ this ->getAttributeValue ($ subscription , 'subscription_model ' );
114
114
115
115
if (!empty ($ subscriptionModel )
@@ -173,24 +173,13 @@ private function getAdditionalColumns(\DOMNode $subscription): array
173
173
* @param string $columnName
174
174
* @return string
175
175
*/
176
- private function checkColumnOrReturnPrimarykeyColumn ($ tableName , $ columnName )
176
+ public function checkifcolumnexist ($ tableName , $ columnName )
177
177
{
178
178
$ connection = $ this ->resourceConnection ->getConnection ();
179
179
$ tableName = $ this ->resourceConnection ->getTableName ($ tableName );
180
180
181
181
if (!$ connection ->isTableExists ($ tableName ) || $ connection ->tableColumnExists ($ tableName , $ columnName )) {
182
182
return $ columnName ;
183
183
}
184
-
185
- $ primarykeyColumn = null ;
186
- $ columns = $ connection ->describeTable ($ tableName );
187
- foreach ($ columns as $ column ) {
188
- if (!empty ($ column ['PRIMARY ' ])) {
189
- $ primarykeyColumn = $ column ['COLUMN_NAME ' ];
190
- break ;
191
- }
192
- }
193
-
194
- return $ primarykeyColumn ;
195
184
}
196
185
}
0 commit comments