wbrawner/server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Group database connection and schema function

Browse source
This commit is contained in:
Bart Visscher 2013-02-26 17:39:13 +01:00
parent 013333fe6a
commit de83bf98c7
1 changed files with 27 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

54
lib/db.php
View file

@ -285,6 +285,33 @@ class OC_DB {
return self::$connection->lastInsertId($table);
}
/**
* @brief Insert a row if a matching row doesn't exists.
* @param string $table. The table to insert into in the form '*PREFIX*tableName'
* @param array $input. An array of fieldname/value pairs
* @returns int number of updated rows
*/
public static function insertIfNotExist($table, $input) {
self::connect();
return self::$connection->insertIfNotExist($table, $input);
}
/**
* Start a transaction
*/
public static function beginTransaction() {
self::connect();
self::$connection->beginTransaction();
}
/**
* Commit the database changes done during a transaction that is in progress
*/
public static function commit() {
self::connect();
self::$connection->commit();
}
/**
* @brief Disconnect
*
@ -340,17 +367,6 @@ class OC_DB {
return $result;
}
/**
* @brief Insert a row if a matching row doesn't exists.
* @param string $table. The table to insert into in the form '*PREFIX*tableName'
* @param array $input. An array of fieldname/value pairs
* @returns int number of updated rows
*/
public static function insertIfNotExist($table, $input) {
self::connect();
return self::$connection->insertIfNotExist($table, $input);
}
/**
* @brief drop a table
* @param string $tableName the table to drop
@ -378,22 +394,6 @@ class OC_DB {
OC_DB_Schema::replaceDB(self::$connection, $file);
}
/**
* Start a transaction
*/
public static function beginTransaction() {
self::connect();
self::$connection->beginTransaction();
}
/**
* Commit the database changes done during a transaction that is in progress
*/
public static function commit() {
self::connect();
self::$connection->commit();
}
/**
* check if a result is an error, works with Doctrine
* @param mixed $result