flywithu/ocsms
1
0
Fork 0
mirror of https://github.com/nerzhul/ocsms.git synced 2025-06-08 00:16:24 +00:00
Code Issues Releases Wiki Activity

Use DB transaction methods of the DB connection (#225)

Browse Source 
Signed-off-by: Morris Jobke <hey@morrisjobke.de>
This commit is contained in:
Morris Jobke 2018-03-21 12:17:22 +01:00 committed by Loïc Blot
parent 005f761d9e
commit c33d871bf0
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
db/conversationstatemapper.php
View File

@ -52,7 +52,7 @@ class ConversationStateMapper extends Mapper {
} }
public function setLast ($userId, $phoneNumber, $lastDate) { public function setLast ($userId, $phoneNumber, $lastDate) {
\OCP\DB::beginTransaction(); $this->db->beginTransaction();
$query = \OCP\DB::prepare('DELETE FROM *PREFIX*ocsms_conversation_read_states ' . $query = \OCP\DB::prepare('DELETE FROM *PREFIX*ocsms_conversation_read_states ' .
'WHERE user_id = ? AND phone_number = ?'); 'WHERE user_id = ? AND phone_number = ?');
$query->execute(array($userId, $phoneNumber)); $query->execute(array($userId, $phoneNumber));
@ -61,7 +61,7 @@ class ConversationStateMapper extends Mapper {
'(user_id, phone_number, int_date) VALUES ' . '(user_id, phone_number, int_date) VALUES ' .
'(?,?,?)'); '(?,?,?)');
$query->execute(array($userId, $phoneNumber, $lastDate)); $query->execute(array($userId, $phoneNumber, $lastDate));
\OCP\DB::commit(); $this->db->commit();
} }
/* /*

12
db/smsmapper.php
View File

@ -182,23 +182,23 @@ class SmsMapper extends Mapper {
} }
public function removeMessagesForPhoneNumber ($userId, $phoneNumber) { public function removeMessagesForPhoneNumber ($userId, $phoneNumber) {
\OCP\DB::beginTransaction(); $this->db->beginTransaction();
$query = \OCP\DB::prepare('DELETE FROM ' . $query = \OCP\DB::prepare('DELETE FROM ' .
'*PREFIX*ocsms_smsdatas WHERE user_id = ? AND sms_address = ?'); '*PREFIX*ocsms_smsdatas WHERE user_id = ? AND sms_address = ?');
$query->execute(array($userId, $phoneNumber)); $query->execute(array($userId, $phoneNumber));
\OCP\DB::commit(); $this->db->commit();
} }
/* /*
* WARN: messageId is sms_date here * WARN: messageId is sms_date here
*/ */
public function removeMessage ($userId, $phoneNumber, $messageId) { public function removeMessage ($userId, $phoneNumber, $messageId) {
\OCP\DB::beginTransaction(); $this->db->beginTransaction();
$query = \OCP\DB::prepare('DELETE FROM ' . $query = \OCP\DB::prepare('DELETE FROM ' .
'*PREFIX*ocsms_smsdatas WHERE user_id = ? AND sms_address = ? ' . '*PREFIX*ocsms_smsdatas WHERE user_id = ? AND sms_address = ? ' .
'AND sms_date = ?'); 'AND sms_date = ?');
$query->execute(array($userId, $phoneNumber, $messageId)); $query->execute(array($userId, $phoneNumber, $messageId));
\OCP\DB::commit(); $this->db->commit();
} }
public function getLastMessageTimestampForAllPhonesNumbers ($userId, $order = true) { public function getLastMessageTimestampForAllPhonesNumbers ($userId, $order = true) {
@ -253,7 +253,7 @@ class SmsMapper extends Mapper {
} }
public function writeToDB ($userId, $smsList, $purgeAllSmsBeforeInsert = false) { public function writeToDB ($userId, $smsList, $purgeAllSmsBeforeInsert = false) {
\OCP\DB::beginTransaction(); $this->db->beginTransaction();
if ($purgeAllSmsBeforeInsert === true) { if ($purgeAllSmsBeforeInsert === true) {
$query = \OCP\DB::prepare('DELETE FROM *PREFIX*ocsms_smsdatas ' . $query = \OCP\DB::prepare('DELETE FROM *PREFIX*ocsms_smsdatas ' .
@ -292,7 +292,7 @@ class SmsMapper extends Mapper {
} }
\OCP\DB::commit(); $this->db->commit();
} }
} }