@@ -58,7 +58,7 @@ public function execute($storeId): void
58
58
$ metadataIds = $ this ->getMetadataIdsByStoreId ($ storeId );
59
59
$ profileIds = $ this ->getProfileIdsByMetadataIds ($ metadataIds );
60
60
61
- $ this ->appResource ->getConnection ()->delete (
61
+ $ this ->appResource ->getConnection (' sales ' )->delete (
62
62
$ this ->appResource ->getTableName ('sales_sequence_profile ' ),
63
63
['profile_id IN (?) ' => $ profileIds ]
64
64
);
@@ -70,7 +70,7 @@ public function execute($storeId): void
70
70
continue ;
71
71
}
72
72
73
- $ this ->appResource ->getConnection ()->dropTable (
73
+ $ this ->appResource ->getConnection (' sales ' )->dropTable (
74
74
$ metadata ->getSequenceTable ()
75
75
);
76
76
$ this ->resourceMetadata ->delete ($ metadata );
@@ -85,7 +85,7 @@ public function execute($storeId): void
85
85
*/
86
86
private function getMetadataIdsByStoreId ($ storeId )
87
87
{
88
- $ connection = $ this ->appResource ->getConnection ();
88
+ $ connection = $ this ->appResource ->getConnection (' sales ' );
89
89
$ bind = ['store_id ' => $ storeId ];
90
90
$ select = $ connection ->select ()->from (
91
91
$ this ->appResource ->getTableName ('sales_sequence_meta ' ),
@@ -105,7 +105,7 @@ private function getMetadataIdsByStoreId($storeId)
105
105
*/
106
106
private function getProfileIdsByMetadataIds (array $ metadataIds )
107
107
{
108
- $ connection = $ this ->appResource ->getConnection ();
108
+ $ connection = $ this ->appResource ->getConnection (' sales ' );
109
109
$ select = $ connection ->select ()
110
110
->from (
111
111
$ this ->appResource ->getTableName ('sales_sequence_profile ' ),
0 commit comments