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

Use transaction before writing to database

Browse Source
This commit is contained in:
Loic Blot 2014-09-15 13:31:32 +02:00
parent cfc94b253f
commit 3ea5fee350
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
db/smsmapper.php
View File

@ -20,14 +20,14 @@ class SmsMapper extends Mapper {
parent::__construct($db, 'ocsms_smsdatas'); parent::__construct($db, 'ocsms_smsdatas');
} }
// @TODO
public function writeToDB($userId, $smsList) { public function writeToDB($userId, $smsList) {
\OCP\DB::beginTransaction();
foreach ($smsList as $sms) { foreach ($smsList as $sms) {
$smsFlags = sprintf("%s%s", $smsFlags = sprintf("%s%s",
$sms["read"] === "true" ? "1" : "0", $sms["read"] === "true" ? "1" : "0",
$sms["seen"] === "true" ? "1" : "0" $sms["seen"] === "true" ? "1" : "0"
); );
$query = \OC_DB::prepare('INSERT INTO *PREFIX*ocsms_smsdatas ' . $query = \OC_DB::prepare('INSERT INTO *PREFIX*ocsms_smsdatas ' .
'(user_id, added, lastmodified, sms_flags, sms_date, sms_id,' . '(user_id, added, lastmodified, sms_flags, sms_date, sms_id,' .
'sms_address, sms_msg, sms_mailbox, sms_type) VALUES ' . 'sms_address, sms_msg, sms_mailbox, sms_type) VALUES ' .
@ -38,7 +38,10 @@ class SmsMapper extends Mapper {
$sms["address"], $sms["body"], (int) $sms["mbox"], $sms["address"], $sms["body"], (int) $sms["mbox"],
(int) $sms["type"] (int) $sms["type"]
)); ));
} }
\OCP\DB::commit();
} }
public function find($id) { public function find($id) {