@@ -28,7 +28,8 @@ class RevokedRepository implements RevokedRepositoryInterface
28
28
/**
29
29
* @param ResourceConnection $resourceConnection
30
30
*/
31
- public function __construct (ResourceConnection $ resourceConnection ) {
31
+ public function __construct (ResourceConnection $ resourceConnection )
32
+ {
32
33
$ this ->connection = $ resourceConnection ;
33
34
}
34
35
@@ -38,7 +39,7 @@ public function __construct(ResourceConnection $resourceConnection) {
38
39
public function saveRevoked (Revoked $ revoked ): void
39
40
{
40
41
$ conn = $ this ->getAdapter ();
41
- $ table = $ conn ->getTableName (self ::TABLE );
42
+ $ table = $ conn ->getTableName ($ this -> connection -> getTableName ( self ::TABLE ) );
42
43
43
44
$ conn ->insertOnDuplicate ($ table , $ revoked ->getData (), array_keys ($ revoked ->getData ()));
44
45
}
@@ -49,7 +50,7 @@ public function saveRevoked(Revoked $revoked): void
49
50
public function findRevoked (int $ userTypeId , int $ userId ): ?Revoked
50
51
{
51
52
$ conn = $ this ->getAdapter ();
52
- $ table = $ conn ->getTableName (self ::TABLE );
53
+ $ table = $ conn ->getTableName ($ this -> connection -> getTableName ( self ::TABLE ) );
53
54
54
55
$ data = $ conn ->fetchRow (
55
56
$ conn ->select ()
@@ -64,6 +65,11 @@ public function findRevoked(int $userTypeId, int $userId): ?Revoked
64
65
return null ;
65
66
}
66
67
68
+ /**
69
+ * Resource connection
70
+ *
71
+ * @return AdapterInterface
72
+ */
67
73
private function getAdapter (): AdapterInterface
68
74
{
69
75
return $ this ->connection ->getConnection (ResourceConnection::DEFAULT_CONNECTION );
0 commit comments