}
// do nothing if the connection already has been established
- if(!self::$connection) {
+ if (!self::$connection) {
$config = new \Doctrine\DBAL\Configuration();
switch($type) {
case 'sqlite':
return false;
}
$connectionParams['wrapperClass'] = 'OC\DB\Connection';
- $connectionParams['table_prefix'] = OC_Config::getValue( "dbtableprefix", "oc_" );
+ $connectionParams['tablePrefix'] = OC_Config::getValue('dbtableprefix', 'oc_' );
try {
self::$connection = \Doctrine\DBAL\DriverManager::getConnection($connectionParams, $config);
if ($type === 'sqlite' || $type === 'sqlite3') {
// return the result
try {
- $result=self::$connection->prepare($query, $limit, $offset);
- } catch(\Doctrine\DBAL\DBALException $e) {
+ $result = self::$connection->prepare($query, $limit, $offset);
+ } catch (\Doctrine\DBAL\DBALException $e) {
throw new \DatabaseException($e->getMessage(), $query);
}
// differentiate between query and manipulation
- $result=new OC_DB_StatementWrapper($result, $isManipulation);
+ $result = new OC_DB_StatementWrapper($result, $isManipulation);
return $result;
}
* @return bool
*/
static public function isManipulation( $sql ) {
- $selectOccurrence = stripos ($sql, "SELECT");
+ $selectOccurrence = stripos($sql, 'SELECT');
if ($selectOccurrence !== false && $selectOccurrence < 10) {
return false;
}
- $insertOccurrence = stripos ($sql, "INSERT");
+ $insertOccurrence = stripos($sql, 'INSERT');
if ($insertOccurrence !== false && $insertOccurrence < 10) {
return true;
}
- $updateOccurrence = stripos ($sql, "UPDATE");
+ $updateOccurrence = stripos($sql, 'UPDATE');
if ($updateOccurrence !== false && $updateOccurrence < 10) {
return true;
}
- $deleteOccurrence = stripos ($sql, "DELETE");
+ $deleteOccurrence = stripos($sql, 'DELETE');
if ($deleteOccurrence !== false && $deleteOccurrence < 10) {
return true;
}
class Connection extends \Doctrine\DBAL\Connection {
/**
- * @var string $table_prefix
+ * @var string $tablePrefix
*/
- protected $table_prefix;
+ protected $tablePrefix;
/**
* @var \OC\DB\Adapter $adapter
if (!isset($params['adapter'])) {
throw new \Exception('adapter not set');
}
- if (!isset($params['table_prefix'])) {
- throw new \Exception('table_prefix not set');
+ if (!isset($params['tablePrefix'])) {
+ throw new \Exception('tablePrefix not set');
}
parent::__construct($params, $driver, $config, $eventManager);
$this->adapter = new $params['adapter']($this);
- $this->table_prefix = $params['table_prefix'];
+ $this->tablePrefix = $params['tablePrefix'];
}
/**
* @return string
*/
protected function replaceTablePrefix($statement) {
- return str_replace( '*PREFIX*', $this->table_prefix, $statement );
+ return str_replace( '*PREFIX*', $this->tablePrefix, $statement );
}
public function enableQueryStatementCaching() {