summaryrefslogtreecommitdiffstats
path: root/lib/migration/content.php
diff options
context:
space:
mode:
Diffstat (limited to 'lib/migration/content.php')
-rw-r--r--lib/migration/content.php126
1 files changed, 63 insertions, 63 deletions
diff --git a/lib/migration/content.php b/lib/migration/content.php
index 7ef88f36e43..64b8168cd98 100644
--- a/lib/migration/content.php
+++ b/lib/migration/content.php
@@ -25,42 +25,42 @@
* provides methods to add and access data from the migration
*/
class OC_Migration_Content{
-
+
private $zip=false;
// Holds the MDB2 object
private $db=null;
// Holds an array of tmpfiles to delete after zip creation
private $tmpfiles=false;
-
+
/**
* @brief sets up the
* @param $zip ZipArchive object
* @param optional $db a MDB2 database object (required for exporttype user)
* @return bool
*/
- public function __construct( $zip, $db=null ){
+ public function __construct( $zip, $db=null ) {
$this->zip = $zip;
$this->db = $db;
-
- if( !is_null( $db ) ){
+
+ if( !is_null( $db ) ) {
// Get db path
$db = $this->db->getDatabase();
$this->tmpfiles[] = $db;
}
-
+
}
-
+
// @brief prepares the db
// @param $query the sql query to prepare
- public function prepare( $query ){
-
+ public function prepare( $query ) {
+
// Optimize the query
$query = $this->processQuery( $query );
-
+
// Optimize the query
$query = $this->db->prepare( $query );
-
+
// Die if we have an error (error means: bad query, not 0 results!)
if( PEAR::isError( $query ) ) {
$entry = 'DB Error: "'.$result->getMessage().'"<br />';
@@ -68,17 +68,17 @@ class OC_Migration_Content{
OC_Log::write( 'migration', $entry, OC_Log::FATAL );
return false;
} else {
- return $query;
+ return $query;
}
-
+
}
-
+
/**
* @brief processes the db query
* @param $query the query to process
* @return string of processed query
*/
- private function processQuery( $query ){
+ private function processQuery( $query ) {
$query = str_replace( '`', '\'', $query );
$query = str_replace( 'NOW()', 'datetime(\'now\')', $query );
$query = str_replace( 'now()', 'datetime(\'now\')', $query );
@@ -86,30 +86,30 @@ class OC_Migration_Content{
$query = str_replace( '*PREFIX*', '', $query );
return $query;
}
-
+
/**
* @brief copys rows to migration.db from the main database
* @param $options array of options.
* @return bool
*/
- public function copyRows( $options ){
- if( !array_key_exists( 'table', $options ) ){
- return false;
+ public function copyRows( $options ) {
+ if( !array_key_exists( 'table', $options ) ) {
+ return false;
}
-
+
$return = array();
-
+
// Need to include 'where' in the query?
- if( array_key_exists( 'matchval', $options ) && array_key_exists( 'matchcol', $options ) ){
-
+ if( array_key_exists( 'matchval', $options ) && array_key_exists( 'matchcol', $options ) ) {
+
// If only one matchval, create an array
- if(!is_array($options['matchval'])){
- $options['matchval'] = array( $options['matchval'] );
+ if(!is_array($options['matchval'])) {
+ $options['matchval'] = array( $options['matchval'] );
}
-
- foreach( $options['matchval'] as $matchval ){
+
+ foreach( $options['matchval'] as $matchval ) {
// Run the query for this match value (where x = y value)
- $sql = "SELECT * FROM *PREFIX*" . $options['table'] . " WHERE " . $options['matchcol'] . " LIKE ?";
+ $sql = 'SELECT * FROM `*PREFIX*' . $options['table'] . '` WHERE `' . $options['matchcol'] . '` LIKE ?';
$query = OC_DB::prepare( $sql );
$results = $query->execute( array( $matchval ) );
$newreturns = $this->insertData( $results, $options );
@@ -118,33 +118,33 @@ class OC_Migration_Content{
} else {
// Just get everything
- $sql = "SELECT * FROM *PREFIX*" . $options['table'];
+ $sql = 'SELECT * FROM `*PREFIX*' . $options['table'] . '`';
$query = OC_DB::prepare( $sql );
$results = $query->execute();
$return = $this->insertData( $results, $options );
-
+
}
-
+
return $return;
-
+
}
-
+
/**
* @brief saves a sql data set into migration.db
* @param $data a sql data set returned from self::prepare()->query()
* @param $options array of copyRows options
* @return void
*/
- private function insertData( $data, $options ){
+ private function insertData( $data, $options ) {
$return = array();
// Foreach row of data to insert
- while( $row = $data->fetchRow() ){
+ while( $row = $data->fetchRow() ) {
// Now save all this to the migration.db
- foreach($row as $field=>$value){
+ foreach($row as $field=>$value) {
$fields[] = $field;
$values[] = $value;
}
-
+
// Generate some sql
$sql = "INSERT INTO `" . $options['table'] . '` ( `';
$fieldssql = implode( '`, `', $fields );
@@ -153,19 +153,19 @@ class OC_Migration_Content{
$sql .= $valuessql . " )";
// Make the query
$query = $this->prepare( $sql );
- if( !$query ){
- OC_Log::write( 'migration', 'Invalid sql produced: '.$sql, OC_Log::FATAL );
+ if( !$query ) {
+ OC_Log::write( 'migration', 'Invalid sql produced: '.$sql, OC_Log::FATAL );
return false;
exit();
} else {
$query->execute( $values );
// Do we need to return some values?
- if( array_key_exists( 'idcol', $options ) ){
+ if( array_key_exists( 'idcol', $options ) ) {
// Yes we do
- $return[] = $row[$options['idcol']];
+ $return[] = $row[$options['idcol']];
} else {
// Take a guess and return the first field :)
- $return[] = reset($row);
+ $return[] = reset($row);
}
}
$fields = '';
@@ -173,11 +173,11 @@ class OC_Migration_Content{
}
return $return;
}
-
+
/**
* @brief adds a directory to the zip object
* @param $dir string path of the directory to add
- * @param $recursive bool
+ * @param $recursive bool
* @param $internaldir string path of folder to add dir to in zip
* @return bool
*/
@@ -185,14 +185,14 @@ class OC_Migration_Content{
$dirname = basename($dir);
$this->zip->addEmptyDir($internaldir . $dirname);
$internaldir.=$dirname.='/';
- if( !file_exists( $dir ) ){
- return false;
+ if( !file_exists( $dir ) ) {
+ return false;
}
if ($dirhandle = opendir($dir)) {
while (false !== ( $file = readdir($dirhandle))) {
-
+
if (( $file != '.' ) && ( $file != '..' )) {
-
+
if (is_dir($dir . '/' . $file) && $recursive) {
$this->addDir($dir . '/' . $file, $recursive, $internaldir);
} elseif (is_file($dir . '/' . $file)) {
@@ -207,46 +207,46 @@ class OC_Migration_Content{
}
return true;
}
-
+
/**
* @brief adds a file to the zip from a given string
* @param $data string of data to add
* @param $path the relative path inside of the zip to save the file to
* @return bool
*/
- public function addFromString( $data, $path ){
+ public function addFromString( $data, $path ) {
// Create a temp file
$file = tempnam( get_temp_dir(). '/', 'oc_export_tmp_' );
$this->tmpfiles[] = $file;
- if( !file_put_contents( $file, $data ) ){
+ if( !file_put_contents( $file, $data ) ) {
OC_Log::write( 'migation', 'Failed to save data to a temporary file', OC_Log::ERROR );
- return false;
+ return false;
}
// Add file to the zip
$this->zip->addFile( $file, $path );
return true;
}
-
+
/**
* @brief closes the zip, removes temp files
* @return bool
*/
- public function finish(){
- if( !$this->zip->close() ){
+ public function finish() {
+ if( !$this->zip->close() ) {
OC_Log::write( 'migration', 'Failed to write the zip file with error: '.$this->zip->getStatusString(), OC_Log::ERROR );
- return false;
+ return false;
}
$this->cleanup();
- return true;
- }
-
+ return true;
+ }
+
/**
* @brief cleans up after the zip
*/
- private function cleanup(){
+ private function cleanup() {
// Delete tmp files
- foreach($this->tmpfiles as $i){
- unlink( $i );
- }
+ foreach($this->tmpfiles as $i) {
+ unlink( $i );
+ }
}
}
generated by cgit v1.2.3 (git 2.39.1) at 2025-02-22 12:15:00 +0000