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

Replace \OC_DB by \OCP\DB (need tests)

Browse Source
This commit is contained in:
Loic Blot 2014-10-06 13:41:18 +02:00
parent 3ce5b7a69d
commit 5b333a0091
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
db/smsmapper.php
View File

@ -33,7 +33,7 @@ class SmsMapper extends Mapper {
} }
public function getAllIds ($userId) { public function getAllIds ($userId) {
$query = \OC_DB::prepare('SELECT sms_id, sms_mailbox FROM ' . $query = \OCP\DB::prepare('SELECT sms_id, sms_mailbox FROM ' .
'*PREFIX*ocsms_smsdatas WHERE user_id = ?'); '*PREFIX*ocsms_smsdatas WHERE user_id = ?');
$result = $query->execute(array($userId)); $result = $query->execute(array($userId));
@ -52,7 +52,7 @@ class SmsMapper extends Mapper {
} }
public function getAllPeersPhoneNumbers ($userId) { public function getAllPeersPhoneNumbers ($userId) {
$query = \OC_DB::prepare('SELECT sms_address FROM ' . $query = \OCP\DB::prepare('SELECT sms_address FROM ' .
'*PREFIX*ocsms_smsdatas WHERE user_id = ? AND sms_mailbox IN (?,?)'); '*PREFIX*ocsms_smsdatas WHERE user_id = ? AND sms_mailbox IN (?,?)');
$result = $query->execute(array($userId, 0, 1)); $result = $query->execute(array($userId, 0, 1));
@ -66,7 +66,7 @@ class SmsMapper extends Mapper {
} }
public function getAllMessagesForPhoneNumber ($userId, $phoneNumber, $minDate = 0) { public function getAllMessagesForPhoneNumber ($userId, $phoneNumber, $minDate = 0) {
$query = \OC_DB::prepare('SELECT sms_date, sms_msg, sms_type FROM ' . $query = \OCP\DB::prepare('SELECT sms_date, sms_msg, sms_type FROM ' .
'*PREFIX*ocsms_smsdatas WHERE user_id = ? AND sms_address = ? ' . '*PREFIX*ocsms_smsdatas WHERE user_id = ? AND sms_address = ? ' .
'AND sms_mailbox IN (?,?) AND sms_date > ?'); 'AND sms_mailbox IN (?,?) AND sms_date > ?');
$result = $query->execute(array($userId, $phoneNumber, 0, 1, $minDate)); $result = $query->execute(array($userId, $phoneNumber, 0, 1, $minDate));
@ -86,7 +86,7 @@ class SmsMapper extends Mapper {
\OCP\DB::beginTransaction(); \OCP\DB::beginTransaction();
if ($purgeAllSmsBeforeInsert === true) { if ($purgeAllSmsBeforeInsert === true) {
$query = \OC_DB::prepare('DELETE FROM *PREFIX*ocsms_smsdatas ' . $query = \OCP\DB::prepare('DELETE FROM *PREFIX*ocsms_smsdatas ' .
'WHERE user_id = ?'); 'WHERE user_id = ?');
$result = $query->execute(array($userId)); $result = $query->execute(array($userId));
} }
@ -101,14 +101,14 @@ class SmsMapper extends Mapper {
if ($purgeAllSmsBeforeInsert === false) { if ($purgeAllSmsBeforeInsert === false) {
// Remove previous record // Remove previous record
// @ TODO: only update the required fields, getAllIds can be useful // @ TODO: only update the required fields, getAllIds can be useful
$query = \OC_DB::prepare('DELETE FROM *PREFIX*ocsms_smsdatas ' . $query = \OCP\DB::prepare('DELETE FROM *PREFIX*ocsms_smsdatas ' .
'WHERE user_id = ? AND sms_id = ?'); 'WHERE user_id = ? AND sms_id = ?');
$result = $query->execute(array( $result = $query->execute(array(
$userId, (int) $sms["_id"] $userId, (int) $sms["_id"]
)); ));
} }
$query = \OC_DB::prepare('INSERT INTO *PREFIX*ocsms_smsdatas ' . $query = \OCP\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 ' .
'(?,?,?,?,?,?,?,?,?,?)'); '(?,?,?,?,?,?,?,?,?,?)');